Repository: flink Updated Branches: refs/heads/master 11fa089d6 -> 307eae6e2
[hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests This closes #2654 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/307eae6e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/307eae6e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/307eae6e Branch: refs/heads/master Commit: 307eae6e225f450ad953f1135e504e6d2e5b5d80 Parents: 11fa089 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Tue Oct 18 16:16:36 2016 +0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Wed Oct 26 15:45:57 2016 +0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/307eae6e/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java index c30a4dd..f15fd45 100644 --- a/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java +++ b/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java @@ -288,7 +288,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { ZkUtils zkUtils = getZkUtils(); try { - AdminUtils.createTopic(zkUtils, topic, numberOfPartitions, replicationFactor, topicConfig, new kafka.admin.RackAwareMode.Enforced$()); + AdminUtils.createTopic(zkUtils, topic, numberOfPartitions, replicationFactor, topicConfig, kafka.admin.RackAwareMode.Enforced$.MODULE$); } finally { zkUtils.close(); }
