Huang Xingbo created FLINK-21271:
------------------------------------
Summary: 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.2
Reporter: Huang Xingbo
[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)
