[jira] [Comment Edited] (SPARK-13316) "SparkException: DStream has not been initialized" when restoring StreamingContext from checkpoint and the dstream is created afterwards

[ https://issues.apache.org/jira/browse/SPARK-13316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16311036#comment-16311036 ] Riccardo Vincelli edited comment on SPARK-13316 at 1/4/18 9:01 AM: ---

[jira] [Comment Edited] (SPARK-13316) "SparkException: DStream has not been initialized" when restoring StreamingContext from checkpoint and the dstream is created afterwards

[ https://issues.apache.org/jira/browse/SPARK-13316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16311036#comment-16311036 ] Riccardo Vincelli edited comment on SPARK-13316 at 1/4/18 9:01 AM: ---

[jira] [Commented] (SPARK-13316) "SparkException: DStream has not been initialized" when restoring StreamingContext from checkpoint and the dstream is created afterwards

[ https://issues.apache.org/jira/browse/SPARK-13316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16311036#comment-16311036 ] Riccardo Vincelli commented on SPARK-13316: --- Actually I am not completely sure this is cleared

[jira] [Comment Edited] (SPARK-19280) Failed Recovery from checkpoint caused by the multi-threads issue in Spark Streaming scheduler

[ https://issues.apache.org/jira/browse/SPARK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330558#comment-16330558 ] Riccardo Vincelli edited comment on SPARK-19280 at 1/18/18 2:20 PM:

[jira] [Commented] (SPARK-19280) Failed Recovery from checkpoint caused by the multi-threads issue in Spark Streaming scheduler

[ https://issues.apache.org/jira/browse/SPARK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330558#comment-16330558 ] Riccardo Vincelli commented on SPARK-19280: --- What is the exception you are getting? For me it

[jira] [Commented] (SPARK-19280) Failed Recovery from checkpoint caused by the multi-threads issue in Spark Streaming scheduler

[ https://issues.apache.org/jira/browse/SPARK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16335756#comment-16335756 ] Riccardo Vincelli commented on SPARK-19280: --- A decent workaround if stateful serialized streams

[jira] [Commented] (SPARK-19275) Spark Streaming, Kafka receiver, "Failed to get records for ... after polling for 512"

[ https://issues.apache.org/jira/browse/SPARK-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348996#comment-16348996 ] Riccardo Vincelli commented on SPARK-19275: --- Hi, I would like to point out that a timeout could

[jira] [Commented] (SPARK-20436) NullPointerException when restart from checkpoint file

[ https://issues.apache.org/jira/browse/SPARK-20436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16311402#comment-16311402 ] Riccardo Vincelli commented on SPARK-20436: --- I have tested this myself and it seems that this

[jira] [Commented] (SPARK-10908) ClassCastException in HadoopRDD.getJobConf

[ https://issues.apache.org/jira/browse/SPARK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382241#comment-16382241 ] Riccardo Vincelli commented on SPARK-10908: --- Hi, I am encountering this as well, running two

[jira] [Comment Edited] (SPARK-10908) ClassCastException in HadoopRDD.getJobConf

[ https://issues.apache.org/jira/browse/SPARK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382241#comment-16382241 ] Riccardo Vincelli edited comment on SPARK-10908 at 3/1/18 4:19 PM: --- Hi,

[jira] [Comment Edited] (SPARK-10908) ClassCastException in HadoopRDD.getJobConf

[ https://issues.apache.org/jira/browse/SPARK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16382241#comment-16382241 ] Riccardo Vincelli edited comment on SPARK-10908 at 3/1/18 4:19 PM: --- Hi,

[jira] [Issue Comment Deleted] (SPARK-10908) ClassCastException in HadoopRDD.getJobConf

[ https://issues.apache.org/jira/browse/SPARK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Riccardo Vincelli updated SPARK-10908: -- Comment: was deleted (was: Hi, I am encountering this as well, running two local Spark