[BEAM-921] Register Coders and Sources to serialize with JavaSerializer

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.5.0
• Component/s: runner-spark
• Assignee: Aviem Zur
• Reporter: Amit Sela
• Created: 07/Nov/16 08:32
• Updated: 16/May/20 13:51
• Resolved: 19/Jan/17 13:08

Description

Register all implementations of Source and Coder in BeamSparkRunnerRegistrator to use Spark's JavaSerializer.

This will provide stability since Sources and Coders won't guarantee being Kryo-serializable.

Issue Links

• relates to: BEAM-4597 Serialization problem using SparkRunner and KryoSerializer from spark
• links to: GitHub Pull Request #1552