Siying Dong created SPARK-48383:
-----------------------------------
Summary: In KafkaOffsetReader, partition mismatch should not be an
assertion
Key: SPARK-48383
URL: https://issues.apache.org/jira/browse/SPARK-48383
Project: Spark
Issue Type: Task
Components: Structured Streaming
Affects Versions: 4.0.0
Reporter: Siying Dong
In KafkaOffsetReader, we assert startOffsets have the same topic partition list
as assigned. However, if the user changes topic partition while the query is
running, they will see the assertion. Instead, they should see an exception.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
