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:46:00 UTC

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

     [ https://issues.apache.org/jira/browse/BEAM-12050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kenneth Knowles reassigned BEAM-12050:
--------------------------------------

    Assignee: Kenneth Knowles

> 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, test-failures
>            Reporter: Kenneth Knowles
>            Assignee: Kenneth Knowles
>            Priority: P1
>              Labels: currently-failing
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> 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)