Skip to content

Conversation

@goyal-anshul
Copy link

@goyal-anshul goyal-anshul commented Nov 27, 2025

Why are the changes needed?

Close #171.

Brief change log

  • Upgrading Flink from 1.19 to 2.1
  • As part of the upgrade, some of the existing classes have been deprecated and removed. Adjusted all the breaking classes to their new counterpart in Flink 2.x.
  • I kept the OutputFormat functionality as it is, to minimize the overall changes. As a result, I added a new method open() that does the same as the previous open(int, int) method. Since the OutputFormat interface is updated, I had to keep the method open(InitializationContext) but it is unused.

How was this patch tested?

I generated the jar file locally using mvn clean package. I then used the generated jar file in my local flink-sql pipeline for testing.

  • Add some test cases that check the changes thoroughly including negative and positive cases if possible

  • Add screenshots for manual tests if appropriate

  • Run test locally before making a pull request

Documentation

  • Does this pull request introduce a new feature? (yes / no): no
  • If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)

@goyal-anshul goyal-anshul changed the title upgrading to flink 2.x [Fix] upgrading to flink 2.x Nov 27, 2025
@goyal-anshul goyal-anshul marked this pull request as ready for review November 27, 2025 14:26
@itinycheng itinycheng self-requested a review December 3, 2025 03:50
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.

Upgrade to Flink 2.x

1 participant