[FLINK-35009] Change on getTransitivePredecessors breaks connectors

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Won't Fix
• Affects Version/s: 1.18.2, 1.20.0, 1.19.1
• Component/s: API / Core, Connectors / Kafka
• Assignee: Martijn Visser
• Reporter: Martijn Visser
• Created: 04/Apr/24 13:33
• Updated: 23/Apr/24 07:01
• Resolved: 23/Apr/24 07:01

Description

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

Example: https://github.com/apache/flink-connector-kafka/actions/runs/8494349338/job/23269406762#step:15:167

Issue Links

• is caused by: FLINK-32513 Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()
• mentioned in: Page Loading...