[
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:
-
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