[
https://issues.apache.org/jira/browse/SPARK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hyukjin Kwon updated SPARK-21378:
-
Labels: bulk-closed (was: )
> Spark Poll timeout when specific offsets are passed
> ---
[
https://issues.apache.org/jira/browse/SPARK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shixiong Zhu updated SPARK-21378:
-
Component/s: (was: Spark Core)
DStreams
> Spark Poll timeout when specific o
[
https://issues.apache.org/jira/browse/SPARK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ambud Sharma updated SPARK-21378:
-
Description:
Kafka direct stream fails with poll timeout:
{code:java}
JavaInputDStream> stream =
[
https://issues.apache.org/jira/browse/SPARK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ambud Sharma updated SPARK-21378:
-
Description:
Kafka direct stream fails with poll timeout:
{code:java}
JavaInputDStream> stream =
[
https://issues.apache.org/jira/browse/SPARK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ambud Sharma updated SPARK-21378:
-
Description:
Kafka direct stream fails with poll timeout:
{code:java}
JavaInputDStream> stream =