The GitHub Actions job "Build Docker Image" on flink-kubernetes-operator.git/FLINK-38381 has failed. Run started by GitHub user mxm (triggered by mxm).
Head commit for run: 63141159c1f115029508c7bffe9f5e2a9a861a5f / Maximilian Michels <[email protected]> [FLINK-38381] Enumerate Kafka partitions across Kafka clusters When using the DynamicKafkaSink, topics can be spread across multiple clusters. This used to work fine, but a regression has been added which considers partitions across different clusters to be identical. This limits the scale out of the source operator. Here is an example: ``` "1.Source__Kafka_Source_(testTopic).kafkaCluster.my-cluster-1.KafkaSourceReader.topic.testTopic.partition.0.currentOffset", "1.Source__Kafka_Source_(testTopic).kafkaCluster.my-cluster-2.KafkaSourceReader.topic.testTopic.partition.0.currentOffset" ``` Those would result be treated as one partition, but there are two partitions from separate kafka clusters. Report URL: https://github.com/apache/flink-kubernetes-operator/actions/runs/17830917564 With regards, GitHub Actions via GitBox
