diff --git a/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java b/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java index 7f62e1359c9f8..3d6e5ebe978e8 100644 --- a/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java +++ b/external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java @@ -53,7 +53,7 @@ public void testConsumerStrategyConstructors() { dummyOffsets.put(kv.getKey(), kv.getValue()); } final scala.collection.Map sOffsets = - JavaConverters.asScala(dummyOffsets); + JavaConverters.mapAsScalaMap(dummyOffsets); final ConsumerStrategy sub1 = ConsumerStrategies.Subscribe(sTopics, sKafkaParams, sOffsets);