[
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
[
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
[
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
[
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
[
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
[
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 --
> -
[
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 --
>
[
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 --
> ---
[
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
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
10 matches
Mail list logo