Vlad created SPARK-27720:
----------------------------
Summary: ConcurrentModificationException on closing
DirectKafkaInputDStream
Key: SPARK-27720
URL: https://issues.apache.org/jira/browse/SPARK-27720
Project: Spark
Issue Type: Bug
Components: DStreams
Affects Versions: 2.4.1
Reporter: Vlad
If a DirectKafkaInputDStream is started in one thread and is being stopped in
another thread (e.g. by shutdown hook) a
java.util.ConcurrentModificationException (KafkaConsumer is not safe for
multi-threaded access) is thrown.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
