[jira] [Updated] (BEAM-9534) Flink testParDoRequiresStableInput timed out

["Maximilian Michels (Jira)" <ji...@apache.org>]

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

Maximilian Michels updated BEAM-9534:
-------------------------------------
    Status: Open  (was: Triage Needed)

> Flink testParDoRequiresStableInput timed out
> --------------------------------------------
>
>                 Key: BEAM-9534
>                 URL: https://issues.apache.org/jira/browse/BEAM-9534
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>            Reporter: Kyle Weaver
>            Priority: Major
>
> Regression
> org.apache.beam.runners.flink.FlinkRequiresStableInputTest.testParDoRequiresStableInput
> Failing for the past 1 build (Since Failed#10395 )
> Took 30 sec.
> Error Message
> org.junit.runners.model.TestTimedOutException: test timed out after 30000 milliseconds
> Stacktrace
> org.junit.runners.model.TestTimedOutException: test timed out after 30000 milliseconds
> 	at java.io.FileOutputStream.write(Native Method)
> 	at java.io.FileOutputStream.write(FileOutputStream.java:290)
> 	at java.util.zip.ZipOutputStream.writeInt(ZipOutputStream.java:723)
> 	at java.util.zip.ZipOutputStream.writeLOC(ZipOutputStream.java:401)
> 	at java.util.zip.ZipOutputStream.putNextEntry(ZipOutputStream.java:238)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:266)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectoryInternal(ZipFiles.java:253)
> 	at org.apache.beam.sdk.util.ZipFiles.zipDirectory(ZipFiles.java:223)
> 	at org.apache.beam.runners.core.construction.Environments.zipDirectory(Environments.java:234)
> 	at org.apache.beam.runners.core.construction.Environments.getArtifacts(Environments.java:219)
> 	at org.apache.beam.runners.core.construction.Environments.createOrGetDefaultEnvironment(Environments.java:110)
> 	at org.apache.beam.runners.core.construction.SdkComponents.create(SdkComponents.java:92)
> 	at org.apache.beam.runners.core.construction.ParDoTranslation.getParDoPayload(ParDoTranslation.java:735)
> 	at org.apache.beam.runners.core.construction.ParDoTranslation.getSchemaInformation(ParDoTranslation.java:344)
> 	at org.apache.beam.runners.flink.FlinkStreamingTransformTranslators$ParDoStreamingTranslator.translateNode(FlinkStreamingTransformTranslators.java:669)
> 	at org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.applyStreamingTransform(FlinkStreamingPipelineTranslator.java:157)
> 	at org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.visitPrimitiveTransform(FlinkStreamingPipelineTranslator.java:136)
> 	at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:665)
> 	at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:657)
> 	at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:317)
> 	at org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:251)
> 	at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:463)
> 	at org.apache.beam.runners.flink.FlinkPipelineTranslator.translate(FlinkPipelineTranslator.java:38)
> 	at org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.translate(FlinkStreamingPipelineTranslator.java:88)
> 	at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.translate(FlinkPipelineExecutionEnvironment.java:116)
> 	at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.getJobGraph(FlinkPipelineExecutionEnvironment.java:153)
> 	at org.apache.beam.runners.flink.FlinkRunner.getJobGraph(FlinkRunner.java:209)
> 	at org.apache.beam.runners.flink.FlinkRequiresStableInputTest.getJobGraph(FlinkRequiresStableInputTest.java:176)
> 	at org.apache.beam.runners.flink.FlinkRequiresStableInputTest.restoreFromSavepoint(FlinkRequiresStableInputTest.java:201)
> 	at org.apache.beam.runners.flink.FlinkRequiresStableInputTest.testParDoRequiresStableInput(FlinkRequiresStableInputTest.java:163)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 	at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
> 	at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
> 	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 	at java.lang.Thread.run(Thread.java:748)



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