Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
SerializationUtil fails to clone Processors in Spark because the default classloader doesn't contain them. Ensure the right classloader is used, allowing spark to scale out StreamsProcessor execution.