[jira] [Comment Edited] (SPARK-27833) java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark

2019-05-27 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849320#comment-16849320 ] Raviteja edited comment on SPARK-27833 at 5/28/19 4:25 AM: --- I

[jira] [Commented] (SPARK-27833) java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark

2019-05-27 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849320#comment-16849320 ] Raviteja commented on SPARK-27833: -- I have tried step by step, i faced the issue when i

[jira] [Commented] (SPARK-27833) java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847718#comment-16847718 ] Raviteja commented on SPARK-27833: -- yes, using Console sink works fine. But when i writ

[jira] [Updated] (SPARK-27833) Structured Streaming Custom Sink -- java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Summary: Structured Streaming Custom Sink -- java.lang.AssertionError: assertion failed: No plan for Eve

[jira] [Updated] (SPARK-27833) java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Summary: java.lang.AssertionError: assertion failed: No plan for EventTimeWatermark (was: Structured

[jira] [Updated] (SPARK-27833) Structured Streaming Custom Sink --

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Attachment: kafka_custom_sink.java > Structured Streaming Custom Sink -- > -

[jira] [Updated] (SPARK-27833) Structured Streaming Custom Sink --

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Attachment: kafka_error_log.txt > Structured Streaming Custom Sink -- >

[jira] [Updated] (SPARK-27833) Structured Streaming Custom Sink --

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Attachment: kafka_consumer_code.java > Structured Streaming Custom Sink -- > ---

[jira] [Updated] (SPARK-27833) Structured Streaming Custom Sink --

2019-05-24 Thread Raviteja (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-27833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raviteja updated SPARK-27833: - Docs Text: (was: 19/05/24 17:31:58 INFO ConsumerConfig: ConsumerConfig values: metric.reporter

[jira] [Created] (SPARK-27833) Structured Streaming Custom Sink --

2019-05-24 Thread Raviteja (JIRA)
Raviteja created SPARK-27833: Summary: Structured Streaming Custom Sink -- Key: SPARK-27833 URL: https://issues.apache.org/jira/browse/SPARK-27833 Project: Spark Issue Type: Bug Compone