Skip to content

build: upgrade Flink from 1.18.1 to 1.20.5 - #910

Open
romitshah02 wants to merge 3 commits into
Sunbird-Knowlg:v1.0.3from
romitshah02:flink-1.20.5
Open

build: upgrade Flink from 1.18.1 to 1.20.5#910
romitshah02 wants to merge 3 commits into
Sunbird-Knowlg:v1.0.3from
romitshah02:flink-1.20.5

Conversation

@romitshah02

@romitshah02 romitshah02 commented Jul 27, 2026

Copy link
Copy Markdown
Contributor

Upgrades Apache Flink from 1.18.1 to 1.20.5 across the full reactor (11 modules pinned via root pom.xml). Migrates every module off the deprecated flink-streaming-scala API (removed in Flink 2.0, FLINK-37248) onto the Java DataStream/StreamExecutionEnvironment/OutputTag/ProcessWindowFunction APIs, since job logic already used Java ProcessFunction/KeyedProcessFunction rather than Scala closures on Flink types.

Also bumps jobs-distribution/Dockerfile's base image and fs-plugin jar references from 1.18.1 to 1.20.5 (Flink dropped scala-suffixed image variants), and updates README.md's local-dev instructions (Flink download version, IntelliJ debug-mode temporary pom snippets) to match the new dependency shape.

Type of change

Please choose appropriate options.

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to not work as expected)
  • This change requires a documentation update

Test Configuration:

  • Software versions: Flink 1.20.5, Java 11, Scala 2.12, Maven 3.8+
  • Hardware versions: macOS (arm64)

Checklist:

  • My code follows the style guidelines of this project
  • I have performed a self-review of my own code
  • I have commented my code, particularly in hard-to-und
  • I have made corresponding changes to the documentation
  • My changes generate no new warnings
  • I have added tests that prove my fix is effective or that my feature works
  • New and existing unit tests pass locally with my chan
  • Any dependent changes have been merged and published in downstream modules

@coderabbitai

coderabbitai Bot commented Jul 27, 2026

Copy link
Copy Markdown

Important

Review skipped

Auto reviews are disabled on base/target branches other than the default branch.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Pro Plus

Run ID: c5e3b924-01ed-4dfd-9c15-05d809dc0477

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

  • 🔍 Trigger review
✨ Finishing Touches
🧪 Generate unit tests (beta)
  • Create PR with unit tests

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands.

@romitshah02 romitshah02 reopened this Jul 27, 2026
@romitshah02 romitshah02 changed the title Flink 1.20.5 build: upgrade Flink from 1.18.1 to 1.20.5 Jul 28, 2026
@romitshah02
romitshah02 marked this pull request as ready for review July 28, 2026 05:38
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant