[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/af799883 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/af799883 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/af799883 Branch: refs/heads/master Commit: af799883371b7a78c48f227b25b7a0b099dabf93 Parents: 3c93103 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 01:10:54 2016 +0200 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/KafkaConsumerTestBase.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/af799883/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 aa5344b..dd468a4 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 @@ -152,6 +152,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");
