22/11/30 11:34:49 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.Boolean 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.util.Properties 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the org.apache.commons.collections.map.LinkedMap 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.Boolean 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the com.ververica.cdc.connectors.mysql.MySqlValidator 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.util.Properties 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the org.apache.flink.api.common.functions.util.PrintSinkOutputWriter 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.Boolean 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.String 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the [B 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.Byte 22/11/30 11:34:50 DEBUG org.apache.flink.api.java.ClosureCleaner: Dig to clean the java.lang.Integer 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraphGenerator: Transforming LegacySinkTransformation{id=2, name='Print to Std. Out', outputType=String, parallelism=1} 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraphGenerator: Transforming LegacySourceTransformation{id=1, name='MySQL Source', outputType=String, parallelism=1} 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraph: Vertex: 1 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraph: Vertex: 2 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraphHasherV2: Generated hash 'cbc357ccb763df2852fee8c4fc7d55f2' for node 'Source: MySQL Source-1' {id: 1, parallelism: 1, user function: com.ververica.cdc.debezium.DebeziumSourceFunction} 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamGraphHasherV2: Generated hash '7df19f87deec5680128845fd9a6ca18d' for node 'Sink: Print to Std. Out-2' {id: 2, parallelism: 1, user function: org.apache.flink.streaming.api.functions.sink.PrintSinkFunction} 22/11/30 11:34:50 DEBUG org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator: Parallelism set: 1 for 1 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.cpu.cores required for local execution is not set, setting it to the maximal possible value. 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.memory.task.heap.size required for local execution is not set, setting it to the maximal possible value. 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.memory.task.off-heap.size required for local execution is not set, setting it to the maximal possible value. 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.memory.network.min required for local execution is not set, setting it to its default value 64 mb. 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.memory.network.max required for local execution is not set, setting it to its default value 64 mb. 22/11/30 11:34:50 INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils: The configuration option taskmanager.memory.managed.size required for local execution is not set, setting it to its default value 128 mb. 22/11/30 11:34:50 INFO org.apache.flink.runtime.minicluster.MiniCluster: Starting Flink Mini Cluster 22/11/30 11:34:50 DEBUG org.apache.flink.runtime.minicluster.MiniCluster: Using configuration MiniClusterConfiguration {singleRpcService=SHARED, numTaskManagers=1, commonBindAddress='null', config={taskmanager.memory.network.min=64 mb, taskmanager.cpu.cores=1000000.0, taskmanager.memory.task.off-heap.size=1099511627776 bytes, taskmanager.memory.jvm-metaspace.size=256 mb, execution.target=local, cluster.io-pool.size=4, taskmanager.memory.jvm-overhead.min=1 gb, rest.bind-port=0, taskmanager.memory.network.max=64 mb, taskmanager.memory.framework.off-heap.size=128 mb, execution.attached=true, taskmanager.memory.managed.size=128 mb, taskmanager.memory.framework.heap.size=128 mb, parallelism.default=16, taskmanager.numberOfTaskSlots=1, taskmanager.memory.task.heap.size=1099511627776 bytes, rest.address=localhost, taskmanager.memory.jvm-overhead.max=1 gb, akka.ask.timeout=PT5M}} 22/11/30 11:34:50 INFO org.apache.flink.runtime.minicluster.MiniCluster: Starting Metrics Registry 22/11/30 11:34:50 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl: No metrics reporter configured, no metrics will be exposed/reported. 22/11/30 11:34:50 INFO org.apache.flink.runtime.minicluster.MiniCluster: Starting RPC Service(s) 22/11/30 11:34:50 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Trying to start local actor system 22/11/30 11:34:50 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Using akka configuration Config(SimpleConfigObject({"akka":{"actor":{"allow-java-serialization":"on","default-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-factor":1,"parallelism-max":4,"parallelism-min":2},"throughput":15},"guardian-supervisor-strategy":"org.apache.flink.runtime.rpc.akka.EscalatingSupervisorStrategy","supervisor-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-max":1,"core-pool-size-min":1},"type":"Dispatcher"},"warn-about-java-serializer-usage":"off"},"daemonic":"off","jvm-exit-on-fatal-error":"on","log-config-on-start":"off","log-dead-letters":"off","log-dead-letters-during-shutdown":"off","logger-startup-timeout":"50s","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"DEBUG","serialize-messages":"off","stdout-loglevel":"OFF"}})) 22/11/30 11:34:51 INFO akka.event.slf4j.Slf4jLogger: Slf4jLogger started 22/11/30 11:34:51 DEBUG akka.event.EventStream: logger log1-Slf4jLogger started 22/11/30 11:34:51 DEBUG akka.event.EventStream: Default Loggers started 22/11/30 11:34:51 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Actor system started at akka://flink 22/11/30 11:34:51 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Trying to start local actor system 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Using akka configuration Config(SimpleConfigObject({"akka":{"actor":{"allow-java-serialization":"on","default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-max":1,"core-pool-size-min":1},"thread-priority":1,"throughput":15,"type":"org.apache.flink.runtime.rpc.akka.PriorityThreadsDispatcher"},"guardian-supervisor-strategy":"org.apache.flink.runtime.rpc.akka.EscalatingSupervisorStrategy","supervisor-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-max":1,"core-pool-size-min":1},"type":"Dispatcher"},"warn-about-java-serializer-usage":"off"},"daemonic":"off","jvm-exit-on-fatal-error":"on","log-config-on-start":"off","log-dead-letters":"off","log-dead-letters-during-shutdown":"off","logger-startup-timeout":"50s","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"DEBUG","serialize-messages":"off","stdout-loglevel":"OFF"}})) 22/11/30 11:34:51 INFO akka.event.slf4j.Slf4jLogger: Slf4jLogger started 22/11/30 11:34:51 DEBUG akka.event.EventStream: logger log1-Slf4jLogger started 22/11/30 11:34:51 DEBUG akka.event.EventStream: Default Loggers started 22/11/30 11:34:51 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils: Actor system started at akka://flink-metrics 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Starting AkkaRpcActor with name MetricQueryService. 22/11/30 11:34:51 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService . 22/11/30 11:34:51 INFO org.apache.flink.runtime.minicluster.MiniCluster: Starting high-availability services 22/11/30 11:34:51 INFO org.apache.flink.runtime.blob.BlobServer: Created BLOB server storage directory C:\Users\maohj\AppData\Local\Temp\blobStore-f43f2101-a60d-4c0f-bc48-5de97018df9d 22/11/30 11:34:51 DEBUG org.apache.flink.util.NetUtils: Trying to open socket on port 0 22/11/30 11:34:51 INFO org.apache.flink.runtime.blob.BlobServer: Started BLOB server at 0.0.0.0:52382 - max concurrent requests: 50 - max backlog: 1000 22/11/30 11:34:51 INFO org.apache.flink.runtime.blob.PermanentBlobCache: Created BLOB cache storage directory C:\Users\maohj\AppData\Local\Temp\blobStore-fafddfd0-1912-4539-972a-22cab832de7e 22/11/30 11:34:51 INFO org.apache.flink.runtime.blob.TransientBlobCache: Created BLOB cache storage directory C:\Users\maohj\AppData\Local\Temp\blobStore-70550f0c-1f1b-4fdb-9a05-40f9cd5b9d62 22/11/30 11:34:51 INFO org.apache.flink.runtime.minicluster.MiniCluster: Starting 1 TaskManager(s) 22/11/30 11:34:51 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner: Starting TaskManager with ResourceID: a37e9916-a8e6-45b6-a4ea-f673aece4c03 22/11/30 11:34:51 INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices: Temporary file directory 'C:\Users\maohj\AppData\Local\Temp': total 237 GB, usable 10 GB (4.22% usable) 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.io.disk.FileChannelManagerImpl: FileChannelManager uses directory C:\Users\maohj\AppData\Local\Temp\flink-io-fcc414b0-13a4-4f57-a193-766812fa91a7 for spill files. 22/11/30 11:34:51 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager: Created a new FileChannelManager for spilling of task related data to disk (joins, sorting, ...). Used directories: C:\Users\maohj\AppData\Local\Temp\flink-io-fcc414b0-13a4-4f57-a193-766812fa91a7 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.io.disk.FileChannelManagerImpl: FileChannelManager uses directory C:\Users\maohj\AppData\Local\Temp\flink-netty-shuffle-423fcca3-7342-435e-9aff-a150ef985801 for spill files. 22/11/30 11:34:51 INFO org.apache.flink.runtime.io.network.NettyShuffleServiceFactory: Created a new FileChannelManager for storing result partitions of BLOCKING shuffles. Used directories: C:\Users\maohj\AppData\Local\Temp\flink-netty-shuffle-423fcca3-7342-435e-9aff-a150ef985801 22/11/30 11:34:51 INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool: Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768). 22/11/30 11:34:51 INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment: Starting the network environment and its components. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment: Starting network connection manager 22/11/30 11:34:51 INFO org.apache.flink.runtime.taskexecutor.KvStateService: Starting the kvState service and its components. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration: Messages have a max timeout of 300000 ms 22/11/30 11:34:51 INFO org.apache.flink.configuration.Configuration: Config uses fallback configuration key 'akka.ask.timeout' instead of key 'taskmanager.slot.timeout' 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Starting AkkaRpcActor with name taskmanager_0. 22/11/30 11:34:51 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/rpc/taskmanager_0 . 22/11/30 11:34:51 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Start job leader service. 22/11/30 11:34:51 INFO org.apache.flink.runtime.filecache.FileCache: User file cache uses directory C:\Users\maohj\AppData\Local\Temp\flink-dist-cache-4fadb272-3cbd-4c8e-a2be-7fc0c0fdd522 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory: Starting Dispatcher REST endpoint. 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Starting rest endpoint. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Failed to load web based job submission extension. org.apache.flink.util.FlinkException: The module flink-runtime-web could not be found in the class path. Please add this jar in order to enable web based job submission. at org.apache.flink.runtime.webmonitor.WebMonitorUtils.loadWebSubmissionExtension(WebMonitorUtils.java:197) at org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint.initializeWebSubmissionHandlers(DispatcherRestEndpoint.java:110) at org.apache.flink.runtime.webmonitor.WebMonitorEndpoint.initializeHandlers(WebMonitorEndpoint.java:262) at org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint.initializeHandlers(DispatcherRestEndpoint.java:87) at org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:178) at org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory.create(DefaultDispatcherResourceManagerComponentFactory.java:172) at org.apache.flink.runtime.minicluster.MiniCluster.createDispatcherResourceManagerComponents(MiniCluster.java:478) at org.apache.flink.runtime.minicluster.MiniCluster.setupDispatcherResourceManagerComponents(MiniCluster.java:436) at org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:380) at org.apache.flink.client.program.PerJobMiniClusterFactory.submitJob(PerJobMiniClusterFactory.java:75) at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:85) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2042) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1930) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:69) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1916) at DeprecatedMysqlCDC.main(DeprecatedMysqlCDC.java:56) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.logging.InternalLoggerFactory: Using SLF4J as the default logging framework 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap: -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap: -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096 22/11/30 11:34:51 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils: Log file environment variable 'log.file' is not set. 22/11/30 11:34:51 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils: JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'. 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: -Dio.netty.noUnsafe: false 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: Java version: 11 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: sun.misc.Unsafe.theUnsafe: available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: sun.misc.Unsafe.copyMemory: available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: java.nio.Buffer.address: available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: direct buffer constructor: unavailable: Reflective setAccessible(true) disabled 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: java.nio.Bits.unaligned: available, true 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable: class org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0$6 cannot access class jdk.internal.misc.Unsafe (in module java.base) because module java.base does not export jdk.internal.misc to unnamed module @49ec71f8 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0: java.nio.DirectByteBuffer.(long, int): unavailable 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: sun.misc.Unsafe: available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: maxDirectMemory: 8516534272 bytes (maybe) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: -Dio.netty.tmpdir: C:\Users\maohj\AppData\Local\Temp (java.io.tmpdir) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: -Dio.netty.bitMode: 64 (sun.arch.data.model) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: Platform: Windows 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: -Dio.netty.maxDirectMemory: -1 bytes 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: -Dio.netty.uninitializedArrayAllocationThreshold: -1 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.CleanerJava9: java.nio.ByteBuffer.cleaner(): available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: -Dio.netty.noPreferDirect: false 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@2e1ddc90 under DELETE@/v1/cluster. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@2e1ddc90 under DELETE@/cluster. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@285c6918 under GET@/v1/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@285c6918 under GET@/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetListHandler@78a0ff63 under GET@/v1/datasets. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetListHandler@78a0ff63 under GET@/datasets. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetDeleteHandlers$ClusterDataSetDeleteStatusHandler@7c601d50 under GET@/v1/datasets/delete/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetDeleteHandlers$ClusterDataSetDeleteStatusHandler@7c601d50 under GET@/datasets/delete/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetDeleteHandlers$ClusterDataSetDeleteTriggerHandler@79b2852b under DELETE@/v1/datasets/:datasetid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.dataset.ClusterDataSetDeleteHandlers$ClusterDataSetDeleteTriggerHandler@79b2852b under DELETE@/datasets/:datasetid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@326d27ac under GET@/v1/jobmanager/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@326d27ac under GET@/jobmanager/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogFileHandler@4d499d65 under GET@/v1/jobmanager/log. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogFileHandler@4d499d65 under GET@/jobmanager/log. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogListHandler@313f8301 under GET@/v1/jobmanager/logs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogListHandler@313f8301 under GET@/jobmanager/logs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerCustomLogHandler@5cc9d3d0 under GET@/v1/jobmanager/logs/:filename. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerCustomLogHandler@5cc9d3d0 under GET@/jobmanager/logs/:filename. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@7c2dfa2 under GET@/v1/jobmanager/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@7c2dfa2 under GET@/jobmanager/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogFileHandler@661d88a under GET@/v1/jobmanager/stdout. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.JobManagerLogFileHandler@661d88a under GET@/jobmanager/stdout. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@4b0b64cc under GET@/v1/jobs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@4b0b64cc under GET@/jobs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@59ce792e under POST@/v1/jobs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@59ce792e under POST@/jobs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@4860827a under GET@/v1/jobs/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@4860827a under GET@/jobs/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@404db674 under GET@/v1/jobs/overview. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@404db674 under GET@/jobs/overview. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@50f097b5 under GET@/v1/jobs/:jobid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@50f097b5 under GET@/jobs/:jobid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7add838c under PATCH@/v1/jobs/:jobid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7add838c under PATCH@/jobs/:jobid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@3662bdff under GET@/v1/jobs/:jobid/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@3662bdff under GET@/jobs/:jobid/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@1bb15351 under GET@/v1/jobs/:jobid/checkpoints. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@1bb15351 under GET@/jobs/:jobid/checkpoints. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@4fa822ad under GET@/v1/jobs/:jobid/checkpoints/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@4fa822ad under GET@/jobs/:jobid/checkpoints/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@597f0937 under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@597f0937 under GET@/jobs/:jobid/checkpoints/details/:checkpointid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@7ad1caa2 under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@7ad1caa2 under GET@/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@6b6b3572 under GET@/v1/jobs/:jobid/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@6b6b3572 under GET@/jobs/:jobid/config. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.coordination.ClientCoordinationHandler@65d8dff8 under POST@/v1/jobs/:jobid/coordinators/:operatorid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.coordination.ClientCoordinationHandler@65d8dff8 under POST@/jobs/:jobid/coordinators/:operatorid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@444f44c5 under GET@/v1/jobs/:jobid/exceptions. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@444f44c5 under GET@/jobs/:jobid/exceptions. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@303f1234 under GET@/v1/jobs/:jobid/execution-result. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@303f1234 under GET@/jobs/:jobid/execution-result. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@24d61e4 under GET@/v1/jobs/:jobid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@24d61e4 under GET@/jobs/:jobid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@2149594a under GET@/v1/jobs/:jobid/plan. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@2149594a under GET@/jobs/:jobid/plan. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@1f1e58ca under PATCH@/v1/jobs/:jobid/rescaling. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@1f1e58ca under PATCH@/jobs/:jobid/rescaling. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@57f847af under GET@/v1/jobs/:jobid/rescaling/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@57f847af under GET@/jobs/:jobid/rescaling/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@3ed34ef5 under POST@/v1/jobs/:jobid/savepoints. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@3ed34ef5 under POST@/jobs/:jobid/savepoints. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@553bc36c under GET@/v1/jobs/:jobid/savepoints/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@553bc36c under GET@/jobs/:jobid/savepoints/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@380e1909 under POST@/v1/jobs/:jobid/stop. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@380e1909 under POST@/jobs/:jobid/stop. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@2d5ef498 under GET@/v1/jobs/:jobid/vertices/:vertexid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@2d5ef498 under GET@/jobs/:jobid/vertices/:vertexid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@95eb320 under GET@/v1/jobs/:jobid/vertices/:vertexid/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@95eb320 under GET@/jobs/:jobid/vertices/:vertexid/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@2f521c4 under GET@/v1/jobs/:jobid/vertices/:vertexid/backpressure. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@2f521c4 under GET@/jobs/:jobid/vertices/:vertexid/backpressure. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexFlameGraphHandler$DisabledJobVertexFlameGraphHandler@4afbb6c2 under GET@/v1/jobs/:jobid/vertices/:vertexid/flamegraph. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexFlameGraphHandler$DisabledJobVertexFlameGraphHandler@4afbb6c2 under GET@/jobs/:jobid/vertices/:vertexid/flamegraph. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@10db6131 under GET@/v1/jobs/:jobid/vertices/:vertexid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@10db6131 under GET@/jobs/:jobid/vertices/:vertexid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@6c6017b9 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@6c6017b9 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@4730e0f0 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@4730e0f0 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@506a1372 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@506a1372 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@1b7332a7 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@1b7332a7 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@77c233af under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@77c233af under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@37b56ac7 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@37b56ac7 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@37c41ec0 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasktimes. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@37c41ec0 under GET@/jobs/:jobid/vertices/:vertexid/subtasktimes. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@35a0e495 under GET@/v1/jobs/:jobid/vertices/:vertexid/taskmanagers. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@35a0e495 under GET@/jobs/:jobid/vertices/:vertexid/taskmanagers. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexWatermarksHandler@5399f6c5 under GET@/v1/jobs/:jobid/vertices/:vertexid/watermarks. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexWatermarksHandler@5399f6c5 under GET@/jobs/:jobid/vertices/:vertexid/watermarks. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@4fe64d23 under GET@/v1/jobs/:jobid/yarn-cancel. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@4fe64d23 under GET@/jobs/:jobid/yarn-cancel. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@58437801 under GET@/v1/jobs/:jobid/yarn-stop. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@58437801 under GET@/jobs/:jobid/yarn-stop. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@6af5bbd0 under GET@/v1/overview. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@6af5bbd0 under GET@/overview. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@76464795 under POST@/v1/savepoint-disposal. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@76464795 under POST@/savepoint-disposal. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@b34832b under GET@/v1/savepoint-disposal/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@b34832b under GET@/savepoint-disposal/:triggerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@48f4713c under GET@/v1/taskmanagers. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@48f4713c under GET@/taskmanagers. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@f1868c9 under GET@/v1/taskmanagers/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@f1868c9 under GET@/taskmanagers/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@4ba6ec50 under GET@/v1/taskmanagers/:taskmanagerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@4ba6ec50 under GET@/taskmanagers/:taskmanagerid. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@642413d4 under GET@/v1/taskmanagers/:taskmanagerid/log. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@642413d4 under GET@/taskmanagers/:taskmanagerid/log. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogListHandler@fb2e3fd under GET@/v1/taskmanagers/:taskmanagerid/logs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogListHandler@fb2e3fd under GET@/taskmanagers/:taskmanagerid/logs. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerCustomLogHandler@43a09ce2 under GET@/v1/taskmanagers/:taskmanagerid/logs/:filename. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerCustomLogHandler@43a09ce2 under GET@/taskmanagers/:taskmanagerid/logs/:filename. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@3f183caa under GET@/v1/taskmanagers/:taskmanagerid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@3f183caa under GET@/taskmanagers/:taskmanagerid/metrics. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@7b66322e under GET@/v1/taskmanagers/:taskmanagerid/stdout. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@7b66322e under GET@/taskmanagers/:taskmanagerid/stdout. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerThreadDumpHandler@63538bb4 under GET@/v1/taskmanagers/:taskmanagerid/thread-dump. 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerThreadDumpHandler@63538bb4 under GET@/taskmanagers/:taskmanagerid/thread-dump. 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.MultithreadEventLoopGroup: -Dio.netty.eventLoopThreads: 32 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop: -Dio.netty.noKeySetOptimization: false 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop: -Dio.netty.selectorAutoRebuildThreshold: 512 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent: org.jctools-core.MpscChunkedArrayQueue: available 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId: -Dio.netty.processId: 20744 (auto-detected) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil: -Djava.net.preferIPv4Stack: false 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil: -Djava.net.preferIPv6Addresses: false 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtilInitializations: Loopback interface: lo (Software Loopback Interface 1, 127.0.0.1) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil: Failed to get SOMAXCONN from sysctl and file \proc\sys\net\core\somaxconn. Default: 200 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId: -Dio.netty.machineId: b0:7b:25:ff:fe:28:e7:4a (auto-detected) 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector: -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.level: simple 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector: -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.targetRecords: 4 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.numHeapArenas: 32 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.numDirectArenas: 32 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.pageSize: 8192 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.maxOrder: 11 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.chunkSize: 16777216 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.smallCacheSize: 256 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.normalCacheSize: 64 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.maxCachedBufferCapacity: 32768 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.cacheTrimInterval: 8192 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.cacheTrimIntervalMillis: 0 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.useCacheForAllThreads: true 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator: -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil: -Dio.netty.allocator.type: pooled 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil: -Dio.netty.threadLocalDirectBufferSize: 0 22/11/30 11:34:51 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil: -Dio.netty.maxThreadLocalCharBufferSize: 16384 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Binding rest endpoint to null:0. 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Rest endpoint listening at localhost:52449 22/11/30 11:34:51 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Proposing leadership to contender http://localhost:52449 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: http://localhost:52449 was granted leadership with leaderSessionID=046a5830-4be9-41c6-b75c-e7a65dbf5c48 22/11/30 11:34:51 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Received confirmation of leadership for leader http://localhost:52449 , session=046a5830-4be9-41c6-b75c-e7a65dbf5c48 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory: Starting Dispatcher. 22/11/30 11:34:51 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Proposing leadership to contender LeaderContender: DefaultDispatcherRunner 22/11/30 11:34:51 DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory: Starting ResourceManagerService. 22/11/30 11:34:51 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl: Starting resource manager service. 22/11/30 11:34:51 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Proposing leadership to contender LeaderContender: ResourceManagerServiceImpl 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner: DefaultDispatcherRunner was granted leadership with leader id e46e6682-892e-470e-a82e-5812c76151f8. Creating new DispatcherLeaderProcess. 22/11/30 11:34:51 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl: Resource manager service is granted leadership with session id ad85805f-a38e-4ed2-abeb-89f5aef83e02. 22/11/30 11:34:51 INFO org.apache.flink.runtime.minicluster.MiniCluster: Flink Mini Cluster started successfully 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess: Start SessionDispatcherLeaderProcess. 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess: Recover all persisted job graphs. 22/11/30 11:34:51 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess: Successfully recovered 0 persisted job graphs. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Starting FencedAkkaRpcActor with name dispatcher_1. 22/11/30 11:34:52 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_1 . 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Starting FencedAkkaRpcActor with name resourcemanager_2. 22/11/30 11:34:52 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_2 . 22/11/30 11:34:52 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Received confirmation of leadership for leader akka://flink/user/rpc/dispatcher_1 , session=e46e6682-892e-470e-a82e-5812c76151f8 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/dispatcher_1. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/dispatcher_1. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Starting the resource manager. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Starting the slot manager. 22/11/30 11:34:52 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Received confirmation of leadership for leader akka://flink/user/rpc/resourcemanager_2 , session=ad85805f-a38e-4ed2-abeb-89f5aef83e02 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Trigger heartbeat request. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/resourcemanager_2. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/resourcemanager_2. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Trigger heartbeat request. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_2(abeb89f5aef83e02ad85805fa38e4ed2). 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/resourcemanager_2. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Resolved ResourceManager address, beginning registration 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Registration at ResourceManager attempt 1 (timeout=100ms) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Received JobGraph submission 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Submitting job 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Registering TaskManager with ResourceID a37e9916-a8e6-45b6-a4ea-f673aece4c03 (akka://flink/user/rpc/taskmanager_0) at ResourceManager 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Registration with ResourceManager at akka://flink/user/rpc/resourcemanager_2 was successful. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Successful registration at resource manager akka://flink/user/rpc/resourcemanager_2 under registration id 8f50687ee814e67b0a110073657f6a12. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Registering task executor a37e9916-a8e6-45b6-a4ea-f673aece4c03 under 8f50687ee814e67b0a110073657f6a12 at the slot manager. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Start leadership runner for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Proposing leadership to contender LeaderContender: JobMasterServiceLeadershipRunner 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Create new JobMasterServiceProcess because we were granted leadership under 4a8ea290-eccf-46a2-935d-7d49004f562e. 22/11/30 11:34:52 DEBUG org.apache.flink.client.ClientUtils: Wait until job initialization is finished 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Starting FencedAkkaRpcActor with name jobmanager_3. 22/11/30 11:34:52 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/rpc/jobmanager_3 . 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Initializing job 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Using restart back off time strategy NoRestartBackoffTimeStrategy for Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Running initialization on master for job Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Successfully ran initialization on master in 0 ms. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Adding 1 vertices from job graph Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph: Attaching 1 topologically sorted vertices to existing job graph with 0 vertices and 0 intermediate results. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph: Connecting ExecutionJobVertex cbc357ccb763df2852fee8c4fc7d55f2 (Source: MySQL Source -> Sink: Print to Std. Out) to 0 predecessors. 22/11/30 11:34:52 INFO org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology: Built 1 pipelined regions in 1 ms 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Successfully created execution graph from job graph Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@544673bf 22/11/30 11:34:52 INFO org.apache.flink.runtime.state.StateBackendLoader: State backend loader loads the state backend as HashMapStateBackend 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: The configuration state.checkpoint-storage has not be set in the current sessions flink-conf.yaml. Falling back to a default CheckpointStorage type. Users are strongly encouraged explicitly set this configuration so they understand how their applications are checkpointing snapshots for fault-tolerance. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Checkpoint storage is set to 'jobmanager' 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Status of the shared state registry of job 8659e3019b4214efb7d2a1a0b7be240c after restore: SharedStateRegistry{registeredStates={}}. 22/11/30 11:34:52 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator: No checkpoint found during restore. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Resetting the master hooks. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@37f97855 for Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess: Successfully created the JobMasterService for job 8659e3019b4214efb7d2a1a0b7be240c under leader id 4a8ea290-eccf-46a2-935d-7d49004f562e. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Confirm leadership 4a8ea290-eccf-46a2-935d-7d49004f562e. 22/11/30 11:34:52 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService: Received confirmation of leadership for leader akka://flink/user/rpc/jobmanager_3 , session=4a8ea290-eccf-46a2-935d-7d49004f562e 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Starting execution of job 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c) under job master id 935d7d49004f562e4a8ea290eccf46a2. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy] 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Job Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c) switched from state CREATED to RUNNING. 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Source: MySQL Source -> Sink: Print to Std. Out (1/1) (ab7ff693a2a29d55c1412ca2658b6b55) switched from CREATED to SCHEDULED. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.PhysicalSlotProviderImpl: Received slot request [SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}] with resource requirements: ResourceProfile{UNKNOWN} 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Request new allocated slot with slot request id SlotRequestId{251c191ba454e6735e171bc6ad39e8a7} and resource profile ResourceProfile{UNKNOWN} 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Declare new resource requirements for job 8659e3019b4214efb7d2a1a0b7be240c. required resources: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}] acquired resources: ResourceCounter{resources={}} 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.scheduler.SharedSlot: Request a logical slot (SlotRequestId{7d92301d449bc31887249c8b1ecdec7f}) for execution vertex (id cbc357ccb763df2852fee8c4fc7d55f2_0) from the physical slot (SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Trigger heartbeat request. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Connecting to ResourceManager akka://flink/user/rpc/resourcemanager_2(abeb89f5aef83e02ad85805fa38e4ed2) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/resourcemanager_2. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: Resolved ResourceManager address, beginning registration 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Registration at ResourceManager attempt 1 (timeout=100ms) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.DefaultJobLeaderIdService: Add job 8659e3019b4214efb7d2a1a0b7be240c to job leader id monitoring. 22/11/30 11:34:52 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Registering job manager 935d7d49004f562e4a8ea290eccf46a2@akka://flink/user/rpc/jobmanager_3 for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.DefaultJobLeaderIdService: Job 8659e3019b4214efb7d2a1a0b7be240c has a new job leader 4a8ea290-eccf-46a2-935d-7d49004f562e@akka://flink/user/rpc/jobmanager_3. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/jobmanager_3. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Registered job manager 935d7d49004f562e4a8ea290eccf46a2@akka://flink/user/rpc/jobmanager_3 for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Registration with ResourceManager at akka://flink/user/rpc/resourcemanager_2 was successful. 22/11/30 11:34:52 INFO org.apache.flink.runtime.jobmaster.JobMaster: JobManager successfully registered at ResourceManager, leader id: abeb89f5aef83e02ad85805fa38e4ed2. 22/11/30 11:34:52 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Received resource requirements from job 8659e3019b4214efb7d2a1a0b7be240c: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}] 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DefaultResourceTracker: Initiating tracking of resources for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Starting allocation of slot a37e9916-a8e6-45b6-a4ea-f673aece4c03_0 for job 8659e3019b4214efb7d2a1a0b7be240c with resource profile ResourceProfile{UNKNOWN}. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Receive slot request 61fe8e4949dc7be06004134f350bc424 for job 8659e3019b4214efb7d2a1a0b7be240c from resource manager with leader id abeb89f5aef83e02ad85805fa38e4ed2. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.memory.MemoryManager: Initialized MemoryManager with total memory size 134217728 and page size 32768. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Allocated slot for 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Add job 8659e3019b4214efb7d2a1a0b7be240c for job leader monitoring. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: New leader information for job 8659e3019b4214efb7d2a1a0b7be240c. Address: akka://flink/user/rpc/jobmanager_3, leader id: 935d7d49004f562e4a8ea290eccf46a2. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Try to register at job manager akka://flink/user/rpc/jobmanager_3 with leader id 4a8ea290-eccf-46a2-935d-7d49004f562e. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/jobmanager_3. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Resolved JobManager address, beginning registration 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Registration at JobManager attempt 1 (timeout=100ms) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService: Try to connect to remote RPC endpoint with address akka://flink/user/rpc/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Register new TaskExecutor a37e9916-a8e6-45b6-a4ea-f673aece4c03. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Registration with JobManager at akka://flink/user/rpc/jobmanager_3 was successful. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Successful registration at job manager akka://flink/user/rpc/jobmanager_3 for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Establish JobManager connection for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Offer reserved slots to the leader of job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Received 1 slot offers from TaskExecutor a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1). 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Matched slot offer 61fe8e4949dc7be06004134f350bc424 to requirement ResourceProfile{UNKNOWN}. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Acquired new resources; new total acquired resources: ResourceCounter{resources={ResourceProfile{UNKNOWN}=1}} 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Matched slot AllocatedSlot 61fe8e4949dc7be06004134f350bc424 @ a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1) - 0 to pending request PendingRequest{slotRequestId=SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}, resourceProfile=ResourceProfile{UNKNOWN}, isBatchRequest=false, unfulfillableSince=9223372036854775807}. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Reserve slot 61fe8e4949dc7be06004134f350bc424 for slot request id SlotRequestId{251c191ba454e6735e171bc6ad39e8a7} 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultAllocatedSlotPool: Reserve free slot with allocation id 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.scheduler.SharedSlot: Allocated logical slot (SlotRequestId{7d92301d449bc31887249c8b1ecdec7f}) for execution vertex (id cbc357ccb763df2852fee8c4fc7d55f2_0) from the physical slot (SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}) 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Source: MySQL Source -> Sink: Print to Std. Out (1/1) (ab7ff693a2a29d55c1412ca2658b6b55) switched from SCHEDULED to DEPLOYING. 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Deploying Source: MySQL Source -> Sink: Print to Std. Out (1/1) (attempt #0) with attempt id ab7ff693a2a29d55c1412ca2658b6b55 to a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1) with allocation id 61fe8e4949dc7be06004134f350bc424 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl: Activate slot 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager: Registered new allocation id 61fe8e4949dc7be06004134f350bc424 for local state stores for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager: Registered new local state store with configuration LocalRecoveryConfig{localRecoveryMode=false, localStateDirectories=LocalRecoveryDirectoryProvider{rootDirectories=[C:\Users\maohj\AppData\Local\Temp\localState\aid_61fe8e4949dc7be06004134f350bc424], jobID=8659e3019b4214efb7d2a1a0b7be240c, jobVertexID=cbc357ccb763df2852fee8c4fc7d55f2, subtaskIndex=0}} for 8659e3019b4214efb7d2a1a0b7be240c - cbc357ccb763df2852fee8c4fc7d55f2 - 0 under allocation id 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 INFO org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader: StateChangelogStorageLoader initialized with shortcut names {memory}. 22/11/30 11:34:52 INFO org.apache.flink.runtime.state.changelog.StateChangelogStorageLoader: Creating a changelog storage with name 'memory'. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager: Registered new state changelog storage for job 8659e3019b4214efb7d2a1a0b7be240c : org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogStorage@4c18bda1. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Received task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55), deploy into slot with allocation id 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskmanager.Task: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) switched from CREATED to DEPLOYING. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskmanager.Task: Creating FileSystem stream leak safety net for task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) [DEPLOYING] 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl: Activate slot 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskmanager.Task: Loading JAR files for task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) [DEPLOYING]. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskmanager.Task: Getting user code class loader for task ab7ff693a2a29d55c1412ca2658b6b55 at library cache manager took 0 milliseconds 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskmanager.Task: Registering task at network: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) [DEPLOYING]. 22/11/30 11:34:52 INFO org.apache.flink.streaming.runtime.tasks.StreamTask: No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@49981441 22/11/30 11:34:52 INFO org.apache.flink.runtime.state.StateBackendLoader: State backend loader loads the state backend as HashMapStateBackend 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: The configuration state.checkpoint-storage has not be set in the current sessions flink-conf.yaml. Falling back to a default CheckpointStorage type. Users are strongly encouraged explicitly set this configuration so they understand how their applications are checkpointing snapshots for fault-tolerance. 22/11/30 11:34:52 INFO org.apache.flink.streaming.runtime.tasks.StreamTask: Checkpoint storage is set to 'jobmanager' 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskmanager.Task: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) switched from DEPLOYING to INITIALIZING. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Initializing Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0. 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Source: MySQL Source -> Sink: Print to Std. Out (1/1) (ab7ff693a2a29d55c1412ca2658b6b55) switched from DEPLOYING to INITIALIZING. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Invoking Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.api.operators.BackendRestorerProcedure: Creating operator state backend for StreamSink_7df19f87deec5680128845fd9a6ca18d_(1/1) with empty state. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.api.operators.BackendRestorerProcedure: Creating operator state backend for StreamSource_cbc357ccb763df2852fee8c4fc7d55f2_(1/1) with empty state. 22/11/30 11:34:52 INFO com.ververica.cdc.debezium.DebeziumSourceFunction: Consumer subtask 0 has no restore state. 22/11/30 11:34:52 DEBUG io.debezium.jdbc.JdbcConnection: Connected to jdbc:mysql://192.168.4.231:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with {server.name=mysql_binlog_source, whitelist=test, useLegacyDatetimeCode=false, password=***, server.id=132456, user=dbzuser} 22/11/30 11:34:52 INFO io.debezium.jdbc.JdbcConnection: Connection gracefully closed 22/11/30 11:34:52 INFO com.ververica.cdc.connectors.mysql.MySqlValidator: MySQL validation passed. 22/11/30 11:34:52 INFO org.apache.flink.runtime.taskmanager.Task: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) switched from INITIALIZING to RUNNING. 22/11/30 11:34:52 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Source: MySQL Source -> Sink: Print to Std. Out (1/1) (ab7ff693a2a29d55c1412ca2658b6b55) switched from INITIALIZING to RUNNING. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Legacy source Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) skip execution since the task is finished on restore 22/11/30 11:34:52 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Triggering checkpoint 1 (type=CHECKPOINT) @ 1669808092585 for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Trigger checkpoint 1@1669808092585 for ab7ff693a2a29d55c1412ca2658b6b55. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Starting checkpoint 1 CHECKPOINT on task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.SnapshotStrategyRunner: DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous part) in thread Thread[Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0,5,Flink Task Threads] took 0 ms. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.SnapshotStrategyRunner: DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous part) in thread Thread[Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0,5,Flink Task Threads] took 0 ms. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 - finished synchronous part of checkpoint 1. Alignment duration: 0 ms, snapshot duration -1 ms, is unaligned checkpoint : false 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 - started executing asynchronous part of checkpoint 1. Asynchronous start delay: 0 ms 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.SnapshotStrategyRunner: DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, asynchronous part) in thread Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 8 ms. 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.state.SnapshotStrategyRunner: DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, asynchronous part) in thread Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 0 ms. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 - finished asynchronous part of checkpoint 1. Asynchronous duration: 9 ms 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Received acknowledge message for checkpoint 1 from task ab7ff693a2a29d55c1412ca2658b6b55 of job 8659e3019b4214efb7d2a1a0b7be240c at a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1). 22/11/30 11:34:52 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Completed checkpoint 1 for job 8659e3019b4214efb7d2a1a0b7be240c (444 bytes, checkpointDuration=34 ms, finalizationTime=4 ms). 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Checkpoint state: OperatorState(operatorID: cbc357ccb763df2852fee8c4fc7d55f2, parallelism: 1, maxParallelism: 128, coordinatorState: (none), sub task states: 1, total size (bytes): 444), OperatorState(operatorID: 7df19f87deec5680128845fd9a6ca18d, parallelism: 1, maxParallelism: 128, coordinatorState: (none), sub task states: 1, total size (bytes): 0) 22/11/30 11:34:52 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Confirm checkpoint 1@1669808092585 for ab7ff693a2a29d55c1412ca2658b6b55. 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Notify checkpoint 1 complete on task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 22/11/30 11:34:52 DEBUG org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl: Notification of completed checkpoint 1 for task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 22/11/30 11:34:52 DEBUG com.ververica.cdc.debezium.DebeziumSourceFunction: notifyCheckpointComplete() called when engine is not started. 22/11/30 11:34:52 INFO com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverterConfig: JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true 22/11/30 11:34:52 INFO com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverterConfig: JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false 22/11/30 11:34:52 INFO io.debezium.embedded.EmbeddedEngine$EmbeddedConfig: EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = None header.converter = class com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.storage.SimpleHeaderConverter internal.key.converter = class com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter internal.value.converter = class com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter key.converter = class com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter listeners = null metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 9223372036854775807 offset.flush.timeout.ms = 5000 offset.storage.file.filename = offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] rest.host.name = null rest.port = 8083 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter 22/11/30 11:34:52 INFO com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.runtime.WorkerConfig: Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value 'com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. 22/11/30 11:34:52 INFO com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.runtime.WorkerConfig: Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value 'com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverter' matches the default, so this property can be safely removed from the worker configuration. 22/11/30 11:34:52 WARN com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.runtime.WorkerConfig: Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 22/11/30 11:34:52 WARN io.debezium.config.Configuration: Using configuration property "table.whitelist" is deprecated and will be removed in future versions. Please use "table.include.list" instead. 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: Starting MySqlConnectorTask with configuration: 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: connector.class = io.debezium.connector.mysql.MySqlConnector 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: bigint.unsigned.handling.mode = precise 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.user = dbzuser 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.server.id = 132456 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: offset.storage = com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.server.name = mysql_binlog_source 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: include.schema.changes = false 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.port = 3306 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: table.whitelist = test.test2 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: offset.flush.interval.ms = 9223372036854775807 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: tombstones.on.delete = false 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.hostname = 192.168.4.231 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.password = ******** 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: name = engine 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.history.skip.unparseable.ddl = true 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.whitelist = test 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.history.instance.name = e5eb1248-50bc-455c-b866-66d1b56b7d78 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: snapshot.mode = initial 22/11/30 11:34:52 INFO io.debezium.connector.common.BaseSourceTask: database.history = com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory 22/11/30 11:34:52 DEBUG io.debezium.jdbc.JdbcConnection: Connected to jdbc:mysql://192.168.4.231:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useSSL=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with {responseBuffering=adaptive, server.name=mysql_binlog_source, fetchSize=10000, whitelist=test, useLegacyDatetimeCode=false, password=***, server.id=132456, user=dbzuser} 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_format=ROW 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_row_image=FULL 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlConnectorTask: No previous offset found 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: Reading MySQL system variables 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: auto_increment_increment = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: auto_increment_offset = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: autocommit = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: automatic_sp_privileges = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: avoid_temporal_upgrade = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: back_log = 250 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: basedir = /usr/local/mysql/ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: big_tables = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: bind_address = * 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_cache_size = 32768 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_checksum = CRC32 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_direct_non_transactional_updates = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_error_action = IGNORE_ERROR 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_format = ROW 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_gtid_simple_recovery = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_max_flush_queue_time = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_order_commits = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_row_image = FULL 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_rows_query_log_events = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlog_stmt_cache_size = 32768 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: binlogging_impossible_mode = IGNORE_ERROR 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: block_encryption_mode = aes-128-ecb 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: bulk_insert_buffer_size = 8388608 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_client = utf8mb4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_connection = utf8mb4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_database = utf8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_filesystem = binary 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_results = utf8mb4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_server = utf8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_set_system = utf8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: character_sets_dir = /usr/local/mysql/share/charsets/ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: collation_connection = utf8mb4_general_ci 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: collation_database = utf8_general_ci 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: collation_server = utf8_general_ci 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: completion_type = NO_CHAIN 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: concurrent_insert = AUTO 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: connect_timeout = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: core_file = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: datadir = /home/mysql/data/ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: date_format = %Y-%m-%d 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: datetime_format = %Y-%m-%d %H:%i:%s 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: default_storage_engine = InnoDB 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: default_tmp_storage_engine = InnoDB 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: default_week_format = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: delay_key_write = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: delayed_insert_limit = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: delayed_insert_timeout = 300 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: delayed_queue_size = 1000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: disconnect_on_expired_password = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: div_precision_increment = 4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: end_markers_in_json = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: enforce_gtid_consistency = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: eq_range_index_dive_limit = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: error_count = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: event_scheduler = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: expire_logs_days = 2 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: explicit_defaults_for_timestamp = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: external_user = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: flush = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: flush_time = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: foreign_key_checks = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ft_boolean_syntax = + -><()~*:""&| 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ft_max_word_len = 84 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ft_min_word_len = 4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ft_query_expansion_limit = 20 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ft_stopword_file = (built-in) 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: general_log = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: general_log_file = /home/mysql/data/localhost.log 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: group_concat_max_len = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: gtid_executed = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: gtid_mode = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: gtid_next = AUTOMATIC 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: gtid_owned = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: gtid_purged = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_compress = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_crypt = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_dynamic_loading = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_geometry = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_openssl = DISABLED 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_profiling = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_query_cache = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_rtree_keys = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_ssl = DISABLED 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: have_symlink = DISABLED 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: host_cache_size = 653 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: hostname = localhost.localdomain 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: identity = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ignore_builtin_innodb = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ignore_db_dirs = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: init_connect = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: init_file = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: init_slave = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_adaptive_flushing = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_adaptive_flushing_lwm = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_adaptive_hash_index = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_adaptive_max_sleep_delay = 150000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_additional_mem_pool_size = 8388608 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_api_bk_commit_interval = 5 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_api_disable_rowlock = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_api_enable_binlog = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_api_enable_mdl = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_api_trx_level = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_autoextend_increment = 64 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_autoinc_lock_mode = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_dump_at_shutdown = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_dump_now = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_filename = ib_buffer_pool 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_instances = 32 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_load_abort = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_load_at_startup = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_load_now = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_buffer_pool_size = 34359738368 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_change_buffer_max_size = 25 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_change_buffering = none 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_checksum_algorithm = innodb 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_checksums = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_cmp_per_index_enabled = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_commit_concurrency = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_compression_failure_threshold_pct = 5 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_compression_level = 6 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_compression_pad_pct_max = 50 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_concurrency_tickets = 5000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_data_file_path = ibdata1:12M:autoextend 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_data_home_dir = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_disable_sort_file_cache = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_doublewrite = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_fast_shutdown = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_file_format = Antelope 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_file_format_check = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_file_format_max = Antelope 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_file_per_table = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_flush_log_at_timeout = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_flush_log_at_trx_commit = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_flush_method = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_flush_neighbors = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_flushing_avg_loops = 30 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_force_load_corrupted = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_force_recovery = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_aux_table = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_cache_size = 8000000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_enable_diag_print = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_enable_stopword = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_max_token_size = 84 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_min_token_size = 3 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_num_word_optimize = 2000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_result_cache_limit = 2000000000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_server_stopword_table = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_sort_pll_degree = 2 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_total_cache_size = 640000000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_ft_user_stopword_table = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_io_capacity = 200 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_io_capacity_max = 2000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_large_prefix = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_lock_wait_timeout = 50 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_locks_unsafe_for_binlog = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_log_buffer_size = 134217728 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_log_compressed_pages = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_log_file_size = 50331648 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_log_files_in_group = 2 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_log_group_home_dir = ./ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_lru_scan_depth = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_max_dirty_pages_pct = 75 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_max_dirty_pages_pct_lwm = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_max_purge_lag = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_max_purge_lag_delay = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_mirrored_log_groups = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_monitor_disable = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_monitor_enable = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_monitor_reset = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_monitor_reset_all = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_numa_interleave = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_old_blocks_pct = 37 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_old_blocks_time = 1000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_online_alter_log_max_size = 134217728 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_open_files = 2000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_optimize_fulltext_only = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_page_size = 16384 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_print_all_deadlocks = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_purge_batch_size = 300 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_purge_threads = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_random_read_ahead = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_read_ahead_threshold = 56 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_read_io_threads = 4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_read_only = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_replication_delay = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_rollback_on_timeout = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_rollback_segments = 128 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_sort_buffer_size = 1048576 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_spin_wait_delay = 6 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_auto_recalc = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_include_delete_marked = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_method = nulls_equal 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_on_metadata = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_persistent = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_persistent_sample_pages = 20 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_sample_pages = 8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_stats_transient_sample_pages = 8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_status_output = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_status_output_locks = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_strict_mode = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_support_xa = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_sync_array_size = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_sync_spin_loops = 30 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_table_locks = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_thread_concurrency = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_thread_sleep_delay = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_tmpdir = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_undo_directory = . 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_undo_logs = 128 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_undo_tablespaces = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_use_native_aio = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_use_sys_malloc = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_version = 5.6.51 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: innodb_write_io_threads = 4 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: insert_id = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: interactive_timeout = 28800 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: join_buffer_size = 262144 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: keep_files_on_create = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: key_buffer_size = 8388608 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: key_cache_age_threshold = 300 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: key_cache_block_size = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: key_cache_division_limit = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: large_files_support = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: large_page_size = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: large_pages = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: last_insert_id = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lc_messages = en_US 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lc_messages_dir = /usr/local/mysql/share/ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lc_time_names = en_US 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: license = GPL 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: local_infile = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lock_wait_timeout = 31536000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: locked_in_memory = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_bin = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_bin_basename = /home/mysql/data/mysql-bin 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_bin_index = /home/mysql/data/mysql-bin.index 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_bin_trust_function_creators = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_bin_use_v1_row_events = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_error = /home/mysql/data/mysql-error.log 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_output = FILE 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_queries_not_using_indexes = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_slave_updates = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_slow_admin_statements = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_slow_slave_statements = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_throttle_queries_not_using_indexes = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: log_warnings = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: long_query_time = 10.000000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: low_priority_updates = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lower_case_file_system = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: lower_case_table_names = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: master_info_repository = FILE 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: master_verify_checksum = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_allowed_packet = 4194304 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_binlog_cache_size = 18446744073709547520 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_binlog_size = 1073741824 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_binlog_stmt_cache_size = 18446744073709547520 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_connect_errors = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_connections = 1000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_delayed_threads = 20 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_digest_length = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_error_count = 64 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_heap_table_size = 16777216 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_insert_delayed_threads = 20 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_join_size = 18446744073709551615 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_length_for_sort_data = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_prepared_stmt_count = 16382 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_relay_log_size = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_seeks_for_key = 18446744073709551615 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_sort_length = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_sp_recursion_depth = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_tmp_tables = 32 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_user_connections = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: max_write_lock_count = 18446744073709551615 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: metadata_locks_cache_size = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: metadata_locks_hash_instances = 8 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: min_examined_row_limit = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: multi_range_count = 256 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_data_pointer_size = 6 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_max_sort_file_size = 9223372036853727232 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_mmap_size = 18446744073709551615 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_recover_options = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_repair_threads = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_sort_buffer_size = 8388608 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_stats_method = nulls_unequal 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: myisam_use_mmap = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: net_buffer_length = 16384 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: net_read_timeout = 30 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: net_retry_count = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: net_write_timeout = 60 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: new = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: old = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: old_alter_table = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: old_passwords = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: open_files_limit = 5010 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_prune_level = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_search_depth = 62 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_switch = index_merge=on,index_merge_union=on,index_merge_sort_union=on,index_merge_intersection=on,engine_condition_pushdown=on,index_condition_pushdown=on,mrr=on,mrr_cost_based=on,block_nested_loop=on,batched_key_access=off,materialization=on,semijoin=on,loosescan=on,firstmatch=on,subquery_materialization_cost_based=on,use_index_extensions=on 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_trace = enabled=off,one_line=off 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_trace_features = greedy_search=on,range_optimizer=on,dynamic_range=on,repeated_subselect=on 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_trace_limit = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_trace_max_mem_size = 16384 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: optimizer_trace_offset = -1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_accounts_size = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_digests_size = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_stages_history_long_size = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_stages_history_size = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_statements_history_long_size = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_statements_history_size = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_waits_history_long_size = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_events_waits_history_size = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_hosts_size = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_cond_classes = 80 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_cond_instances = 6900 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_digest_length = 1024 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_file_classes = 50 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_file_handles = 32768 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_file_instances = 7708 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_mutex_classes = 200 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_mutex_instances = 21000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_rwlock_classes = 40 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_rwlock_instances = 10800 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_socket_classes = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_socket_instances = 2020 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_stage_classes = 150 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_statement_classes = 168 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_table_handles = 4000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_table_instances = 12500 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_thread_classes = 50 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_max_thread_instances = 2100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_session_connect_attrs_size = 512 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_setup_actors_size = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_setup_objects_size = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: performance_schema_users_size = 100 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: pid_file = /home/mysql/data/mysql.pid 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: plugin_dir = /usr/local/mysql/lib/plugin/ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: port = 3306 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: preload_buffer_size = 32768 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: profiling = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: profiling_history_size = 15 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: protocol_version = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: proxy_user = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: pseudo_slave_mode = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: pseudo_thread_id = 44533 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_alloc_block_size = 8192 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_cache_limit = 1048576 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_cache_min_res_unit = 4096 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_cache_size = 1048576 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_cache_type = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_cache_wlock_invalidate = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: query_prealloc_size = 8192 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: rand_seed1 = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: rand_seed2 = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: range_alloc_block_size = 4096 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: read_buffer_size = 131072 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: read_only = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: read_rnd_buffer_size = 262144 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_basename = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_index = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_info_file = relay-log.info 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_info_repository = FILE 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_purge = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_recovery = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: relay_log_space_limit = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: report_host = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: report_password = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: report_port = 3306 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: report_user = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: rpl_stop_slave_timeout = 31536000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: secure_auth = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: secure_file_priv = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: server_id = 223344 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: server_id_bits = 32 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: server_uuid = b7a47a6c-6cbc-11ed-bd3e-5254006c59b1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sha256_password_private_key_path = private_key.pem 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sha256_password_public_key_path = public_key.pem 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: show_old_temporals = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: simplified_binlog_gtid_recovery = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: skip_external_locking = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: skip_name_resolve = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: skip_networking = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: skip_show_database = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_allow_batching = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_checkpoint_group = 512 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_checkpoint_period = 300 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_compressed_protocol = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_exec_mode = STRICT 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_load_tmpdir = /tmp 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_max_allowed_packet = 1073741824 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_net_timeout = 3600 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_parallel_workers = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_pending_jobs_size_max = 16777216 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_rows_search_algorithms = TABLE_SCAN,INDEX_SCAN 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_skip_errors = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_sql_verify_checksum = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_transaction_retries = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slave_type_conversions = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slow_launch_time = 2 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slow_query_log = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: slow_query_log_file = /home/mysql/data/localhost-slow.log 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: socket = /home/mysql/data/mysql.sock 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sort_buffer_size = 262144 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_auto_is_null = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_big_selects = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_buffer_result = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_log_bin = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_log_off = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_mode = STRICT_TRANS_TABLES,NO_ENGINE_SUBSTITUTION 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_notes = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_quote_show_create = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_safe_updates = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_select_limit = 18446744073709551615 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_slave_skip_counter = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sql_warnings = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_ca = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_capath = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_cert = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_cipher = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_crl = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_crlpath = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: ssl_key = 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: storage_engine = InnoDB 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: stored_program_cache = 256 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sync_binlog = 0 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sync_frm = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sync_master_info = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sync_relay_log = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: sync_relay_log_info = 10000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: system_time_zone = CST 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: table_definition_cache = 1400 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: table_open_cache = 2000 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: table_open_cache_instances = 1 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: thread_cache_size = 18 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: thread_concurrency = 10 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: thread_handling = one-thread-per-connection 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: thread_stack = 262144 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: time_format = %H:%i:%s 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: time_zone = SYSTEM 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: timed_mutexes = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: timestamp = 1669808092.713645 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: tmp_table_size = 16777216 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: tmpdir = /tmp 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: transaction_alloc_block_size = 8192 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: transaction_allow_batching = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: transaction_prealloc_size = 4096 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: tx_isolation = REPEATABLE-READ 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: tx_read_only = OFF 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: unique_checks = ON 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: updatable_views_with_limit = YES 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: version = 5.6.51-log 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: version_comment = MySQL Community Server (GPL) 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: version_compile_machine = x86_64 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: version_compile_os = linux-glibc2.12 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: wait_timeout = 28800 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: warning_count = 0 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlConnectorTask: Connector started for the first time, database history recovery will not be executed 22/11/30 11:34:52 DEBUG io.debezium.pipeline.signal.Signal: Registering signal 'log' using class 'io.debezium.pipeline.signal.Log' 22/11/30 11:34:52 DEBUG io.debezium.pipeline.signal.Signal: Registering signal 'schema-changes' using class 'io.debezium.pipeline.signal.SchemaChanges' 22/11/30 11:34:52 INFO io.debezium.util.Threads: Requested thread factory for connector MySqlConnector, id = mysql_binlog_source named = change-event-source-coordinator 22/11/30 11:34:52 INFO io.debezium.util.Threads: Creating thread debezium-mysqlconnector-mysql_binlog_source-change-event-source-coordinator 22/11/30 11:34:52 DEBUG io.debezium.embedded.EmbeddedEngine: Embedded engine is polling task for records on thread Thread[debezium-engine,5,Flink Task Threads] 22/11/30 11:34:52 DEBUG io.debezium.connector.base.ChangeEventQueue: polling records... 22/11/30 11:34:52 DEBUG io.debezium.connector.base.ChangeEventQueue: no records available yet, sleeping a bit... 22/11/30 11:34:52 INFO io.debezium.pipeline.ChangeEventSourceCoordinator: Metrics registered 22/11/30 11:34:52 INFO io.debezium.pipeline.ChangeEventSourceCoordinator: Context created 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: No previous offset has been found 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: According to the connector configuration both schema and data will be snapshotted 22/11/30 11:34:52 INFO io.debezium.relational.RelationalSnapshotChangeEventSource: Snapshot step 1 - Preparing 22/11/30 11:34:52 INFO io.debezium.relational.RelationalSnapshotChangeEventSource: Snapshot step 2 - Determining captured tables 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: Read list of available databases 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: list of available databases is: [information_schema, CIS_BILL, CIS_BUSINESS, CIS_CUSTOMER, CIS_JOB, CIS_ORDER, M2Y_SNAPSHOT_WITHOUT_PK, TEST_CIS_BILL, TEST_CIS_BUSINESS, TEST_CIS_CUSTOMER, TEST_CIS_JOB, TEST_CIS_ORDER, TEST_CIS_REPORT, TPCC_100, TPCC_200, YAS_DATA_SYNC, cis_bill, cis_business, cis_customer, cis_job, cis_order, cis_report, cis_system, cis_view, mysql, performance_schema, test] 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: Read list of available tables in each database 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: snapshot continuing with database(s): [test] 22/11/30 11:34:52 INFO io.debezium.relational.RelationalSnapshotChangeEventSource: Snapshot step 3 - Locking captured tables [test.test2] 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: Flush and obtain global read lock to prevent writes to database 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: Unable to flush and acquire global read lock, will use table read locks after reading table names 22/11/30 11:34:52 INFO io.debezium.relational.RelationalSnapshotChangeEventSource: Snapshot step 4 - Determining snapshot offset 22/11/30 11:34:52 INFO io.debezium.relational.RelationalSnapshotChangeEventSource: Snapshot step 5 - Reading structure of captured tables 22/11/30 11:34:52 DEBUG io.debezium.connector.mysql.MySqlConnection: GRANT SELECT, SHOW DATABASES, LOCK TABLES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'dbzuser'@'%' IDENTIFIED BY PASSWORD 22/11/30 11:34:52 INFO io.debezium.connector.mysql.MySqlSnapshotChangeEventSource: Flush and obtain read lock for [test.test2] tables (preventing writes) 22/11/30 11:34:52 INFO io.debezium.pipeline.source.AbstractSnapshotChangeEventSource: Snapshot - Final stage 22/11/30 11:34:52 ERROR io.debezium.pipeline.ErrorHandler: Producer failure io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG io.debezium.connector.base.ChangeEventQueue: checking for more records... 22/11/30 11:34:53 DEBUG io.debezium.embedded.EmbeddedEngine: Stopping the task and engine 22/11/30 11:34:53 INFO io.debezium.connector.common.BaseSourceTask: Stopping down connector 22/11/30 11:34:53 INFO io.debezium.jdbc.JdbcConnection: Connection gracefully closed 22/11/30 11:34:53 ERROR com.ververica.cdc.debezium.internal.Handover: Reporting error: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask: Cleanup StreamTask (operators closed: false, cancelled: false) 22/11/30 11:34:53 INFO io.debezium.embedded.EmbeddedEngine: Stopping the embedded engine 22/11/30 11:34:53 INFO io.debezium.embedded.EmbeddedEngine: Stopping the embedded engine 22/11/30 11:34:53 WARN org.apache.flink.runtime.taskmanager.Task: Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) switched from RUNNING to FAILED with failure cause: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskmanager.Task: Freeing task resources for Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55). 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.taskmanager.Task: Release task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 network resources (state: FAILED). 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.taskmanager.Task: Ensuring all FileSystem streams are closed for task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 (ab7ff693a2a29d55c1412ca2658b6b55) [FAILED] 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Un-registering task and sending final execution state FAILED to JobManager for task Source: MySQL Source -> Sink: Print to Std. Out (1/1)#0 ab7ff693a2a29d55c1412ca2658b6b55. 22/11/30 11:34:53 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Source: MySQL Source -> Sink: Print to Std. Out (1/1) (ab7ff693a2a29d55c1412ca2658b6b55) switched from RUNNING to FAILED on a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1). com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.scheduler.SharedSlot: Remove logical slot (SlotRequestId{7d92301d449bc31887249c8b1ecdec7f}) for execution vertex (id cbc357ccb763df2852fee8c4fc7d55f2_0) from the physical slot (SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}) 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.scheduler.SharedSlot: Release shared slot externally (SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}) 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Release slot with slot request id SlotRequestId{251c191ba454e6735e171bc6ad39e8a7} 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Free reserved slot 61fe8e4949dc7be06004134f350bc424. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.scheduler.SharedSlot: Release shared slot (SlotRequestId{251c191ba454e6735e171bc6ad39e8a7}) 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge: Could not match slot AllocatedSlot 61fe8e4949dc7be06004134f350bc424 @ a37e9916-a8e6-45b6-a4ea-f673aece4c03 @ transact.netsarang.com (dataPort=-1) - 0 to any pending request. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Declare new resource requirements for job 8659e3019b4214efb7d2a1a0b7be240c. required resources: [] acquired resources: ResourceCounter{resources={ResourceProfile{UNKNOWN}=1}} 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Clearing resource requirements of job 8659e3019b4214efb7d2a1a0b7be240c 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.JobScopedResourceTracker: Detected excess resources for job 8659e3019b4214efb7d2a1a0b7be240c: [ExcessResource{numExcessResources=1, requirementProfile=ResourceProfile{UNKNOWN}, resourceProfile=ResourceProfile{taskHeapMemory=1024.000gb (1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes), managedMemory=128.000mb (134217728 bytes), networkMemory=64.000mb (67108864 bytes)}}] 22/11/30 11:34:53 INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy: Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0. 22/11/30 11:34:53 INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy: 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.scheduler.SlotSharingExecutionSlotAllocator: There is no SharedSlot for ExecutionSlotSharingGroup of ExecutionVertexID cbc357ccb763df2852fee8c4fc7d55f2_0 22/11/30 11:34:53 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Job Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c) switched from state RUNNING to FAILING. org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph: Job Print MySQL Snapshot + Binlog (8659e3019b4214efb7d2a1a0b7be240c) switched from state FAILING to FAILED. org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph: ExecutionGraph 8659e3019b4214efb7d2a1a0b7be240c reached terminal state FAILED. 22/11/30 11:34:53 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator: Stopping checkpoint coordinator for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Archive global failure. org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess: Job 8659e3019b4214efb7d2a1a0b7be240c under leader id 4a8ea290-eccf-46a2-935d-7d49004f562e reached a globally terminal state FAILED. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Completing the result for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Job 8659e3019b4214efb7d2a1a0b7be240c reached terminal state FAILED. org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 INFO org.apache.flink.runtime.minicluster.MiniCluster: Shutting down Flink Mini Cluster 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Shutting down rest endpoint. 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Stopping TaskExecutor akka://flink/user/rpc/taskmanager_0. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Close ResourceManager connection ce408fa011594663aa5da63cfb86a4c5. org.apache.flink.util.FlinkException: The TaskExecutor is shutting down. at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:444) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:580) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:579) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:191) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Terminating the leadership runner for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess: Terminating the JobMasterService process for job 8659e3019b4214efb7d2a1a0b7be240c under leader id 4a8ea290-eccf-46a2-935d-7d49004f562e. 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Closing TaskExecutor connection a37e9916-a8e6-45b6-a4ea-f673aece4c03 because: The TaskExecutor is shutting down. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Unregistering task executor 8f50687ee814e67b0a110073657f6a12 from the slot manager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DefaultResourceTracker: Stopping tracking of resources for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.network.partition.ResourceManagerPartitionTrackerImpl: Processing shutdown of task executor a37e9916-a8e6-45b6-a4ea-f673aece4c03. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor: Close JobManager connection for job 8659e3019b4214efb7d2a1a0b7be240c. org.apache.flink.util.FlinkException: The TaskExecutor is shutting down. at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:444) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:580) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:579) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:191) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 INFO org.apache.flink.runtime.jobmaster.JobMaster: Stopping the JobMaster for job 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c). 22/11/30 11:34:53 INFO org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager: Shutting down TaskExecutorStateChangelogStoragesManager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.scheduler.SlotSharingExecutionSlotAllocator: There is no SharedSlot for ExecutionSlotSharingGroup of ExecutionVertexID cbc357ccb763df2852fee8c4fc7d55f2_0 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl: Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{taskHeapMemory=1024.000gb (1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes), managedMemory=128.000mb (134217728 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationId: 61fe8e4949dc7be06004134f350bc424, jobId: 8659e3019b4214efb7d2a1a0b7be240c). org.apache.flink.util.FlinkException: Closing task slot table at org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl.closeAsync(TaskSlotTableImpl.java:173) at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:463) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:580) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:579) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:191) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Disconnect TaskExecutor a37e9916-a8e6-45b6-a4ea-f673aece4c03 because: The TaskExecutor is shutting down. 22/11/30 11:34:53 INFO org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Releasing slot [61fe8e4949dc7be06004134f350bc424]. org.apache.flink.util.FlinkException: The TaskExecutor is shutting down. at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:444) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:580) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:579) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:191) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore: Shutting down 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Stop job leader service. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMaster: Close ResourceManager connection ce408fa011594663aa5da63cfb86a4c5. org.apache.flink.util.FlinkException: Stopping JobMaster for job 'Print MySQL Snapshot + Binlog' (8659e3019b4214efb7d2a1a0b7be240c). at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:409) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.lambda$terminate$0(AkkaRpcActor.java:580) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:579) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:191) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager: Shutting down TaskExecutorLocalStateStoresManager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.DefaultJobLeaderIdService: Remove job 8659e3019b4214efb7d2a1a0b7be240c from job leader id monitoring. 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Disconnect job manager 935d7d49004f562e4a8ea290eccf46a2@akka://flink/user/rpc/jobmanager_3 for job 8659e3019b4214efb7d2a1a0b7be240c from the resource manager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DefaultResourceTracker: Initiating tracking of resources for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.DefaultResourceTracker: Stopping tracking of resources for job 8659e3019b4214efb7d2a1a0b7be240c. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor: The RpcEndpoint jobmanager_3 terminated successfully. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.disk.iomanager.IOManager: Shutting down I/O manager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.DeadLettersActor: Could not deliver message LocalFencedMessage(935d7d49004f562e4a8ea290eccf46a2, LocalRpcInvocation(JobMasterGateway.disconnectResourceManager(ResourceManagerId, Exception))) with no sender to recipient Actor[akka://flink/user/rpc/jobmanager_3#-1591103534]. This indicates that the actor terminated unexpectedly. Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47) at akka.dispatch.OnComplete.internal(Future.scala:300) at akka.dispatch.OnComplete.internal(Future.scala:297) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23) at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532) at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) ... 5 more Caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:82) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110) ... 5 more Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1373) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.tableLock(MySqlSnapshotChangeEventSource.java:540) at io.debezium.connector.mysql.MySqlSnapshotChangeEventSource.readTableStructure(MySqlSnapshotChangeEventSource.java:310) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71) ... 6 more 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: AkkaRpcActor akka://flink/user/rpc/jobmanager_3 has terminated. 22/11/30 11:34:53 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl: FileChannelManager removed spill file directory C:\Users\maohj\AppData\Local\Temp\flink-io-fcc414b0-13a4-4f57-a193-766812fa91a7 22/11/30 11:34:53 INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment: Shutting down the network environment and its components. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment: Shutting down network connection manager 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment: Shutting down intermediate result partition manager 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.network.partition.ResultPartitionManager: Releasing 0 partitions because of shutdown. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.io.network.partition.ResultPartitionManager: Successful shutdown. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Removing cache directory C:\Users\maohj\AppData\Local\Temp\flink-web-ui 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner: Leadership runner for job 8659e3019b4214efb7d2a1a0b7be240c has been terminated. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess: JobMasterService process for job 8659e3019b4214efb7d2a1a0b7be240c under leader id 4a8ea290-eccf-46a2-935d-7d49004f562e has been terminated. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint: Shut down complete. 22/11/30 11:34:53 INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl: FileChannelManager removed spill file directory C:\Users\maohj\AppData\Local\Temp\flink-netty-shuffle-423fcca3-7342-435e-9aff-a150ef985801 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager: Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed.. 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.KvStateService: Shutting down the kvState service and its components. 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService: Stop job leader service. 22/11/30 11:34:53 INFO org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent: Closing components. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess: Stopping SessionDispatcherLeaderProcess. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Stopping dispatcher akka://flink/user/rpc/dispatcher_1. 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl: Stopping resource manager service. 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Closing the slot manager. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Stopping all currently running jobs of dispatcher akka://flink/user/rpc/dispatcher_1. 22/11/30 11:34:53 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager: Suspending the slot manager. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor: The RpcEndpoint resourcemanager_2 terminated successfully. 22/11/30 11:34:53 INFO org.apache.flink.runtime.filecache.FileCache: removed file cache directory C:\Users\maohj\AppData\Local\Temp\flink-dist-cache-4fadb272-3cbd-4c8e-a2be-7fc0c0fdd522 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: AkkaRpcActor akka://flink/user/rpc/resourcemanager_2 has terminated. 22/11/30 11:34:53 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher: Stopped dispatcher akka://flink/user/rpc/dispatcher_1. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor: The RpcEndpoint dispatcher_1 terminated successfully. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: AkkaRpcActor akka://flink/user/rpc/dispatcher_1 has terminated. 22/11/30 11:34:53 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcActor: The RpcEndpoint taskmanager_0 terminated successfully. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: AkkaRpcActor akka://flink/user/rpc/taskmanager_0 has terminated. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool: Releasing slot [61fe8e4949dc7be06004134f350bc424] of registered TaskExecutor a37e9916-a8e6-45b6-a4ea-f673aece4c03 failed. Discarding slot. org.apache.flink.runtime.rpc.exceptions.RecipientUnreachableException: Could not send message [LocalRpcInvocation(TaskExecutorGateway.freeSlot(AllocationID, Throwable, Time))] from sender [Actor[akka://flink/temp/taskmanager_0$x]] to recipient [Actor[akka://flink/user/rpc/taskmanager_0#-971783775]], because the recipient is unreachable. This can either mean that the recipient has been terminated or that the remote RpcService is currently not reachable. at org.apache.flink.runtime.rpc.akka.DeadLettersActor.handleDeadLetter(DeadLettersActor.java:61) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) 22/11/30 11:34:53 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Stopping Akka RPC service. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.DeadLettersActor: Could not deliver message LocalRpcInvocation(TaskExecutorGateway.disconnectJobManager(JobID, Exception)) with no sender to recipient Actor[akka://flink/user/rpc/taskmanager_0#-971783775]. This indicates that the actor terminated unexpectedly. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcActor: The RpcEndpoint MetricQueryService terminated successfully. 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: AkkaRpcActor akka://flink-metrics/user/rpc/MetricQueryService has terminated. 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-service-unbind] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-unbind] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-requests-done] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-stop] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-cluster-shutdown] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-sharding-shutdown-region] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-leave] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-exiting] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-exiting-done] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-shutdown] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-actor-system-terminate] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [actor-system-terminate] with [1] tasks. 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing task [terminate-system] in CoordinatedShutdown phase [actor-system-terminate] 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Stopping supervisor actor. 22/11/30 11:34:53 DEBUG akka.event.EventStream: shutting down: StandardOutLogger 22/11/30 11:34:53 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Stopping Akka RPC service. 22/11/30 11:34:53 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Stopped Akka RPC service. 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-service-unbind] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-unbind] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-requests-done] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [service-stop] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-cluster-shutdown] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-sharding-shutdown-region] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-leave] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-exiting] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-exiting-done] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [cluster-shutdown] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [before-actor-system-terminate] with [0] tasks 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing phase [actor-system-terminate] with [1] tasks. 22/11/30 11:34:53 DEBUG akka.actor.CoordinatedShutdown: Performing task [terminate-system] in CoordinatedShutdown phase [actor-system-terminate] 22/11/30 11:34:53 DEBUG org.apache.flink.runtime.rpc.akka.SupervisorActor: Stopping supervisor actor. 22/11/30 11:34:53 DEBUG akka.event.EventStream: shutting down: StandardOutLogger 22/11/30 11:34:53 INFO org.apache.flink.runtime.blob.PermanentBlobCache: Shutting down BLOB cache 22/11/30 11:34:53 INFO org.apache.flink.runtime.blob.TransientBlobCache: Shutting down BLOB cache 22/11/30 11:34:53 INFO org.apache.flink.runtime.blob.BlobServer: Stopped BLOB server at 0.0.0.0:52382 22/11/30 11:34:53 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService: Stopped Akka RPC service. Process finished with exit code 1