[BEAM-3492] Spark Integration Tests fail with a Closed Connection

• Type: Bug
• Status: Resolved
• Priority: P0
• Resolution: Fixed
• Fix Version/s: 2.3.0
• Component/s: runner-spark
• Assignee: Ismaël Mejía
• Reporter: Thomas Groh
• Created: 18/Jan/18 01:07
• Updated: 16/May/20 14:20
• Resolved: 22/Jan/18 17:22

Description

Example: https://builds.apache.org/job/beam_PreCommit_Java_MavenInstall/16832

 
2018-01-17T23:52:25.668 [ERROR] testE2EWordCount(org.apache.beam.examples.WordCountIT) Time elapsed: 14.329 s <<< ERROR!
org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.io.IOException: Connection from /127.0.0.1:45363 closed
at org.apache.beam.runners.spark.SparkPipelineResult.beamExceptionFrom(SparkPipelineResult.java:68)