Skip to content

[FLINK-39317] Add Source e2e with Flink2.2.#4336

Closed
lvyanquan wants to merge 1 commit intoapache:masterfrom
lvyanquan:FLINK-39317
Closed

[FLINK-39317] Add Source e2e with Flink2.2.#4336
lvyanquan wants to merge 1 commit intoapache:masterfrom
lvyanquan:FLINK-39317

Conversation

@lvyanquan
Copy link
Contributor

[FLINK-39317] Add Source E2E with Flink 2.2

Summary

This PR adds support for running Source E2E tests with Flink 2.2, introducing Maven profiles to switch between Flink 1.x and Flink 2.x compatibility layers.

Changes

CI Configuration

  • Add new source_e2e_2_x job in GitHub workflow to run Source E2E tests with Flink 2.2.0
  • Use -Pflink2 Maven profile for Flink 2.x compatibility

Maven Profiles

Bug Fixes

  • Fix paimon artifact version variable: change ${flink.major.version} to ${paimon.flink.major.version} in pipeline e2e tests
  • Add missing createWriter(InitContext) method to StatefulSink interface in flink2-compat module

Affected Connectors

All SQL connectors now include the flink-cdc-flink*-compat dependency:

Test Plan

  • Source E2E tests pass with Flink 1.x (default profile)
  • Source E2E tests pass with Flink 2.2.0 (-Pflink2 profile)
  • CI workflow runs successfully for both profiles

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant