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 aba45f5de678..8d7c05b5a615 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 @@ -50,8 +50,8 @@ public void testConsumerStrategyConstructors() { JavaConverters.mapAsScalaMapConverter(offsets).asScala(); // make sure constructors can be called from java - final ConsumerStrategy sub0 = - Subscribe.apply(topics, kafkaParams, offsets); + // final ConsumerStrategy sub0 = // does not compile in Scala 2.10 + // Subscribe.apply(topics, kafkaParams, offsets); final ConsumerStrategy sub1 = Subscribe.apply(sTopics, sKafkaParams, sOffsets); final ConsumerStrategy sub2 = @@ -65,8 +65,8 @@ public void testConsumerStrategyConstructors() { sub1.executorKafkaParams().get("bootstrap.servers"), sub3.executorKafkaParams().get("bootstrap.servers")); - final ConsumerStrategy asn0 = - Assign.apply(parts, kafkaParams, offsets); + // final ConsumerStrategy asn0 = // does not compile in Scala 2.10 + // Assign.apply(parts, kafkaParams, offsets); final ConsumerStrategy asn1 = Assign.apply(sParts, sKafkaParams, sOffsets); final ConsumerStrategy asn2 =