You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Valentyn Tymofieiev (Jira)" <ji...@apache.org> on 2021/11/23 20:48:00 UTC
[jira] [Created] (BEAM-13311) org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElementStateful is flaky in Java ValidatesRunner Flink suite.
Valentyn Tymofieiev created BEAM-13311:
------------------------------------------
Summary: org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElementStateful is flaky in Java ValidatesRunner Flink suite.
Key: BEAM-13311
URL: https://issues.apache.org/jira/browse/BEAM-13311
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Valentyn Tymofieiev
Sample run: https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/9666/testReport/junit/org.apache.beam.sdk.transforms/ParDoLifecycleTest/testTeardownCalledAfterExceptionInProcessElementStateful/
Saw at least 2 other instances this week.
{noformat}
Error Message
java.lang.AssertionError: Expected to have a processing method throw an exception
Stacktrace
java.lang.AssertionError: Expected to have a processing method throw an exception
at org.junit.Assert.fail(Assert.java:89)
at org.apache.beam.sdk.transforms.ParDoLifecycleTest$ExceptionThrowingFn.after(ParDoLifecycleTest.java:439)
Standard Error
Nov 23, 2021 12:07:43 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Executing pipeline using FlinkRunner.
Nov 23, 2021 12:07:43 PM org.apache.beam.runners.flink.FlinkRunner run
WARNING: For maximum performance you should set the 'fasterCopy' option. See more at https://issues.apache.org/jira/browse/BEAM-11146
Nov 23, 2021 12:07:43 PM org.apache.beam.runners.flink.FlinkRunner run
INFO: Translating pipeline to Flink program.
Nov 23, 2021 12:07:43 PM org.apache.beam.runners.flink.FlinkExec
...[truncated 869358 chars]...
ction.open(WrappingFunction.java:46)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:508)
... 4 more
Caused by: java.lang.Exception: Hasn't yet thrown
at org.apache.beam.sdk.transforms.ParDoLifecycleTest$ExceptionThrowingFn.throwIfNecessary(ParDoLifecycleTest.java:432)
at org.apache.beam.sdk.transforms.ParDoLifecycleTest$ExceptionThrowingFn.before(ParDoLifecycleTest.java:395)
{noformat}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)