Fix JavaConsumerStrategySuite

apache · Jul 13, 2020 · 77fb2be · 77fb2be
1 parent 00eceec
commit 77fb2be
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...fka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java b/...fka-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<TopicPartition, Object> sOffsets =
-      JavaConverters.asScala(dummyOffsets);
+      JavaConverters.mapAsScalaMap(dummyOffsets);
 
     final ConsumerStrategy<String, String> sub1 =
       ConsumerStrategies.Subscribe(sTopics, sKafkaParams, sOffsets);