[BEAM-12374] Spark postcommit failing ResumeFromCheckpointStreamingTest

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: runner-spark, test-failures
• Assignee: Unassigned
• Reporter: Kyle Weaver
• Created: 20/May/21 16:04
• Updated: 09/Sep/21 18:46
• Resolved: 09/Sep/21 18:46

Description

java.lang.IllegalStateException: Not expected to directly translate splittable DoFn, should have been overridden: org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFn@466ad4c7

Probably caused by https://github.com/apache/beam/pull/14801.

https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/8908/testReport/junit/org.apache.beam.runners.spark.translation.streaming/ResumeFromCheckpointStreamingTest/testWithResume/