flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzuli...@apache.org
Subject flink git commit: [hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests
Date Wed, 26 Oct 2016 07:47:59 GMT
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 <tzulitai@apache.org>
Authored: Tue Oct 18 16:16:36 2016 +0800
Committer: Tzu-Li (Gordon) Tai <tzulitai@apache.org>
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();
 		}


Mime
View raw message