Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34149

Flink Kafka connector can't compile against 1.19-SNAPSHOT

    XMLWordPrintableJSON

Details

    Description

      The Flink Kafka connector for main fails for 1.19-SNAPSHOT, see https://github.com/apache/flink-connector-kafka/actions/runs/7569481434/job/20612876543#step:14:134

      Error:  COMPILATION ERROR : 
[INFO] -------------------------------------------------------------
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/StoppableKafkaEnumContextProxy.java:[65,8] org.apache.flink.connector.kafka.dynamic.source.enumerator.StoppableKafkaEnumContextProxy is not abstract and does not override abstract method setIsProcessingBacklog(boolean) in org.apache.flink.api.connector.source.SplitEnumeratorContext

      This interface seems to be added as part of https://issues.apache.org/jira/browse/FLINK-32514 / https://cwiki.apache.org/confluence/display/FLINK/FLIP-309%3A+Support+using+larger+checkpointing+interval+when+source+is+processing+backlog
      The FLIP indicates that the changes should be backward compatible, but that appears to have not been the case

      Attachments

        Issue Links

          is caused by

          New Feature - A new feature of the product, which has yet to be developed. FLINK-32514 FLIP-309: Support using larger checkpointing interval when source is processing backlog

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #24146

          Activity

            People

              yunfengzhou Yunfeng Zhou
              martijnvisser Martijn Visser
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: