[
https://issues.apache.org/jira/browse/FLINK-21271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-21271.
---------------------------
Resolution: Duplicate
> DataStreamTests.test_key_by_on_connect_stream test failed with
> "ArrayIndexOutOfBoundsException" in py35
> -------------------------------------------------------------------------------------------------------
>
> Key: FLINK-21271
> URL: https://issues.apache.org/jira/browse/FLINK-21271
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.12.1
> Reporter: Huang Xingbo
> Priority: Minor
> Labels: auto-deprioritized-major, test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12892&view=logs&j=e92ecf6d-e207-5a42-7ff7-528ff0c5b259&t=d59eb898-29f7-5a99-91a7-b2dfc3e8a653]
> {code:java}
> 2021-02-03T23:58:12.7918092Z E Caused by:
> java.lang.ArrayIndexOutOfBoundsException: Index 1 out of bounds for length 0
> 2021-02-03T23:58:12.7918584Z E at
> java.base/java.util.ArrayList.add(ArrayList.java:487)
> 2021-02-03T23:58:12.7918997Z E at
> java.base/java.util.ArrayList.add(ArrayList.java:499)
> 2021-02-03T23:58:12.7919587Z E at
> org.apache.flink.streaming.api.runners.python.beam.PythonSharedResources.addPythonEnvironmentManager(PythonSharedResources.java:66)
> 2021-02-03T23:58:12.7920305Z E at
> org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:253)
> 2021-02-03T23:58:12.7921116Z E at
> org.apache.flink.streaming.api.operators.python.AbstractPythonFunctionOperator.open(AbstractPythonFunctionOperator.java:113)
> 2021-02-03T23:58:12.7921850Z E at
> org.apache.flink.streaming.api.operators.python.TwoInputPythonFunctionOperator.open(TwoInputPythonFunctionOperator.java:144)
> 2021-02-03T23:58:12.7922555Z E at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:428)
> 2021-02-03T23:58:12.7923247Z E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:543)
> 2021-02-03T23:58:12.7923983Z E at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
> 2021-02-03T23:58:12.7924610Z E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:533)
> 2021-02-03T23:58:12.7925161Z E at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:573)
> 2021-02-03T23:58:12.7925683Z E at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755)
> 2021-02-03T23:58:12.7926259Z E at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:570)
> 2021-02-03T23:58:12.7926849Z E at
> java.base/java.lang.Thread.run(Thread.java:834)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
