You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kenneth Knowles (Jira)" <ji...@apache.org> on 2021/03/25 02:42:00 UTC

[jira] [Created] (BEAM-12050) ParDoTest TimerTests that use TestStream failing for portable FlinkRunner

Kenneth Knowles created BEAM-12050:
--------------------------------------

             Summary: ParDoTest TimerTests that use TestStream failing for portable FlinkRunner
                 Key: BEAM-12050
                 URL: https://issues.apache.org/jira/browse/BEAM-12050
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Kenneth Knowles


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

{code}
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)
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)