[BEAM-12050] ParDoTest TimerTests that use TestStream failing for portable FlinkRunner

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Fix Version/s: 2.34.0
• Component/s: runner-flink, test-failures
• Labels: currently-failing
• Assignee: Ke Wu
• Reporter: Kenneth Knowles
• Created: 25/Mar/21 02:41
• Updated: 07/Sep/21 15:49
• Resolved: 07/Sep/21 15:49

Description

https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/6184/

java.lang.ClassCastException: java.lang.Integer cannot be cast to [B
	at org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:166)
	at org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:111)
	at org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:83)
	at org.apache.beam.sdk.Pipeline.run(Pipeline.java:322)
	at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:398)
	at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:334)
	at org.apache.beam.sdk.transforms.ParDoTest$TimerTests.testEventTimeTimerAlignUnbounded(ParDoTest.java:4120)

Issue Links

• links to: GitHub Pull Request #14333
• links to: GitHub Pull Request #15455