[ https://issues.apache.org/jira/browse/FLINK-22083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313795#comment-17313795 ]
Huang Xingbo commented on FLINK-22083: -------------------------------------- This issue should have been addressed in [FLINK-22076|https://issues.apache.org/jira/browse/FLINK-22076]. Feel free to reopen it if it still happens. > Python tests fail on azure > -------------------------- > > Key: FLINK-22083 > URL: https://issues.apache.org/jira/browse/FLINK-22083 > Project: Flink > Issue Type: Bug > Components: API / Python > Affects Versions: 1.13.0 > Reporter: Dawid Wysakowicz > Priority: Major > Labels: test-stability > Fix For: 1.13.0 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=15934&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=4fad9527-b9a5-5015-1b70-8356e5c91490&l=23503 > {code} > E at > akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) > E at > akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) > E at > scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > E at > akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) > E at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) > E at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > E at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > E at akka.actor.Actor$class.aroundReceive(Actor.scala:517) > E at > akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) > E at > akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) > E at akka.actor.ActorCell.invoke(ActorCell.scala:561) > E at > akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) > E at akka.dispatch.Mailbox.run(Mailbox.scala:225) > E at akka.dispatch.Mailbox.exec(Mailbox.scala:235) > E ... 4 more > E Caused by: java.lang.Exception: The user defined > 'open(Configuration)' method in class > org.apache.flink.table.runtime.functions.python.PythonTableFunctionFlatMap > caused an exception: Failed to create stage bundle factory! > INFO:root:Initializing python harness: > /__w/1/s/flink-python/pyflink/fn_execution/beam/beam_boot.py --id=313-1 > --provision_endpoint=localhost:42447 > E > E at > org.apache.flink.runtime.operators.BatchTask.openUserCode(BatchTask.java:1499) > E at > org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.openTask(ChainedFlatMapDriver.java:47) > E at > org.apache.flink.runtime.operators.BatchTask.openChainedTasks(BatchTask.java:1541) > E at > org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:164) > E at > org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:776) > E at > org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) > E at java.lang.Thread.run(Thread.java:748) > E Caused by: java.lang.RuntimeException: Failed to create > stage bundle factory! INFO:root:Initializing python harness: > /__w/1/s/flink-python/pyflink/fn_execution/beam/beam_boot.py --id=313-1 > --provision_endpoint=localhost:42447 > E > E at > org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:429) > E at > org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:279) > E at > org.apache.flink.table.runtime.functions.python.AbstractPythonStatelessFunctionFlatMap.open(AbstractPythonStatelessFunctionFlatMap.java:188) > E at > org.apache.flink.table.runtime.functions.python.PythonTableFunctionFlatMap.open(PythonTableFunctionFlatMap.java:84) > E at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > E at > org.apache.flink.runtime.operators.BatchTask.openUserCode(BatchTask.java:1493) > E ... 6 more > E Caused by: > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException: > java.lang.IllegalStateException: Process died with exit code 0 > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2050) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.get(LocalCache.java:3952) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3974) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4958) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4964) > E at > org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.<init>(DefaultJobBundleFactory.java:451) > E at > org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.<init>(DefaultJobBundleFactory.java:436) > E at > org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:303) > E at > org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:427) > E ... 11 more > E Caused by: java.lang.IllegalStateException: Process died > with exit code 0 > E at > org.apache.beam.runners.fnexecution.environment.ProcessManager$RunningProcess.isAliveOrThrow(ProcessManager.java:75) > E at > org.apache.beam.runners.fnexecution.environment.ProcessEnvironmentFactory.createEnvironment(ProcessEnvironmentFactory.java:112) > E at > org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:252) > E at > org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:231) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3528) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2277) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2154) > E at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2044) > E ... 19 more > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)