flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-8022][kafka] Bump at-least-once timeout in tests
Date Mon, 27 Nov 2017 11:59:08 GMT
Repository: flink
Updated Branches:
  refs/heads/master 1119c48c2 -> da38a219a


[FLINK-8022][kafka] Bump at-least-once timeout in tests

Increasing timeout for reading the records from 30s to 60s seems to solve the issue
for failing at-least-one tests.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da38a219
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da38a219
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/da38a219

Branch: refs/heads/master
Commit: da38a219a9abf31f53318b2a902bd064bfd0a775
Parents: 1119c48
Author: Piotr Nowojski <piotr.nowojski@gmail.com>
Authored: Thu Nov 23 12:53:37 2017 +0100
Committer: Piotr Nowojski <piotr.nowojski@gmail.com>
Committed: Mon Nov 27 12:46:34 2017 +0100

----------------------------------------------------------------------
 .../streaming/connectors/kafka/KafkaProducerTestBase.java      | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/da38a219/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
index 7ba3c95..8104d8f 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
@@ -68,6 +68,8 @@ import static org.junit.Assert.fail;
 @SuppressWarnings("serial")
 public abstract class KafkaProducerTestBase extends KafkaTestBase {
 
+	private static final long KAFKA_READ_TIMEOUT = 60_000L;
+
 	/**
 	 * This tests verifies that custom partitioning works correctly, with a default topic
 	 * and dynamic topic. The number of partitions for each topic is deliberately different.
@@ -291,7 +293,7 @@ public abstract class KafkaProducerTestBase extends KafkaTestBase {
 				topic,
 				partition,
 				Collections.unmodifiableSet(new HashSet<>(getIntegersSequence(BrokerRestartingMapper.numElementsBeforeSnapshot))),
-				30000L);
+				KAFKA_READ_TIMEOUT);
 
 		deleteTestTopic(topic);
 	}
@@ -367,7 +369,7 @@ public abstract class KafkaProducerTestBase extends KafkaTestBase {
 			topic,
 			partition,
 			expectedElements,
-			30000L);
+			KAFKA_READ_TIMEOUT);
 
 		deleteTestTopic(topic);
 	}


Mime
View raw message