[ https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834799#comment-17834799 ]
Zhu Zhu commented on FLINK-35009: --------------------------------- Thanks for looking into the issue. [~Weijie Guo] So it is just a test class which uses Flink `@Internal` classes is broken. And that test class is even not used. I think it's better to just remove `MockTransformation` from kafka connector. WDYT? [~martijnvisser] > Change on getTransitivePredecessors breaks connectors > ----------------------------------------------------- > > Key: FLINK-35009 > URL: https://issues.apache.org/jira/browse/FLINK-35009 > Project: Flink > Issue Type: Bug > Components: API / Core, Connectors / Kafka > Affects Versions: 1.18.2, 1.20.0, 1.19.1 > Reporter: Martijn Visser > Priority: Blocker > > {code:java} > Error: Failed to execute goal > org.apache.maven.plugins:maven-compiler-plugin:3.8.0:testCompile > (default-testCompile) on project flink-connector-kafka: Compilation failure: > Compilation failure: > Error: > /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/DataGenerators.java:[214,24] > > org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator.MockTransformation > is not abstract and does not override abstract method > getTransitivePredecessorsInternal() in org.apache.flink.api.dag.Transformation > Error: > /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/DataGenerators.java:[220,44] > getTransitivePredecessors() in > org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator.MockTransformation > cannot override getTransitivePredecessors() in > org.apache.flink.api.dag.Transformation > Error: overridden method is final > {code} > Example: > https://github.com/apache/flink-connector-kafka/actions/runs/8494349338/job/23269406762#step:15:167 -- This message was sent by Atlassian Jira (v8.20.10#820010)