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.lison...@intel.com> Authored: Thu Apr 7 17:47:19 2016 -0700 Committer: Stephan Ewen <se...@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");
