[
https://issues.apache.org/jira/browse/FLINK-22083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-22083.
----------------------------------
Resolution: Fixed
> 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)
