diff options
| -rw-r--r-- | external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java | 8 |
1 files changed, 4 insertions, 4 deletions
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 aba45f5de6..8d7c05b5a6 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 class JavaConsumerStrategySuite implements Serializable { JavaConverters.mapAsScalaMapConverter(offsets).asScala(); // make sure constructors can be called from java - final ConsumerStrategy<String, String> sub0 = - Subscribe.<String, String>apply(topics, kafkaParams, offsets); + // final ConsumerStrategy<String, String> sub0 = // does not compile in Scala 2.10 + // Subscribe.<String, String>apply(topics, kafkaParams, offsets); final ConsumerStrategy<String, String> sub1 = Subscribe.<String, String>apply(sTopics, sKafkaParams, sOffsets); final ConsumerStrategy<String, String> sub2 = @@ -65,8 +65,8 @@ public class JavaConsumerStrategySuite implements Serializable { sub1.executorKafkaParams().get("bootstrap.servers"), sub3.executorKafkaParams().get("bootstrap.servers")); - final ConsumerStrategy<String, String> asn0 = - Assign.<String, String>apply(parts, kafkaParams, offsets); + // final ConsumerStrategy<String, String> asn0 = // does not compile in Scala 2.10 + // Assign.<String, String>apply(parts, kafkaParams, offsets); final ConsumerStrategy<String, String> asn1 = Assign.<String, String>apply(sParts, sKafkaParams, sOffsets); final ConsumerStrategy<String, String> asn2 = |