flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker() will pass before JUnit timeout
Date Wed, 13 Apr 2016 08:49:34 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.0 ff38202ba -> ea50ed348


[FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker() will pass
before JUnit timeout

This closes #1864


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

Branch: refs/heads/release-1.0
Commit: ea50ed348ccd34a343ebc501f989593253179774
Parents: ff38202
Author: Todd Lisonbee <todd.lisonbee@intel.com>
Authored: Thu Apr 7 17:47:19 2016 -0700
Committer: Stephan Ewen <sewen@apache.org>
Committed: Wed Apr 13 10:48:39 2016 +0200

----------------------------------------------------------------------
 .../flink/streaming/connectors/kafka/KafkaConsumerTestBase.java     | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/ea50ed34/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
----------------------------------------------------------------------
diff --git a/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
b/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
index 9377cee..f31e4f1 100644
--- a/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
+++ b/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
@@ -147,6 +147,7 @@ public abstract class KafkaConsumerTestBase extends KafkaTestBase {
 			properties.setProperty("zookeeper.connect", "localhost:80");
 			properties.setProperty("group.id", "test");
 			properties.setProperty("request.timeout.ms", "3000"); // let the test fail fast
+			properties.setProperty("socket.timeout.ms", "3000");
 			properties.setProperty("session.timeout.ms", "2000");
 			properties.setProperty("fetch.max.wait.ms", "2000");
 			properties.setProperty("heartbeat.interval.ms", "1000");


Mime
View raw message