Skip to content

Upgrade Flink connector to Flink 2.2 and Java 17#424

Open
nicolaspa1 wants to merge 1 commit into
GoogleCloudPlatform:masterfrom
nicolaspa1:upgrade-flink-2.2-java-17
Open

Upgrade Flink connector to Flink 2.2 and Java 17#424
nicolaspa1 wants to merge 1 commit into
GoogleCloudPlatform:masterfrom
nicolaspa1:upgrade-flink-2.2-java-17

Conversation

@nicolaspa1

@nicolaspa1 nicolaspa1 commented Jun 22, 2026

Copy link
Copy Markdown

Summary

Minimal upgrade to support Apache Flink 2.2 and Java 17:

  • flink-connector/pom.xml: bump Flink 1.17.2 → 2.2.0, Java 11 → 17
  • flink-connector-gcp-pubsub/pom.xml: bump protoc 3.4.0 → 3.25.3
    (required for Flink 2.2 compatibility)
  • PubSubSink.java: update createWriter signature from InitContext
    to WriterInitContext (API change in Flink 2.x / FLIP-143)

Motivation

Flink 2.x renamed Sink.InitContext to WriterInitContext as part of
the FLIP-143 unified sink API. Without this change the connector fails
to compile against Flink 2.2+.

This was validated end-to-end on GCP Dataproc 3.0 (Flink 2.2.0,
Java 17) consuming real Pub/Sub topics in a streaming pipeline
(cross-project subscriptions).

Testing

  • Compiled and ran against Flink 2.2.0 on Dataproc 3.0-debian13
  • Streaming job processed messages from Pub/Sub cross-project
    subscriptions successfully with PubSubSource (FLIP-27) and
    PubSubSink (FLIP-143)
  • All existing tests pass

@google-cla

google-cla Bot commented Jun 22, 2026

Copy link
Copy Markdown

Thanks for your pull request! It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA).

View this failed invocation of the CLA check for more information.

For the most up to date status, view the checks section at the bottom of the pull request.

@nicolaspa1 nicolaspa1 force-pushed the upgrade-flink-2.2-java-17 branch from 106e7cf to f7eda64 Compare June 22, 2026 21:18
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