You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/14 11:05:00 UTC
[jira] [Created] (FLINK-26636) EmbeddedMultiThreadDependencyTests test_add_python_file failed on azure
Roman Khachatryan created FLINK-26636:
-----------------------------------------
Summary: EmbeddedMultiThreadDependencyTests test_add_python_file failed on azure
Key: FLINK-26636
URL: https://issues.apache.org/jira/browse/FLINK-26636
Project: Flink
Issue Type: Bug
Reporter: Roman Khachatryan
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32981&view=logs&j=e92ecf6d-e207-5a42-7ff7-528ff0c5b259&t=40fc352e-9b4c-5fd8-363f-628f24b01ec2&l=28024
{code}
2022-03-14T04:11:09.7985367Z Mar 14 04:11:09 =================================== FAILURES ===================================
2022-03-14T04:11:09.7988965Z Mar 14 04:11:09 ___________ EmbeddedMultiThreadDependencyTests.test_add_python_file ____________
2022-03-14T04:11:09.7989557Z Mar 14 04:11:09
2022-03-14T04:11:09.7990098Z Mar 14 04:11:09 self = <pyflink.table.tests.test_dependency.EmbeddedMultiThreadDependencyTests testMethod=test_add_python_file>
2022-03-14T04:11:09.7990644Z Mar 14 04:11:09
2022-03-14T04:11:09.7991165Z Mar 14 04:11:09 def test_add_python_file(self):
2022-03-14T04:11:09.7991785Z Mar 14 04:11:09 python_file_dir = os.path.join(self.tempdir, "python_file_dir_" + str(uuid.uuid4()))
2022-03-14T04:11:09.7992318Z Mar 14 04:11:09 os.mkdir(python_file_dir)
2022-03-14T04:11:09.7993113Z Mar 14 04:11:09 python_file_path = os.path.join(python_file_dir, "test_dependency_manage_lib.py")
2022-03-14T04:11:09.7994443Z Mar 14 04:11:09 with open(python_file_path, 'w') as f:
2022-03-14T04:11:09.7995251Z Mar 14 04:11:09 f.write("def add_two(a):\n raise Exception('This function should not be called!')")
2022-03-14T04:11:09.7997796Z Mar 14 04:11:09 self.t_env.add_python_file(python_file_path)
2022-03-14T04:11:09.7998592Z Mar 14 04:11:09
2022-03-14T04:11:09.7999298Z Mar 14 04:11:09 python_file_dir_with_higher_priority = os.path.join(
2022-03-14T04:11:09.8000146Z Mar 14 04:11:09 self.tempdir, "python_file_dir_" + str(uuid.uuid4()))
2022-03-14T04:11:09.8001027Z Mar 14 04:11:09 os.mkdir(python_file_dir_with_higher_priority)
2022-03-14T04:11:09.8001891Z Mar 14 04:11:09 python_file_path_higher_priority = os.path.join(python_file_dir_with_higher_priority,
2022-03-14T04:11:09.8002526Z Mar 14 04:11:09 "test_dependency_manage_lib.py")
2022-03-14T04:11:09.8003945Z Mar 14 04:11:09 with open(python_file_path_higher_priority, 'w') as f:
2022-03-14T04:11:09.8004664Z Mar 14 04:11:09 f.write("def add_two(a):\n return a + 2")
2022-03-14T04:11:09.8005208Z Mar 14 04:11:09 self.t_env.add_python_file(python_file_path_higher_priority)
2022-03-14T04:11:09.8005648Z Mar 14 04:11:09
2022-03-14T04:11:09.8005992Z Mar 14 04:11:09 def plus_two(i):
2022-03-14T04:11:09.8006430Z Mar 14 04:11:09 from test_dependency_manage_lib import add_two
2022-03-14T04:11:09.8006857Z Mar 14 04:11:09 return add_two(i)
2022-03-14T04:11:09.8007204Z Mar 14 04:11:09
2022-03-14T04:11:09.8007605Z Mar 14 04:11:09 self.t_env.create_temporary_system_function(
2022-03-14T04:11:09.8008206Z Mar 14 04:11:09 "add_two", udf(plus_two, DataTypes.BIGINT(), DataTypes.BIGINT()))
2022-03-14T04:11:09.8008742Z Mar 14 04:11:09 table_sink = source_sink_utils.TestAppendSink(
2022-03-14T04:11:09.8009465Z Mar 14 04:11:09 ['a', 'b'], [DataTypes.BIGINT(), DataTypes.BIGINT()])
2022-03-14T04:11:09.8009993Z Mar 14 04:11:09 self.t_env.register_table_sink("Results", table_sink)
2022-03-14T04:11:09.8010763Z Mar 14 04:11:09 t = self.t_env.from_elements([(1, 2), (2, 5), (3, 1)], ['a', 'b'])
2022-03-14T04:11:09.8011324Z Mar 14 04:11:09 > t.select(expr.call("add_two", t.a), t.a).execute_insert("Results").wait()
2022-03-14T04:11:09.8011779Z Mar 14 04:11:09
2022-03-14T04:11:09.8012176Z Mar 14 04:11:09 pyflink/table/tests/test_dependency.py:63:
2022-03-14T04:11:09.8012677Z Mar 14 04:11:09 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2022-03-14T04:11:09.8013574Z Mar 14 04:11:09 pyflink/table/table_result.py:76: in wait
2022-03-14T04:11:09.8014041Z Mar 14 04:11:09 get_method(self._j_table_result, "await")()
2022-03-14T04:11:09.8014843Z Mar 14 04:11:09 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1321: in __call__
2022-03-14T04:11:09.8015387Z Mar 14 04:11:09 return_value = get_return_value(
2022-03-14T04:11:09.8015843Z Mar 14 04:11:09 pyflink/util/exceptions.py:146: in deco
2022-03-14T04:11:09.8016267Z Mar 14 04:11:09 return f(*a, **kw)
2022-03-14T04:11:09.8016720Z Mar 14 04:11:09 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2022-03-14T04:11:09.8017116Z Mar 14 04:11:09
2022-03-14T04:11:09.8017626Z Mar 14 04:11:09 answer = 'xro2722'
2022-03-14T04:11:09.8018127Z Mar 14 04:11:09 gateway_client = <py4j.java_gateway.GatewayClient object at 0x7f4a061764c0>
2022-03-14T04:11:09.8018812Z Mar 14 04:11:09 target_id = 'o2721', name = 'await'
2022-03-14T04:11:09.8019195Z Mar 14 04:11:09
2022-03-14T04:11:09.8019636Z Mar 14 04:11:09 def get_return_value(answer, gateway_client, target_id=None, name=None):
2022-03-14T04:11:09.8020216Z Mar 14 04:11:09 """Converts an answer received from the Java gateway into a Python object.
2022-03-14T04:11:09.8020660Z Mar 14 04:11:09
2022-03-14T04:11:09.8021099Z Mar 14 04:11:09 For example, string representation of integers are converted to Python
2022-03-14T04:11:09.8021690Z Mar 14 04:11:09 integer, string representation of objects are converted to JavaObject
2022-03-14T04:11:09.8022339Z Mar 14 04:11:09 instances, etc.
2022-03-14T04:11:09.8022667Z Mar 14 04:11:09
2022-03-14T04:11:09.8023336Z Mar 14 04:11:09 :param answer: the string returned by the Java gateway
2022-03-14T04:11:09.8024028Z Mar 14 04:11:09 :param gateway_client: the gateway client used to communicate with the Java
2022-03-14T04:11:09.8024733Z Mar 14 04:11:09 Gateway. Only necessary if the answer is a reference (e.g., object,
2022-03-14T04:11:09.8025294Z Mar 14 04:11:09 list, map)
2022-03-14T04:11:09.8025880Z Mar 14 04:11:09 :param target_id: the name of the object from which the answer comes from
2022-03-14T04:11:09.8026438Z Mar 14 04:11:09 (e.g., *object1* in `object1.hello()`). Optional.
2022-03-14T04:11:09.8026979Z Mar 14 04:11:09 :param name: the name of the member from which the answer comes from
2022-03-14T04:11:09.8027627Z Mar 14 04:11:09 (e.g., *hello* in `object1.hello()`). Optional.
2022-03-14T04:11:09.8028057Z Mar 14 04:11:09 """
2022-03-14T04:11:09.8028433Z Mar 14 04:11:09 if is_error(answer)[0]:
2022-03-14T04:11:09.8028823Z Mar 14 04:11:09 if len(answer) > 1:
2022-03-14T04:11:09.8029207Z Mar 14 04:11:09 type = answer[1]
2022-03-14T04:11:09.8029673Z Mar 14 04:11:09 value = OUTPUT_CONVERTER[type](answer[2:], gateway_client)
2022-03-14T04:11:09.8030161Z Mar 14 04:11:09 if answer[1] == REFERENCE_TYPE:
2022-03-14T04:11:09.8030599Z Mar 14 04:11:09 > raise Py4JJavaError(
2022-03-14T04:11:09.8031047Z Mar 14 04:11:09 "An error occurred while calling {0}{1}{2}.\n".
2022-03-14T04:11:09.8031514Z Mar 14 04:11:09 format(target_id, ".", name), value)
2022-03-14T04:11:09.8032060Z Mar 14 04:11:09 E py4j.protocol.Py4JJavaError: An error occurred while calling o2721.await.
2022-03-14T04:11:09.8032746Z Mar 14 04:11:09 E : java.util.concurrent.ExecutionException: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-03-14T04:11:09.8033758Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2022-03-14T04:11:09.8034512Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2022-03-14T04:11:09.8035279Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:118)
2022-03-14T04:11:09.8036067Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:81)
2022-03-14T04:11:09.8036782Z Mar 14 04:11:09 E at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-03-14T04:11:09.8037493Z Mar 14 04:11:09 E at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-03-14T04:11:09.8038313Z Mar 14 04:11:09 E at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-14T04:11:09.8039029Z Mar 14 04:11:09 E at java.base/java.lang.reflect.Method.invoke(Method.java:566)
2022-03-14T04:11:09.8039754Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
2022-03-14T04:11:09.8040582Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
2022-03-14T04:11:09.8041372Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
2022-03-14T04:11:09.8042137Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
2022-03-14T04:11:09.8043191Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
2022-03-14T04:11:09.8069008Z Mar 14 04:11:09 E at org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
2022-03-14T04:11:09.8069833Z Mar 14 04:11:09 E at java.base/java.lang.Thread.run(Thread.java:829)
2022-03-14T04:11:09.8070440Z Mar 14 04:11:09 E Caused by: org.apache.flink.table.api.TableException: Failed to wait job finish
2022-03-14T04:11:09.8071339Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:85)
2022-03-14T04:11:09.8072166Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.InsertResultProvider.isFirstRowReady(InsertResultProvider.java:71)
2022-03-14T04:11:09.8073477Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.TableResultImpl.lambda$awaitInternal$1(TableResultImpl.java:105)
2022-03-14T04:11:09.8074302Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1736)
2022-03-14T04:11:09.8075059Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2022-03-14T04:11:09.8075792Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2022-03-14T04:11:09.8076340Z Mar 14 04:11:09 E ... 1 more
2022-03-14T04:11:09.8077108Z Mar 14 04:11:09 E Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-03-14T04:11:09.8077884Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
2022-03-14T04:11:09.8078608Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
2022-03-14T04:11:09.8079363Z Mar 14 04:11:09 E at org.apache.flink.table.api.internal.InsertResultProvider.hasNext(InsertResultProvider.java:83)
2022-03-14T04:11:09.8079947Z Mar 14 04:11:09 E ... 6 more
2022-03-14T04:11:09.8080464Z Mar 14 04:11:09 E Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-03-14T04:11:09.8081358Z Mar 14 04:11:09 E at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-03-14T04:11:09.8082191Z Mar 14 04:11:09 E at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-03-14T04:11:09.8083421Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
2022-03-14T04:11:09.8084294Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2022-03-14T04:11:09.8085354Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
2022-03-14T04:11:09.8086852Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:259)
2022-03-14T04:11:09.8088373Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2022-03-14T04:11:09.8089323Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2022-03-14T04:11:09.8090081Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2022-03-14T04:11:09.8090810Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
2022-03-14T04:11:09.8091675Z Mar 14 04:11:09 E at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
2022-03-14T04:11:09.8092533Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
2022-03-14T04:11:09.8093689Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
2022-03-14T04:11:09.8094878Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
2022-03-14T04:11:09.8095920Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
2022-03-14T04:11:09.8096815Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
2022-03-14T04:11:09.8097750Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
2022-03-14T04:11:09.8098477Z Mar 14 04:11:09 E at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
2022-03-14T04:11:09.8099249Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
2022-03-14T04:11:09.8099959Z Mar 14 04:11:09 E at akka.dispatch.OnComplete.internal(Future.scala:300)
2022-03-14T04:11:09.8100564Z Mar 14 04:11:09 E at akka.dispatch.OnComplete.internal(Future.scala:297)
2022-03-14T04:11:09.8101416Z Mar 14 04:11:09 E at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
2022-03-14T04:11:09.8102067Z Mar 14 04:11:09 E at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
2022-03-14T04:11:09.8102707Z Mar 14 04:11:09 E at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-03-14T04:11:09.8103691Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
2022-03-14T04:11:09.8104502Z Mar 14 04:11:09 E at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
2022-03-14T04:11:09.8105715Z Mar 14 04:11:09 E at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
2022-03-14T04:11:09.8107070Z Mar 14 04:11:09 E at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
2022-03-14T04:11:09.8108410Z Mar 14 04:11:09 E at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
2022-03-14T04:11:09.8109614Z Mar 14 04:11:09 E at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
2022-03-14T04:11:09.8110620Z Mar 14 04:11:09 E at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
2022-03-14T04:11:09.8111683Z Mar 14 04:11:09 E at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
2022-03-14T04:11:09.8112420Z Mar 14 04:11:09 E at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
2022-03-14T04:11:09.8113538Z Mar 14 04:11:09 E at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
2022-03-14T04:11:09.8114729Z Mar 14 04:11:09 E at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
2022-03-14T04:11:09.8115918Z Mar 14 04:11:09 E at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
2022-03-14T04:11:09.8117203Z Mar 14 04:11:09 E at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
2022-03-14T04:11:09.8118852Z Mar 14 04:11:09 E at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
2022-03-14T04:11:09.8120169Z Mar 14 04:11:09 E at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
2022-03-14T04:11:09.8121393Z Mar 14 04:11:09 E at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
2022-03-14T04:11:09.8122701Z Mar 14 04:11:09 E at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
2022-03-14T04:11:09.8124429Z Mar 14 04:11:09 E at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
2022-03-14T04:11:09.8125793Z Mar 14 04:11:09 E at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
2022-03-14T04:11:09.8127341Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
2022-03-14T04:11:09.8128573Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
2022-03-14T04:11:09.8129843Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
2022-03-14T04:11:09.8131031Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
2022-03-14T04:11:09.8132332Z Mar 14 04:11:09 E at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
2022-03-14T04:11:09.8133813Z Mar 14 04:11:09 E Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2022-03-14T04:11:09.8135320Z Mar 14 04:11:09 E at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2022-03-14T04:11:09.8137118Z Mar 14 04:11:09 E at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2022-03-14T04:11:09.8138823Z Mar 14 04:11:09 E at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
2022-03-14T04:11:09.8140327Z Mar 14 04:11:09 E at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
2022-03-14T04:11:09.8141947Z Mar 14 04:11:09 E at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
2022-03-14T04:11:09.8143703Z Mar 14 04:11:09 E at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
2022-03-14T04:11:09.8145203Z Mar 14 04:11:09 E at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2022-03-14T04:11:09.8146697Z Mar 14 04:11:09 E at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2022-03-14T04:11:09.8147972Z Mar 14 04:11:09 E at jdk.internal.reflect.GeneratedMethodAccessor29.invoke(Unknown Source)
2022-03-14T04:11:09.8149302Z Mar 14 04:11:09 E at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-14T04:11:09.8150613Z Mar 14 04:11:09 E at java.base/java.lang.reflect.Method.invoke(Method.java:566)
2022-03-14T04:11:09.8151899Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-03-14T04:11:09.8153658Z Mar 14 04:11:09 E at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-03-14T04:11:09.8155097Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-03-14T04:11:09.8156099Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-03-14T04:11:09.8156902Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2022-03-14T04:11:09.8157700Z Mar 14 04:11:09 E at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-03-14T04:11:09.8158598Z Mar 14 04:11:09 E at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-03-14T04:11:09.8159254Z Mar 14 04:11:09 E at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-03-14T04:11:09.8159905Z Mar 14 04:11:09 E at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-03-14T04:11:09.8160642Z Mar 14 04:11:09 E at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-03-14T04:11:09.8161324Z Mar 14 04:11:09 E at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-03-14T04:11:09.8162009Z Mar 14 04:11:09 E at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-03-14T04:11:09.8162688Z Mar 14 04:11:09 E at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-14T04:11:09.8163777Z Mar 14 04:11:09 E at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-14T04:11:09.8164579Z Mar 14 04:11:09 E at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-03-14T04:11:09.8165155Z Mar 14 04:11:09 E at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-03-14T04:11:09.8165792Z Mar 14 04:11:09 E at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-03-14T04:11:09.8166454Z Mar 14 04:11:09 E at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-03-14T04:11:09.8167070Z Mar 14 04:11:09 E at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-03-14T04:11:09.8167676Z Mar 14 04:11:09 E at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-03-14T04:11:09.8168268Z Mar 14 04:11:09 E at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-03-14T04:11:09.8169061Z Mar 14 04:11:09 E at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-03-14T04:11:09.8169530Z Mar 14 04:11:09 E ... 5 more
2022-03-14T04:11:09.8170975Z Mar 14 04:11:09 E Caused by: pemja.core.PythonException: <class 'Exception'>: This function should not be called!
2022-03-14T04:11:09.8171921Z Mar 14 04:11:09 E at /__w/2/s/flink-python/pyflink/fn_execution/table/operations.process_element(operations.py:83)
2022-03-14T04:11:09.8172544Z Mar 14 04:11:09 E at <string>.<lambda>(<string>:1)
2022-03-14T04:11:09.8173602Z Mar 14 04:11:09 E at /__w/2/s/flink-python/pyflink/table/tests/test_dependency.plus_two(test_dependency.py:55)
2022-03-14T04:11:09.8174907Z Mar 14 04:11:09 E at /tmp/python-dist-4fc65d80-4b16-4946-b668-93df268e0aae/python-files/blob_p-bedc014754a86159784fd7cebff77ab534802643-71c9e3fa909e04f70aa5b12f7e01e8dd/test_dependency_manage_lib.add_two(test_dependency_manage_lib.py:2)
2022-03-14T04:11:09.8175833Z Mar 14 04:11:09 E at pemja.core.PythonInterpreter.invokeMethodOneArgLong(Native Method)
2022-03-14T04:11:09.8176495Z Mar 14 04:11:09 E at pemja.core.PythonInterpreter.invokeMethodOneArg(PythonInterpreter.java:222)
2022-03-14T04:11:09.8177193Z Mar 14 04:11:09 E at pemja.core.PythonInterpreter.invokeMethod(PythonInterpreter.java:116)
2022-03-14T04:11:09.8178087Z Mar 14 04:11:09 E at org.apache.flink.table.runtime.operators.python.scalar.EmbeddedPythonScalarFunctionOperator.processElement(EmbeddedPythonScalarFunctionOperator.java:235)
2022-03-14T04:11:09.8179209Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
2022-03-14T04:11:09.8180068Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
2022-03-14T04:11:09.8180903Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
2022-03-14T04:11:09.8181904Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
2022-03-14T04:11:09.8182655Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
2022-03-14T04:11:09.8183580Z Mar 14 04:11:09 E at SourceConversion$21.processElement(Unknown Source)
2022-03-14T04:11:09.8184298Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
2022-03-14T04:11:09.8185151Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
2022-03-14T04:11:09.8185965Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
2022-03-14T04:11:09.8186760Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
2022-03-14T04:11:09.8187524Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
2022-03-14T04:11:09.8188400Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
2022-03-14T04:11:09.8189354Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
2022-03-14T04:11:09.8190267Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
2022-03-14T04:11:09.8191169Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92)
2022-03-14T04:11:09.8191978Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
2022-03-14T04:11:09.8192700Z Mar 14 04:11:09 E at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
2022-03-14T04:11:09.8193629Z Mar 14 04:11:09 E at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)
{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)