You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2021/12/17 05:28:00 UTC
[jira] [Created] (FLINK-25358) New File Sink end-to-end test failed due to TM could not connect to RM
Yun Gao created FLINK-25358:
-------------------------------
Summary: New File Sink end-to-end test failed due to TM could not connect to RM
Key: FLINK-25358
URL: https://issues.apache.org/jira/browse/FLINK-25358
Project: Flink
Issue Type: Bug
Components: Build System / Azure Pipelines, Runtime / Coordination
Affects Versions: 1.14.2
Reporter: Yun Gao
{code:java}
2021-12-16T16:53:21.8386046Z Dec 16 16:53:15 2021-12-16 16:39:16,946 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Start job leader service.
2021-12-16T16:53:21.8386987Z Dec 16 16:53:15 2021-12-16 16:39:16,948 INFO org.apache.flink.runtime.filecache.FileCache [] - User file cache uses directory /tmp/flink-dist-cache-3a780c9f-c395-4355-b496-ade62a0757ad
2021-12-16T16:53:21.8388219Z Dec 16 16:53:15 2021-12-16 16:39:16,960 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Connecting to ResourceManager akka.ssl.tcp://flink@localhost:6123/user/rpc/resourcemanager_*(00000000000000000000000000000000).
2021-12-16T16:53:21.8389898Z Dec 16 16:53:15 2021-12-16 16:39:17,485 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$a]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8391767Z Dec 16 16:53:15 2021-12-16 16:39:18,851 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8393631Z Dec 16 16:53:15 2021-12-16 16:39:20,374 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8395509Z Dec 16 16:53:15 2021-12-16 16:39:20,376 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8397548Z Dec 16 16:53:15 2021-12-16 16:39:27,018 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8399173Z Dec 16 16:53:15 2021-12-16 16:39:28,864 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8401223Z Dec 16 16:53:15 2021-12-16 16:39:30,357 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8403087Z Dec 16 16:53:15 2021-12-16 16:39:37,036 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$b]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8404956Z Dec 16 16:53:15 2021-12-16 16:39:38,886 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8406801Z Dec 16 16:53:15 2021-12-16 16:39:40,374 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8408655Z Dec 16 16:53:15 2021-12-16 16:39:40,410 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8410517Z Dec 16 16:53:15 2021-12-16 16:39:47,053 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8412137Z Dec 16 16:53:15 2021-12-16 16:39:48,915 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8414008Z Dec 16 16:53:15 2021-12-16 16:39:50,332 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8415859Z Dec 16 16:53:15 2021-12-16 16:39:57,076 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$c]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8417798Z Dec 16 16:53:15 2021-12-16 16:39:58,852 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8419746Z Dec 16 16:53:15 2021-12-16 16:39:58,852 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/user/rpc/taskmanager_0#-1901973634]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8421605Z Dec 16 16:53:15 2021-12-16 16:40:07,092 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8423227Z Dec 16 16:53:15 2021-12-16 16:40:17,117 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$d]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8425078Z Dec 16 16:53:15 2021-12-16 16:40:27,132 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8426694Z Dec 16 16:53:15 2021-12-16 16:40:37,159 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$e]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8428571Z Dec 16 16:53:15 2021-12-16 16:40:47,172 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8430200Z Dec 16 16:53:15 2021-12-16 16:40:57,196 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$f]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8432064Z Dec 16 16:53:15 2021-12-16 16:41:07,213 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8433680Z Dec 16 16:53:15 2021-12-16 16:41:17,236 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$g]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8435541Z Dec 16 16:53:15 2021-12-16 16:41:27,252 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8437170Z Dec 16 16:53:15 2021-12-16 16:41:37,276 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$h]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8439086Z Dec 16 16:53:15 2021-12-16 16:41:47,292 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8440869Z Dec 16 16:53:15 2021-12-16 16:41:57,316 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$i]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8442707Z Dec 16 16:53:15 2021-12-16 16:42:07,332 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8444344Z Dec 16 16:53:15 2021-12-16 16:42:17,356 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$j]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8446187Z Dec 16 16:53:15 2021-12-16 16:42:27,373 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8447801Z Dec 16 16:53:15 2021-12-16 16:42:37,397 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$k]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8449655Z Dec 16 16:53:15 2021-12-16 16:42:47,412 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8451276Z Dec 16 16:53:15 2021-12-16 16:42:57,435 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$l]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8453121Z Dec 16 16:53:15 2021-12-16 16:43:07,453 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8454750Z Dec 16 16:53:15 2021-12-16 16:43:17,477 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$m]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8456601Z Dec 16 16:53:15 2021-12-16 16:43:27,492 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8458228Z Dec 16 16:53:15 2021-12-16 16:43:37,516 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$n]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8460053Z Dec 16 16:53:15 2021-12-16 16:43:47,532 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8461790Z Dec 16 16:53:15 2021-12-16 16:43:57,560 WARN akka.remote.EndpointReader [] - Discarding inbound message to [Actor[akka://flink/temp/_user_rpc_resourcemanager_*$o]] in read-only association to [akka.ssl.tcp://flink@localhost:6123]. If this happens often you may consider using akka.remote.use-passive-connections=off or use Artery TCP.
2021-12-16T16:53:21.8463707Z Dec 16 16:53:15 2021-12-16 16:44:07,572 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.ssl.tcp://flink@localhost:***@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8464944Z Dec 16 16:53:15 2021-12-16 16:44:16,982 ERROR org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Fatal error occurred in TaskExecutor akka.ssl.tcp://flink@127.0.0.1:45031/user/rpc/taskmanager_0.
2021-12-16T16:53:21.8465907Z Dec 16 16:53:15 org.apache.flink.runtime.taskexecutor.exceptions.RegistrationTimeoutException: Could not register at the ResourceManager within the specified maximum registration duration 300000 ms. This indicates a problem with this instance. Terminating now.
2021-12-16T16:53:21.8467009Z Dec 16 16:53:15 at org.apache.flink.runtime.taskexecutor.TaskExecutor.registrationTimeout(TaskExecutor.java:1449) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8468041Z Dec 16 16:53:15 at org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$startRegistrationTimeout$17(TaskExecutor.java:1434) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8469115Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:455) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8470250Z Dec 16 16:53:15 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8471370Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:455) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8472437Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8473490Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8474476Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8475413Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8476361Z Dec 16 16:53:15 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8477303Z Dec 16 16:53:15 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8478238Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8479194Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8480251Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8481311Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8482228Z Dec 16 16:53:15 at akka.actor.Actor.aroundReceive(Actor.scala:537) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8483202Z Dec 16 16:53:15 at akka.actor.Actor.aroundReceive$(Actor.scala:535) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8484135Z Dec 16 16:53:15 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8485071Z Dec 16 16:53:15 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8485987Z Dec 16 16:53:15 at akka.actor.ActorCell.invoke(ActorCell.scala:548) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8486901Z Dec 16 16:53:15 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8487788Z Dec 16 16:53:15 at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8488678Z Dec 16 16:53:15 at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8489281Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_292]
2021-12-16T16:53:21.8489838Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_292]
2021-12-16T16:53:21.8490390Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_292]
2021-12-16T16:53:21.8490953Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_292]
2021-12-16T16:53:21.8491834Z Dec 16 16:53:15 2021-12-16 16:44:16,990 ERROR org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - Fatal error occurred while executing the TaskManager. Shutting it down...
2021-12-16T16:53:21.8492700Z Dec 16 16:53:15 org.apache.flink.runtime.taskexecutor.exceptions.RegistrationTimeoutException: Could not register at the ResourceManager within the specified maximum registration duration 300000 ms. This indicates a problem with this instance. Terminating now.
2021-12-16T16:53:21.8493804Z Dec 16 16:53:15 at org.apache.flink.runtime.taskexecutor.TaskExecutor.registrationTimeout(TaskExecutor.java:1449) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8494833Z Dec 16 16:53:15 at org.apache.flink.runtime.taskexecutor.TaskExecutor.lambda$startRegistrationTimeout$17(TaskExecutor.java:1434) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8495918Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:455) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8497053Z Dec 16 16:53:15 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8498159Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:455) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8499214Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8500274Z Dec 16 16:53:15 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) ~[flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8501324Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8502266Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8503274Z Dec 16 16:53:15 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8504221Z Dec 16 16:53:15 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8505172Z Dec 16 16:53:15 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8506130Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8507087Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8508046Z Dec 16 16:53:15 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8508962Z Dec 16 16:53:15 at akka.actor.Actor.aroundReceive(Actor.scala:537) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8509845Z Dec 16 16:53:15 at akka.actor.Actor.aroundReceive$(Actor.scala:535) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8510773Z Dec 16 16:53:15 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8511714Z Dec 16 16:53:15 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8512603Z Dec 16 16:53:15 at akka.actor.ActorCell.invoke(ActorCell.scala:548) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8513506Z Dec 16 16:53:15 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8514384Z Dec 16 16:53:15 at akka.dispatch.Mailbox.run(Mailbox.scala:231) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8515251Z Dec 16 16:53:15 at akka.dispatch.Mailbox.exec(Mailbox.scala:243) [flink-rpc-akka_f1863f61-8169-473c-af70-7060e3927564.jar:1.14-SNAPSHOT]
2021-12-16T16:53:21.8515849Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_292]
2021-12-16T16:53:21.8516394Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_292]
2021-12-16T16:53:21.8516947Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_292]
2021-12-16T16:53:21.8517500Z Dec 16 16:53:15 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) [?:1.8.0_292]
2021-12-16T16:53:21.8518480Z Dec 16 16:53:15 2021-12-16 16:44:16,995 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopping TaskExecutor akka.ssl.tcp://flink@127.0.0.1:45031/user/rpc/taskmanager_0.
2021-12-16T16:53:21.8519780Z Dec 16 16:53:15 2021-12-16 16:44:16,995 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Terminating registration attempts towards ResourceManager akka.ssl.tcp://flink@localhost:6123/user/rpc/resourcemanager_*.
2021-12-16T16:53:21.8520880Z Dec 16 16:53:15 2021-12-16 16:44:16,995 INFO org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager [] - Shutting down TaskExecutorStateChangelogStoragesManager.
2021-12-16T16:53:21.8521815Z Dec 16 16:53:15 2021-12-16 16:44:16,999 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job leader service.
2021-12-16T16:53:21.8522669Z Dec 16 16:53:15 2021-12-16 16:44:17,000 INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager [] - Shutting down TaskExecutorLocalStateStoresManager.
2021-12-16T16:53:21.8523748Z Dec 16 16:53:15 2021-12-16 16:44:17,006 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] - FileChannelManager removed spill file directory /tmp/flink-io-356d794f-7c1e-42c7-bb5d-58d5d096f90a
2021-12-16T16:53:21.8524702Z Dec 16 16:53:15 2021-12-16 16:44:17,007 INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment [] - Shutting down the network environment and its components.
2021-12-16T16:53:21.8525549Z Dec 16 16:53:15 2021-12-16 16:44:17,007 INFO org.apache.flink.runtime.io.network.netty.NettyClient [] - Successful shutdown (took 0 ms).
2021-12-16T16:53:21.8526370Z Dec 16 16:53:15 2021-12-16 16:44:17,008 INFO org.apache.flink.runtime.io.network.netty.NettyServer [] - Successful shutdown (took 0 ms).
2021-12-16T16:53:21.8527350Z Dec 16 16:53:15 2021-12-16 16:44:17,011 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] - FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-a85e32fc-e7a0-4ceb-8beb-b931a418f85b
2021-12-16T16:53:21.8528320Z Dec 16 16:53:15 2021-12-16 16:44:17,011 INFO org.apache.flink.runtime.taskexecutor.KvStateService [] - Shutting down the kvState service and its components.
2021-12-16T16:53:21.8529149Z Dec 16 16:53:15 2021-12-16 16:44:17,011 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job leader service.
2021-12-16T16:53:21.8530093Z Dec 16 16:53:15 2021-12-16 16:44:17,011 INFO org.apache.flink.runtime.filecache.FileCache [] - removed file cache directory /tmp/flink-dist-cache-3a780c9f-c395-4355-b496-ade62a0757ad
2021-12-16T16:53:21.8531165Z Dec 16 16:53:15 2021-12-16 16:44:17,017 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopped TaskExecutor akka.ssl.tcp://flink@127.0.0.1:45031/user/rpc/taskmanager_0.
2021-12-16T16:53:21.8532096Z Dec 16 16:53:15 2021-12-16 16:44:17,025 INFO org.apache.flink.runtime.blob.PermanentBlobCache [] - Shutting down BLOB cache
2021-12-16T16:53:21.8532875Z Dec 16 16:53:15 2021-12-16 16:44:17,025 INFO org.apache.flink.runtime.blob.TransientBlobCache [] - Shutting down BLOB cache
2021-12-16T16:53:21.8533663Z Dec 16 16:53:15 2021-12-16 16:44:17,031 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Stopping Akka RPC service.
2021-12-16T16:53:21.8534457Z Dec 16 16:53:15 2021-12-16 16:44:17,036 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Stopping Akka RPC service.
2021-12-16T16:53:21.8535254Z Dec 16 16:53:15 2021-12-16 16:44:17,094 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
2021-12-16T16:53:21.8536051Z Dec 16 16:53:15 2021-12-16 16:44:17,094 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
2021-12-16T16:53:21.8536925Z Dec 16 16:53:15 2021-12-16 16:44:17,095 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
2021-12-16T16:53:21.8537860Z Dec 16 16:53:15 2021-12-16 16:44:17,101 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
2021-12-16T16:53:21.8538683Z Dec 16 16:53:15 2021-12-16 16:44:17,142 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
2021-12-16T16:53:21.8539446Z Dec 16 16:53:15 2021-12-16 16:44:17,146 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
2021-12-16T16:53:21.8540224Z Dec 16 16:53:15 2021-12-16 16:44:17,163 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Stopped Akka RPC service.
2021-12-16T16:53:21.8541162Z Dec 16 16:53:15 2021-12-16 16:44:17,163 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - Terminating TaskManagerRunner with exit code 1.
2021-12-16T16:53:21.8541976Z Dec 16 16:53:15 2021-12-16 16:44:17,163 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Stopped Akka RPC service.
2021-12-16T16:53:21.8542956Z Dec 16 16:53:15 2021-12-16 16:39:12,434 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - --------------------------------------------------------------------------------
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28272&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=070ff179-953e-5bda-71fa-d6599415701c&l=70781
--
This message was sent by Atlassian Jira
(v8.20.1#820001)