[
https://issues.apache.org/jira/browse/FLINK-26104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26104:
-----------------------------------
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was: auto-deprioritized-major stale-minor test-stability)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> KeyError: 'type_info' in PyFlink test
> -------------------------------------
>
> Key: FLINK-26104
> URL: https://issues.apache.org/jira/browse/FLINK-26104
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.3
> Reporter: Huang Xingbo
> Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> test-stability
>
> {code:java}
> 2022-02-14T04:33:10.9891373Z Feb 14 04:33:10 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=103-1
> --provision_endpoint=localhost:46669
> 2022-02-14T04:33:10.9892470Z Feb 14 04:33:10 E
> INFO:root:Starting up Python harness in a standalone process.
> 2022-02-14T04:33:10.9893079Z Feb 14 04:33:10 E Traceback
> (most recent call last):
> 2022-02-14T04:33:10.9894030Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/dev/.conda/lib/python3.7/runpy.py", line 193, in
> _run_module_as_main
> 2022-02-14T04:33:10.9894791Z Feb 14 04:33:10 E
> "__main__", mod_spec)
> 2022-02-14T04:33:10.9895653Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/dev/.conda/lib/python3.7/runpy.py", line 85, in
> _run_code
> 2022-02-14T04:33:10.9896395Z Feb 14 04:33:10 E
> exec(code, run_globals)
> 2022-02-14T04:33:10.9904913Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_boot.py", line 116, in
> <module>
> 2022-02-14T04:33:10.9930244Z Feb 14 04:33:10 E from
> pyflink.fn_execution.beam import beam_sdk_worker_main
> 2022-02-14T04:33:10.9931563Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py",
> line 21, in <module>
> 2022-02-14T04:33:10.9932630Z Feb 14 04:33:10 E import
> pyflink.fn_execution.beam.beam_operations # noqa # pylint:
> disable=unused-import
> 2022-02-14T04:33:10.9933754Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_operations.py", line
> 23, in <module>
> 2022-02-14T04:33:10.9934415Z Feb 14 04:33:10 E from
> pyflink.fn_execution import flink_fn_execution_pb2
> 2022-02-14T04:33:10.9935335Z Feb 14 04:33:10 E File
> "/__w/1/s/flink-python/pyflink/fn_execution/flink_fn_execution_pb2.py", line
> 2581, in <module>
> 2022-02-14T04:33:10.9936378Z Feb 14 04:33:10 E
> _SCHEMA_FIELDTYPE.fields_by_name['time_info'].containing_oneof =
> _SCHEMA_FIELDTYPE.oneofs_by_name['type_info']
> 2022-02-14T04:33:10.9946519Z Feb 14 04:33:10 E KeyError:
> 'type_info'
> 2022-02-14T04:33:10.9947110Z Feb 14 04:33:10 E
> 2022-02-14T04:33:10.9947911Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:566)
> 2022-02-14T04:33:10.9949048Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:255)
> 2022-02-14T04:33:10.9950162Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.open(AbstractPythonFunctionOperator.java:131)
> 2022-02-14T04:33:10.9951344Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.operators.python.AbstractOneInputPythonFunctionOperator.open(AbstractOneInputPythonFunctionOperator.java:116)
> 2022-02-14T04:33:10.9952487Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.operators.python.PythonKeyedProcessOperator.open(PythonKeyedProcessOperator.java:121)
> 2022-02-14T04:33:10.9953561Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:110)
> 2022-02-14T04:33:10.9954565Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:711)
> 2022-02-14T04:33:10.9955522Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
> 2022-02-14T04:33:10.9956492Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:687)
> 2022-02-14T04:33:10.9957378Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:654)
> 2022-02-14T04:33:10.9958252Z Feb 14 04:33:10 E at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> 2022-02-14T04:33:10.9959108Z Feb 14 04:33:10 E at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
> 2022-02-14T04:33:10.9960039Z Feb 14 04:33:10 E at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
> 2022-02-14T04:33:10.9960801Z Feb 14 04:33:10 E at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
> 2022-02-14T04:33:10.9961741Z Feb 14 04:33:10 E at
> java.lang.Thread.run(Thread.java:748)
> 2022-02-14T04:33:10.9962730Z Feb 14 04:33:10 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
> 2022-02-14T04:33:10.9963904Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2050)
> 2022-02-14T04:33:10.9964920Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.get(LocalCache.java:3952)
> 2022-02-14T04:33:10.9965915Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3974)
> 2022-02-14T04:33:10.9966962Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4958)
> 2022-02-14T04:33:10.9968077Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4964)
> 2022-02-14T04:33:10.9969238Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.<init>(DefaultJobBundleFactory.java:451)
> 2022-02-14T04:33:10.9970404Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.<init>(DefaultJobBundleFactory.java:436)
> 2022-02-14T04:33:10.9971498Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:303)
> 2022-02-14T04:33:10.9972608Z Feb 14 04:33:10 E at
> org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:564)
> 2022-02-14T04:33:10.9973414Z Feb 14 04:33:10 E ... 14
> more
> 2022-02-14T04:33:10.9973955Z Feb 14 04:33:10 E Caused by:
> java.lang.IllegalStateException: Process died with exit code 0
> 2022-02-14T04:33:10.9974843Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.environment.ProcessManager$RunningProcess.isAliveOrThrow(ProcessManager.java:75)
> 2022-02-14T04:33:10.9975949Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.environment.ProcessEnvironmentFactory.createEnvironment(ProcessEnvironmentFactory.java:112)
> 2022-02-14T04:33:10.9986988Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:252)
> 2022-02-14T04:33:11.0000248Z Feb 14 04:33:10 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$1.load(DefaultJobBundleFactory.java:231)
> 2022-02-14T04:33:11.0001496Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3528)
> 2022-02-14T04:33:11.0002642Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2277)
> 2022-02-14T04:33:11.0003721Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2154)
> 2022-02-14T04:33:11.0004783Z Feb 14 04:33:10 E at
> org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2044)
> 2022-02-14T04:33:11.0005495Z Feb 14 04:33:10 E ... 22
> more
> 2022-02-14T04:33:11.0005879Z Feb 14 04:33:10
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31345&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
