diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
index e4a1e4f77b..3a86352e42 100644
--- a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
+++ b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
@@ -395,7 +395,7 @@ class KafkaTestUtils(
}
def getAllTopicsAndPartitionSize(): Seq[(String, Int)] = {
- zkClient.getPartitionsForTopics(zkClient.getAllTopicsInCluster).mapValues(_.size).toSeq
+ zkClient.getPartitionsForTopics(zkClient.getAllTopicsInCluster()).mapValues(_.size).toSeq
}
/** Create a Kafka topic and wait until it is propagated to the whole cluster */
@@ -587,7 +587,7 @@ class KafkaTestUtils(
}), s"checkpoint for topic $topic still exists")
// ensure the topic is gone
assert(
- !zkClient.getAllTopicsInCluster.contains(topic),
+ !zkClient.getAllTopicsInCluster().contains(topic),
s"topic $topic still exists on zookeeper")
}
diff --git a/pom.xml b/pom.xml
index 6b72e7d136..e414835d8d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -133,7 +133,7 @@
2.3
- 2.5.0
+ 2.6.0
10.12.1.1
1.10.1
1.5.10