[
https://issues.apache.org/jira/browse/SPARK-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386313#comment-14386313
]
Saisai Shao commented on SPARK-6594:
------------------------------------
Hi [~q79969786], would you please paste more warning logs. From your code it is
hard to find the problem why Spark Streaming cannot receive data. Also would
you please let us know what's version of Spark you're using?
I guess mostly this issue is probably your misuse of Spark Streaming and Kafka,
since lots of guys use Kafka + Spark Streaming, if this is a bug, it will be
reported out soon.
> Spark Streaming can't receive data from kafka
> ---------------------------------------------
>
> Key: SPARK-6594
> URL: https://issues.apache.org/jira/browse/SPARK-6594
> Project: Spark
> Issue Type: Bug
> Affects Versions: 1.2.1
> Environment: kafka_2.10-0.8.1.1 + Spark-1.2.1
> Reporter: q79969786
>
> I use KafkaUtils to receive data from Kafka In my Spark streaming application
> as follows:
> Map<String, Integer> topicorder = new HashMap<String, Integer>();
> topicorder.put("order", Integer.valueOf(readThread));
> JavaPairReceiverInputDStream<String, String> jPRIDSOrder =
> KafkaUtils.createStream(jssc, zkQuorum, group, topicorder);
> It worked well at fist, but after I submit this application several times,
> Spark streaming can‘t receive data anymore(Kafka works well).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
