Repository: flink Updated Branches: refs/heads/release-1.3 1651482ae -> e0dbe858a
[hotfix] [kafka] Fix the config parameter names in KafkaTestBase. This closes #4804. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0dbe858 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e0dbe858 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e0dbe858 Branch: refs/heads/release-1.3 Commit: e0dbe858a3a8a93bb92cdaba39b906fb67480575 Parents: 1651482 Author: Xingcan Cui <[email protected]> Authored: Wed Oct 11 21:58:50 2017 +0800 Committer: zentol <[email protected]> Committed: Wed Oct 11 23:57:49 2017 +0200 ---------------------------------------------------------------------- .../apache/flink/streaming/connectors/kafka/KafkaTestBase.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/e0dbe858/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java index d70797e..c030946 100644 --- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java +++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java @@ -121,8 +121,8 @@ public abstract class KafkaTestBase extends TestLogger { protected static Configuration getFlinkConfiguration() { Configuration flinkConfig = new Configuration(); - flinkConfig.setString(AkkaOptions.WATCH_HEARTBEAT_PAUSE, "5 s"); - flinkConfig.setString(AkkaOptions.WATCH_HEARTBEAT_INTERVAL, "1 s"); + flinkConfig.setString(AkkaOptions.AKKA_WATCH_HEARTBEAT_PAUSE, "5 s"); + flinkConfig.setString(AkkaOptions.AKKA_WATCH_HEARTBEAT_INTERVAL, "1 s"); flinkConfig.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, NUM_TMS); flinkConfig.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, TM_SLOTS); flinkConfig.setLong(TaskManagerOptions.MANAGED_MEMORY_SIZE, 16L);
