Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21271

DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException" in py35

    XMLWordPrintableJSON

Details

    Description

      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

      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

          Activity

            People

              Unassigned Unassigned
              hxbks2ks Huang Xingbo
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: