[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16147419#comment-16147419 ] Pablo Panero commented on SPARK-21453: -- [~zsxwing] Failed again but not even there is conext around

[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119988#comment-16119988 ] Pablo Panero commented on SPARK-21453: -- [~zsxwing] Concerning the cached consumer failure all I

[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114071#comment-16114071 ] Pablo Panero commented on SPARK-21453: -- Yes! the job has been launched on debug mode. Ill send the

[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114033#comment-16114033 ] Pablo Panero commented on SPARK-21453: -- [~zsxwing] Yes, I definitely can. No worries, I just did

[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114025#comment-16114025 ] Pablo Panero commented on SPARK-21453: -- [~zsxwing] Yes, I understand. However due to the verbosity

[jira] [Commented] (SPARK-21453) Cached Kafka consumer may be closed too early

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114015#comment-16114015 ] Pablo Panero commented on SPARK-21453: -- [~zsxwing] {code} 17/07/26 13:28:32 ERROR Executor:

[jira] [Commented] (SPARK-21453) Streaming kafka source (structured spark)

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091353#comment-16091353 ] Pablo Panero commented on SPARK-21453: -- [~srowen] could you point me to the mailing list? I checked

[jira] [Updated] (SPARK-21453) Streaming kafka source (structured spark)

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Panero updated SPARK-21453: - Description: On a streaming job using built-in kafka source and sink (over SSL), with I am

[jira] [Updated] (SPARK-21453) Streaming kafka source (structured spark)

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Panero updated SPARK-21453: - Description: On a streaming job using built-in kafka source and sink (over SSL), with I am

[jira] [Created] (SPARK-21453) Streaming kafka source (structured spark)

Pablo Panero created SPARK-21453: Summary: Streaming kafka source (structured spark) Key: SPARK-21453 URL: https://issues.apache.org/jira/browse/SPARK-21453 Project: Spark Issue Type: Bug

[jira] [Updated] (SPARK-21453) Streaming kafka source (structured spark)

[ https://issues.apache.org/jira/browse/SPARK-21453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Panero updated SPARK-21453: - Description: On a streaming job using built-in kafka source and sink (over SSL), with I am