[jira] [Created] (FLINK-21271) DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException" in py35

[Shang Yuanchun (Jira)]

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)