Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Duplicate
-
1.12.1
-
None
Description
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)
Attachments
Issue Links
- duplicates
-
FLINK-20874 Python DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException"
- Closed
- is duplicated by
-
FLINK-21275 DataStreamTests::test_key_by_on_connect_stream Fail
- Closed