William Droste created SPARK-1722:
-------------------------------------
Summary: Unable to create KafkaStream
Key: SPARK-1722
URL: https://issues.apache.org/jira/browse/SPARK-1722
Project: Spark
Issue Type: Bug
Components: Streaming
Affects Versions: 1.0.0
Reporter: William Droste
Getting a NoSuchMethodError when creating a Kafka stream.
{code}
scala> val stream = KafkaUtils.createStream[String, ParameterMessage,
StringDecoder, ParameterMessageDecoder](
| ssc,
| kafkaParams,
| kafkaTopics,
| StorageLevel.MEMORY_ONLY_SER_2
| )
java.lang.NoSuchMethodError:
org.apache.spark.streaming.StreamingContext.getNewNetworkStreamId()I
at
org.apache.spark.streaming.dstream.NetworkInputDStream.<init>(NetworkInputDStream.scala:53)
at
org.apache.spark.streaming.kafka.KafkaInputDStream.<init>(KafkaInputDStream.scala:47)
at
org.apache.spark.streaming.kafka.KafkaUtils$.createStream(KafkaUtils.scala:74)
{code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
