Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
2.32.0
-
None
Description
org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testTwoTimersSettingEachOtherWithCreateAsInputUnbounded is failing because of
java.lang.ClassCastException: org.apache.beam.runners.core.construction.SplittableParDo$PrimitiveBoundedRead cannot be cast to org.apache.beam.runners.core.construction.SplittableParDo$PrimitiveUnboundedRead at org.apache.beam.runners.spark.translation.streaming.StreamingTransformTranslator$3.evaluate(StreamingTransformTranslator.java:152) at org.apache.beam.runners.spark.SparkRunner$Evaluator.doVisitTransform(SparkRunner.java:449) at org.apache.beam.runners.spark.SparkRunner$Evaluator.visitPrimitiveTransform(SparkRunner.java:438) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:593) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)
Attachments
Issue Links
- duplicates
-
BEAM-12625 beam_PostCommit_Java_ValidatesRunner_Spark failing because testTwoTimersSettingEachOtherWithCreateAsInputUnbounded
- Resolved