The GitHub Actions job "Build" on rocketmq-flink.git/issue-155-new-api-migration has failed. Run started by GitHub user lizhimins (triggered by lizhimins).
Head commit for run: dc5a5786ccba398150bd6689ac3496faa6f19d04 / lizhimins <[email protected]> [ISSUE #155] refactor: migrate to the new Source/Sink API only Flink 2.x removed SourceFunction, SinkFunction, TwoPhaseCommittingSink, TableSchema and the ConfigOption-typed Configuration accessors. The connector still ships the legacy implementations next to the FLIP-27 / sink2 ones, so it cannot compile against 2.x and every fix lands twice. Following apache/flink-connector-kafka (new API only, zero legacy, version differences isolated in branches), migrate the shared codebase to the new API while staying on Flink 1.20.3 / Java 11: - Delete the legacy source/sink paths and their tests; the FLIP-27 Source and the sink2 Sink + SupportsCommitter become the only runtime paths. The SQL factory keeps accepting the existing DDL options but resolves them to the new implementations. - TableSchema / SchemaValidator -> ResolvedSchema; Configuration getXxx(ConfigOption) / setXxx -> get / set. - Sink.InitContext and TypeInformation.createSerializer(ExecutionConfig) are still abstract in 1.20; implement the deprecated overloads as delegations. The 1.20 runtime calls the WriterInitContext / SerializerConfig overloads, so the main code path is already the 2.x one. - The async-send bounding and seek-retry behavior of #154 is preserved. Semantics are unchanged: at-least-once / exactly-once guarantees, offset management from Flink state, checkpoint-aligned transaction commits and the #154 permit accounting all stay as they are; this is an API migration, not a behavior change. Verified: mvn clean install green on JDK 17 targeting Java 11 (remoting 146 / grpc 80 unit tests, checkstyle and spotless clean), both SQL fat-jars produced. This is the branch point for the 1.x maintenance line (#155): a follow-up commit switches main to Flink 2.2.1 / Java 17 by flipping flink.version and dropping the deprecated-overload bridges above. Report URL: https://github.com/apache/rocketmq-flink/actions/runs/41416726995 With regards, GitHub Actions via GitBox
