search

dyrnq / cdc-vagrant

CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
https://nightlies.apache.org/flink/flink-cdc-docs-stable/
0 stars 0 forks source link

org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0. #12

Open dyrnq opened 1 year ago

dyrnq commented 1 year ago 
2022-12-01 18:34:34,845 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:34:44,904 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:34:44,911 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:34:44,944 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:34:54,999 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:34:55,007 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:34:55,016 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:05,049 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:35:05,054 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:35:05,058 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:15,101 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:35:15,102 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:35:15,112 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:25,155 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:35:25,166 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:35:25,172 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:35,233 WARN  akka.remote.transport.netty.NettyTransport                   [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587
2022-12-01 18:35:35,237 WARN  akka.remote.ReliableDeliverySupervisor                       [] - Association with remote system [akka.tcp://flink@vm116:20587] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@vm116:20587]] Caused by: [java.net.ConnectException: Connection refused: vm116/192.168.56.116:20587]
2022-12-01 18:35:35,258 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Could not resolve ResourceManager address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:41,913 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner      [] - RECEIVED SIGNAL 15: SIGTERM. Shutting down as requested.
2022-12-01 18:35:41,916 INFO  org.apache.flink.runtime.blob.PermanentBlobCache             [] - Shutting down BLOB cache
2022-12-01 18:35:41,917 INFO  org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager [] - Shutting down TaskExecutorStateChangelogStoragesManager.
2022-12-01 18:35:41,917 INFO  org.apache.flink.runtime.blob.TransientBlobCache             [] - Shutting down BLOB cache
2022-12-01 18:35:41,925 INFO  org.apache.flink.runtime.io.disk.FileChannelManagerImpl      [] - FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-bb3718ae-c8d9-4ea8-9a45-4291121d3390
2022-12-01 18:35:41,928 INFO  org.apache.flink.runtime.filecache.FileCache                 [] - removed file cache directory /tmp/flink-dist-cache-1b30d5af-a75b-4674-b228-dcaa90ffb588
2022-12-01 18:35:41,937 INFO  org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager [] - Shutting down TaskExecutorLocalStateStoresManager.
2022-12-01 18:35:41,977 INFO  org.apache.flink.runtime.io.disk.FileChannelManagerImpl      [] - FileChannelManager removed spill file directory /tmp/flink-io-e310b450-98fc-4966-a847-8006ee938f1e
2022-12-01 18:35:41,989 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Stopping TaskExecutor akka.tcp://flink@localhost:7955/user/rpc/taskmanager_0.
2022-12-01 18:35:41,990 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Terminating registration attempts towards ResourceManager akka.tcp://flink@vm116:20587/user/rpc/resourcemanager_0.
2022-12-01 18:35:42,008 INFO  org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job leader service.
2022-12-01 18:35:42,008 INFO  org.apache.flink.runtime.leaderretrieval.DefaultLeaderRetrievalService [] - Stopping DefaultLeaderRetrievalService.
2022-12-01 18:35:42,009 INFO  org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalDriver [] - Closing ZookeeperLeaderRetrievalDriver{connectionInformationPath='/resource_manager/connection_info'}.
2022-12-01 18:35:42,042 INFO  org.apache.flink.runtime.io.network.NettyShuffleEnvironment  [] - Shutting down the network environment and its components.
2022-12-01 18:35:42,289 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2022-12-01 18:35:42,291 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
2022-12-01 18:35:42,328 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remoting shut down.
2022-12-01 18:35:42,353 WARN  akka.actor.CoordinatedShutdown                               [] - Could not addJvmShutdownHook, due to: Shutdown in progress
2022-12-01 18:35:42,360 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Shutting down remote daemon.
2022-12-01 18:35:42,361 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remote daemon shut down; proceeding with flushing remote transports.
2022-12-01 18:35:42,381 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator        [] - Remoting shut down.