(flink-connector-kafka) branch main updated: [FLINK-40589][source/tests] Increase job failure timeout

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

MartijnVisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/main by this push:
     new 40dc2a79 [FLINK-40589][source/tests] Increase job failure timeout
40dc2a79 is described below

commit 40dc2a79bab7eb6576ec000f3905d8d987061e4d
Author: Efrat Levitan <efrat890...@gmail.com>
AuthorDate: Mon Sep 7 20:58:57 2026 +0300

    [FLINK-40589][source/tests] Increase job failure timeout
    
    Slow CI pipelines might not be able to schedule the job within the current 
2s timeout
---
 .../apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
index 2bf3712b..bd474246 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
@@ -66,7 +66,7 @@ public class SourceTopicIntegrityTest {
     private static final String SOURCE_TOPIC_PATTERN = 
"SourceTopicIntegrityTest_source.*";
     private static final String SINK_TOPIC_NAME = 
"SourceTopicIntegrityTest_sink-topic";
     private static final long DISCOVERY_INTERVAL = 50L;
-    private static final Duration ERROR_DISCOVERY_TIMEOUT = 
Duration.ofSeconds(2);
+    private static final Duration ERROR_DISCOVERY_TIMEOUT = 
Duration.ofSeconds(20);
     @TempDir private Path savepointBasePath;
 
     @RegisterExtension