2019-10-24 10:59:47,496 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- 2019-10-24 10:59:47,498 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting MesosSessionClusterEntrypoint (Version: 1.9.1, Rev:4d56de8, Date:30.09.2019 @ 11:32:19 CST) 2019-10-24 10:59:47,499 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: flink 2019-10-24 10:59:48,455 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2019-10-24 10:59:48,604 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current Hadoop/Kerberos user: flink 2019-10-24 10:59:48,604 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.222-b10 2019-10-24 10:59:48,604 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Maximum heap size: 2169 MiBytes 2019-10-24 10:59:48,604 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JAVA_HOME: (not set) 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop version: 2.8.3 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM Options: 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlog.file=/usr/local/lib/flink-1.9.1/log/flink--mesos-appmaster-deb-node1.log 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlog4j.configuration=file:/usr/local/lib/flink-1.9.1/conf/log4j.properties 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlogback.configurationFile=file:/usr/local/lib/flink-1.9.1/conf/logback.xml 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Program Arguments: (none) 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Classpath: /usr/local/lib/flink-1.9.1/lib/flink-avro-1.9.1.jar:/usr/local/lib/flink-1.9.1/lib/flink-csv-1.9.1.jar:/usr/local/lib/flink-1.9.1/lib/flink-json-1.9.1.jar:/usr/local/lib/flink-1.9.1/lib/flink-shaded-hadoop-2-uber-2.8.3-7.0.jar:/usr/local/lib/flink-1.9.1/lib/flink-table-blink_2.11-1.9.1.jar:/usr/local/lib/flink-1.9.1/lib/flink-table_2.11-1.9.1.jar:/usr/local/lib/flink-1.9.1/lib/log4j-1.2.17.jar:/usr/local/lib/flink-1.9.1/lib/slf4j-log4j12-1.7.15.jar:/usr/local/lib/flink-1.9.1/lib/flink-dist_2.11-1.9.1.jar::: 2019-10-24 10:59:48,609 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- 2019-10-24 10:59:48,611 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Registered UNIX signal handlers for [TERM, HUP, INT] 2019-10-24 10:59:48,623 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.address, 192.168.10.11 2019-10-24 10:59:48,624 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123 2019-10-24 10:59:48,624 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.heap.size, 1024m 2019-10-24 10:59:48,624 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.heap.size, 1024m 2019-10-24 10:59:48,624 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2019-10-24 10:59:48,625 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 1 2019-10-24 10:59:48,625 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: state.checkpoints.dir, file:///var/lib/flink/data/ckeckpoints 2019-10-24 10:59:48,625 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: state.savepoints.dir, file:///var/lib/flink/data/savepoints 2019-10-24 10:59:48,625 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.execution.failover-strategy, region 2019-10-24 10:59:48,626 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: rest.port, 8081 2019-10-24 10:59:48,626 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: rest.bind-address, 0.0.0.0 2019-10-24 10:59:48,626 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.archive.fs.dir, file:///var/lib/flink/completed_jobs/ 2019-10-24 10:59:48,626 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: historyserver.archive.fs.dir, file:///var/lib/flink/completed_jobs/ 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.container.type, docker 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.container.image.name, eskimo:flink-worker 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.bootstrap-cmd, export FLINK_HOME=/usr/local/lib/flink/ 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.container.volumes, /var/log/flink:/var/log/flink:RW,/var/lib/flink:/var/lib/flink:RW,/etc:/host_etc:RO 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.cpus, 2 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.mem, 1024 2019-10-24 10:59:48,627 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.master, zk://192.168.10.11:2181/mesos 2019-10-24 10:59:48,674 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting MesosSessionClusterEntrypoint. 2019-10-24 10:59:48,675 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install default filesystem. 2019-10-24 10:59:48,714 DEBUG org.apache.flink.core.fs.FileSystem - Loading extension file systems via services 2019-10-24 10:59:48,716 DEBUG org.apache.flink.core.fs.FileSystem - Added file system maprfs:org.apache.flink.runtime.fs.maprfs.MapRFsFactory 2019-10-24 10:59:48,730 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install security context. 2019-10-24 10:59:48,760 DEBUG org.apache.flink.runtime.util.HadoopUtils - Cannot find hdfs-default configuration-file path in Flink config. 2019-10-24 10:59:48,761 DEBUG org.apache.flink.runtime.util.HadoopUtils - Cannot find hdfs-site configuration-file path in Flink config. 2019-10-24 10:59:48,761 DEBUG org.apache.flink.runtime.util.HadoopUtils - Could not find Hadoop configuration via any of the supported methods (Flink configuration, environment variables). 2019-10-24 10:59:48,834 INFO org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set to flink (auth:SIMPLE) 2019-10-24 10:59:48,848 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Initializing cluster services. 2019-10-24 10:59:49,368 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Trying to start actor system at 192.168.10.11:6123 2019-10-24 10:59:49,601 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Using akka configuration Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"executor":"fork-join-executor","fork-join-executor":{"parallelism-factor":2,"parallelism-max":64,"parallelism-min":8},"throughput":15},"guardian-supervisor-strategy":"org.apache.flink.runtime.akka.StoppingSupervisorWithoutLoggingActorKilledExceptionStrategy","provider":"akka.remote.RemoteActorRefProvider","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","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"DEBUG","remote":{"log-remote-lifecycle-events":"off","netty":{"tcp":{"bind-hostname":"0.0.0.0","bind-port":6123,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"connection-timeout":"20 s","hostname":"192.168.10.11","maximum-frame-size":"10485760b","port":6123,"server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"tcp-nodelay":"on","transport-class":"akka.remote.transport.netty.NettyTransport"}},"retry-gate-closed-for":"50 ms","startup-timeout":"100 seconds","transport-failure-detector":{"acceptable-heartbeat-pause":"6000 s","heartbeat-interval":"1000 s","threshold":300},"watch-failure-detector":{"acceptable-heartbeat-pause":"60 s","heartbeat-interval":"10 s","threshold":12}},"serialize-messages":"off","stdout-loglevel":"OFF"}})) 2019-10-24 10:59:50,653 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2019-10-24 10:59:50,849 INFO akka.remote.Remoting - Starting remoting 2019-10-24 10:59:50,909 DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Using select timeout of 500 2019-10-24 10:59:50,910 DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Epoll-bug workaround enabled = false 2019-10-24 10:59:51,116 INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink@192.168.10.11:6123] 2019-10-24 10:59:51,277 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Actor system started at akka.tcp://flink@192.168.10.11:6123 2019-10-24 10:59:51,331 INFO org.apache.flink.configuration.Configuration - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address' 2019-10-24 10:59:51,350 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-bd9a9450-c793-4c68-8b9d-f9607e2ced8f 2019-10-24 10:59:51,364 DEBUG org.apache.flink.util.NetUtils - Trying to open socket on port 0 2019-10-24 10:59:51,365 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:40737 - max concurrent requests: 50 - max backlog: 1000 2019-10-24 10:59:51,420 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported. 2019-10-24 10:59:51,422 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Trying to start actor system at 192.168.10.11:0 2019-10-24 10:59:51,432 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Using akka configuration Config(SimpleConfigObject({"akka":{"actor":{"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":"akka.dispatch.PriorityThreadsDispatcher"},"guardian-supervisor-strategy":"org.apache.flink.runtime.akka.StoppingSupervisorWithoutLoggingActorKilledExceptionStrategy","provider":"akka.remote.RemoteActorRefProvider","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","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"DEBUG","remote":{"log-remote-lifecycle-events":"off","netty":{"tcp":{"bind-hostname":"0.0.0.0","bind-port":0,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"connection-timeout":"20 s","hostname":"192.168.10.11","maximum-frame-size":"10485760b","port":0,"server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"tcp-nodelay":"on","transport-class":"akka.remote.transport.netty.NettyTransport"}},"retry-gate-closed-for":"50 ms","startup-timeout":"100 seconds","transport-failure-detector":{"acceptable-heartbeat-pause":"6000 s","heartbeat-interval":"1000 s","threshold":300},"watch-failure-detector":{"acceptable-heartbeat-pause":"60 s","heartbeat-interval":"10 s","threshold":12}},"serialize-messages":"off","stdout-loglevel":"OFF"}})) 2019-10-24 10:59:51,508 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2019-10-24 10:59:51,519 INFO akka.remote.Remoting - Starting remoting 2019-10-24 10:59:51,684 INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink-metrics@192.168.10.11:43593] 2019-10-24 10:59:51,709 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Actor system started at akka.tcp://flink-metrics@192.168.10.11:43593 2019-10-24 10:59:51,727 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/MetricQueryService . 2019-10-24 10:59:51,753 INFO org.apache.flink.runtime.dispatcher.FileArchivedExecutionGraphStore - Initializing FileArchivedExecutionGraphStore: Storage directory /tmp/executionGraphStore-893f12b3-4df7-4362-85ee-6bd2a72140be, expiration time 3600000, maximum cache size 52428800 bytes. 2019-10-24 10:59:51,893 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2019-10-24 10:59:51,943 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as the default logging framework 2019-10-24 10:59:51,979 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - -Dio.netty.noUnsafe: false 2019-10-24 10:59:51,980 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - Java version: 8 2019-10-24 10:59:51,982 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available 2019-10-24 10:59:51,988 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available 2019-10-24 10:59:51,988 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Buffer.address: available 2019-10-24 10:59:51,991 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - direct buffer constructor: available 2019-10-24 10:59:51,992 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: available, true 2019-10-24 10:59:51,992 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9 2019-10-24 10:59:51,992 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.DirectByteBuffer.(long, int): available 2019-10-24 10:59:51,992 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - sun.misc.Unsafe: available 2019-10-24 10:59:51,993 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 2019-10-24 10:59:51,993 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model) 2019-10-24 10:59:51,994 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.maxDirectMemory: 2274361344 bytes 2019-10-24 10:59:51,994 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.uninitializedArrayAllocationThreshold: -1 2019-10-24 10:59:51,995 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.CleanerJava6 - java.nio.ByteBuffer.cleaner(): available 2019-10-24 10:59:51,996 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false 2019-10-24 10:59:52,010 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 4 2019-10-24 10:59:52,074 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false 2019-10-24 10:59:52,074 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512 2019-10-24 10:59:52,092 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - org.jctools-core.MpscChunkedArrayQueue: available 2019-10-24 10:59:52,126 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId - -Dio.netty.processId: 39 (auto-detected) 2019-10-24 10:59:52,129 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - -Djava.net.preferIPv4Stack: false 2019-10-24 10:59:52,129 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - -Djava.net.preferIPv6Addresses: false 2019-10-24 10:59:52,130 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - Loopback interface: [lo, lo, 127.0.0.1] ({}, {}) 2019-10-24 10:59:52,134 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - /proc/sys/net/core/somaxconn: 128 2019-10-24 10:59:52,135 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId - -Dio.netty.machineId: 02:42:20:ff:fe:dd:57:8a (auto-detected) 2019-10-24 10:59:52,143 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024 2019-10-24 10:59:52,143 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096 2019-10-24 10:59:52,163 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector - -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.level: simple 2019-10-24 10:59:52,163 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector - -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.targetRecords: 4 2019-10-24 10:59:52,201 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 4 2019-10-24 10:59:52,201 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 4 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192 2019-10-24 10:59:52,202 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.useCacheForAllThreads: true 2019-10-24 10:59:52,212 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: pooled 2019-10-24 10:59:52,212 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 0 2019-10-24 10:59:52,212 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.maxThreadLocalCharBufferSize: 16384 2019-10-24 10:59:52,238 INFO org.apache.flink.mesos.util.MesosArtifactServer - Mesos Artifact Server Base URL: http://192.168.10.11:37193/820e46e2-fee8-494d-9ffd-12489818ca30/, listening at 192.168.10.11:37193 2019-10-24 10:59:52,271 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - TaskManagers will be created with 1 task slots 2019-10-24 10:59:52,271 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - TaskManagers will be started with container size 1024 MB, JVM heap size 360 MB, JVM direct memory limit 664 MB, 2.0 cpus, 0 gpus, disk space 0 MB 2019-10-24 10:59:52,277 WARN org.apache.flink.runtime.clusterframework.overlays.HadoopConfOverlay - Unable to locate a Hadoop configuration; HDFS will use defaults. 2019-10-24 10:59:52,343 INFO org.apache.flink.configuration.Configuration - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address' 2019-10-24 10:59:52,343 INFO org.apache.flink.configuration.Configuration - Config uses fallback configuration key 'rest.port' instead of key 'rest.bind-port' 2019-10-24 10:59:52,344 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Upload directory /tmp/flink-web-d021a0ff-7d73-488e-b6d7-6212eb868e93/flink-web-upload does not exist. 2019-10-24 10:59:52,345 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Created directory /tmp/flink-web-d021a0ff-7d73-488e-b6d7-6212eb868e93/flink-web-upload for file uploads. 2019-10-24 10:59:52,346 DEBUG org.apache.flink.runtime.entrypoint.component.SessionDispatcherResourceManagerComponentFactory - Starting Dispatcher REST endpoint. 2019-10-24 10:59:52,346 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest endpoint. 2019-10-24 10:59:52,634 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of main cluster component log file: /usr/local/lib/flink-1.9.1/log/flink--mesos-appmaster-deb-node1.log 2019-10-24 10:59:52,635 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of main cluster component stdout file: /usr/local/lib/flink-1.9.1/log/flink--mesos-appmaster-deb-node1.out 2019-10-24 10:59:52,672 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@512d4583 under DELETE@/v1/cluster. 2019-10-24 10:59:52,673 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@512d4583 under DELETE@/cluster. 2019-10-24 10:59:52,673 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@60723d6a under GET@/v1/config. 2019-10-24 10:59:52,673 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@60723d6a under GET@/config. 2019-10-24 10:59:52,673 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarListHandler@18324f97 under GET@/v1/jars. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarListHandler@18324f97 under GET@/jars. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler@64f555e7 under POST@/v1/jars/upload. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler@64f555e7 under POST@/jars/upload. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler@71178a52 under DELETE@/v1/jars/:jarid. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler@71178a52 under DELETE@/jars/:jarid. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@ff6077 under GET@/v1/jars/:jarid/plan. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@ff6077 under GET@/jars/:jarid/plan. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@abbc908 under GET@/v1/jars/:jarid/plan. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@abbc908 under GET@/jars/:jarid/plan. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarRunHandler@44afefd5 under POST@/v1/jars/:jarid/run. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarRunHandler@44afefd5 under POST@/jars/:jarid/run. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@9a7a808 under GET@/v1/jobmanager/config. 2019-10-24 10:59:52,674 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@9a7a808 under GET@/jobmanager/config. 2019-10-24 10:59:52,675 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@72209d93 under GET@/v1/jobmanager/log. 2019-10-24 10:59:52,675 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@72209d93 under GET@/jobmanager/log. 2019-10-24 10:59:52,675 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@2687f956 under GET@/v1/jobmanager/metrics. 2019-10-24 10:59:52,675 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@2687f956 under GET@/jobmanager/metrics. 2019-10-24 10:59:52,675 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@1ded7b14 under GET@/v1/jobmanager/stdout. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@1ded7b14 under GET@/jobmanager/stdout. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@29be7749 under GET@/v1/jobs. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@29be7749 under GET@/jobs. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@5f84abe8 under POST@/v1/jobs. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@5f84abe8 under POST@/jobs. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@4650a407 under GET@/v1/jobs/metrics. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@4650a407 under GET@/jobs/metrics. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@30135202 under GET@/v1/jobs/overview. 2019-10-24 10:59:52,677 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@30135202 under GET@/jobs/overview. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@6a4d7f76 under GET@/v1/jobs/:jobid. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@6a4d7f76 under GET@/jobs/:jobid. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@10ec523c under PATCH@/v1/jobs/:jobid. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@10ec523c under PATCH@/jobs/:jobid. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@53dfacba under GET@/v1/jobs/:jobid/accumulators. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@53dfacba under GET@/jobs/:jobid/accumulators. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@79767781 under GET@/v1/jobs/:jobid/checkpoints. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@79767781 under GET@/jobs/:jobid/checkpoints. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@78411116 under GET@/v1/jobs/:jobid/checkpoints/config. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@78411116 under GET@/jobs/:jobid/checkpoints/config. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@aced190 under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid. 2019-10-24 10:59:52,678 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@aced190 under GET@/jobs/:jobid/checkpoints/details/:checkpointid. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@245a060f under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@245a060f under GET@/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@6edaa77a under GET@/v1/jobs/:jobid/config. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@6edaa77a under GET@/jobs/:jobid/config. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@1e63d216 under GET@/v1/jobs/:jobid/exceptions. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@1e63d216 under GET@/jobs/:jobid/exceptions. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@62ddd21b under GET@/v1/jobs/:jobid/execution-result. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@62ddd21b under GET@/jobs/:jobid/execution-result. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@16c3ca31 under GET@/v1/jobs/:jobid/metrics. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@16c3ca31 under GET@/jobs/:jobid/metrics. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@2d195ee4 under GET@/v1/jobs/:jobid/plan. 2019-10-24 10:59:52,679 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@2d195ee4 under GET@/jobs/:jobid/plan. 2019-10-24 10:59:52,680 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@2d6aca33 under PATCH@/v1/jobs/:jobid/rescaling. 2019-10-24 10:59:52,680 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@2d6aca33 under PATCH@/jobs/:jobid/rescaling. 2019-10-24 10:59:52,680 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@21ab988f under GET@/v1/jobs/:jobid/rescaling/:triggerid. 2019-10-24 10:59:52,680 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@21ab988f under GET@/jobs/:jobid/rescaling/:triggerid. 2019-10-24 10:59:52,684 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@29314cc9 under POST@/v1/jobs/:jobid/savepoints. 2019-10-24 10:59:52,684 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@29314cc9 under POST@/jobs/:jobid/savepoints. 2019-10-24 10:59:52,684 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@4e38d975 under GET@/v1/jobs/:jobid/savepoints/:triggerid. 2019-10-24 10:59:52,684 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@4e38d975 under GET@/jobs/:jobid/savepoints/:triggerid. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@35f8a9d3 under POST@/v1/jobs/:jobid/stop. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@35f8a9d3 under POST@/jobs/:jobid/stop. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@48ea2003 under GET@/v1/jobs/:jobid/vertices/:vertexid. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@48ea2003 under GET@/jobs/:jobid/vertices/:vertexid. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@6b1e7ad3 under GET@/v1/jobs/:jobid/vertices/:vertexid/accumulators. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@6b1e7ad3 under GET@/jobs/:jobid/vertices/:vertexid/accumulators. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@63e5e5b4 under GET@/v1/jobs/:jobid/vertices/:vertexid/backpressure. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@63e5e5b4 under GET@/jobs/:jobid/vertices/:vertexid/backpressure. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@13a37e2a under GET@/v1/jobs/:jobid/vertices/:vertexid/metrics. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@13a37e2a under GET@/jobs/:jobid/vertices/:vertexid/metrics. 2019-10-24 10:59:52,685 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@a50ae65 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/accumulators. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@a50ae65 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/accumulators. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@1280851e under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/metrics. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@1280851e under GET@/jobs/:jobid/vertices/:vertexid/subtasks/metrics. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@5e840abf under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@5e840abf under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@56de6d6b under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@56de6d6b under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@5972d253 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@5972d253 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@4fcc0416 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@4fcc0416 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@31e32ea2 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasktimes. 2019-10-24 10:59:52,686 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@31e32ea2 under GET@/jobs/:jobid/vertices/:vertexid/subtasktimes. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@1473b8c0 under GET@/v1/jobs/:jobid/vertices/:vertexid/taskmanagers. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@1473b8c0 under GET@/jobs/:jobid/vertices/:vertexid/taskmanagers. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@10ec523c under GET@/v1/jobs/:jobid/yarn-cancel. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@10ec523c under GET@/jobs/:jobid/yarn-cancel. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@5b5c0057 under GET@/v1/jobs/:jobid/yarn-stop. 2019-10-24 10:59:52,687 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@5b5c0057 under GET@/jobs/:jobid/yarn-stop. 2019-10-24 10:59:52,690 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@749f539e under GET@/v1/overview. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@749f539e under GET@/overview. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@5ca1f591 under POST@/v1/savepoint-disposal. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@5ca1f591 under POST@/savepoint-disposal. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@551de37d under GET@/v1/savepoint-disposal/:triggerid. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@551de37d under GET@/savepoint-disposal/:triggerid. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@6ef81f31 under GET@/v1/taskmanagers. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@6ef81f31 under GET@/taskmanagers. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@6075b2d3 under GET@/v1/taskmanagers/metrics. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@6075b2d3 under GET@/taskmanagers/metrics. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@33abde31 under GET@/v1/taskmanagers/:taskmanagerid. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@33abde31 under GET@/taskmanagers/:taskmanagerid. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@997d532 under GET@/v1/taskmanagers/:taskmanagerid/log. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@997d532 under GET@/taskmanagers/:taskmanagerid/log. 2019-10-24 10:59:52,691 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@273842a6 under GET@/v1/taskmanagers/:taskmanagerid/metrics. 2019-10-24 10:59:52,692 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@273842a6 under GET@/taskmanagers/:taskmanagerid/metrics. 2019-10-24 10:59:52,692 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@6a969fb8 under GET@/v1/taskmanagers/:taskmanagerid/stdout. 2019-10-24 10:59:52,692 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@6a969fb8 under GET@/taskmanagers/:taskmanagerid/stdout. 2019-10-24 10:59:52,692 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@7a18e8d under GET@/v1/:*. 2019-10-24 10:59:52,692 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@7a18e8d under GET@/:*. 2019-10-24 10:59:52,705 DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Binding rest endpoint to 0.0.0.0:8081. 2019-10-24 10:59:52,705 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at 192.168.10.11:8081 2019-10-24 10:59:52,706 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://192.168.10.11:8081 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000 2019-10-24 10:59:52,706 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://192.168.10.11:8081. 2019-10-24 10:59:52,801 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager at akka://flink/user/resourcemanager . 2019-10-24 10:59:52,845 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher . 2019-10-24 10:59:52,878 DEBUG org.apache.flink.runtime.entrypoint.component.SessionDispatcherResourceManagerComponentFactory - Starting ResourceManager. 2019-10-24 10:59:52,961 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Registering as new framework. 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - -------------------------------------------------------------------------------- 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Mesos Info: 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Master URL: zk://192.168.10.11:2181/mesos 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Framework Info: 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - ID: (none) 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Name: Flink 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Failover Timeout (secs): 604800.0 2019-10-24 10:59:52,962 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Role: * 2019-10-24 10:59:52,969 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Capabilities: (none) 2019-10-24 10:59:52,970 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Principal: (none) 2019-10-24 10:59:52,970 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Host: 192.168.10.11 2019-10-24 10:59:52,970 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Web UI: http://192.168.10.11:8081 2019-10-24 10:59:52,970 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - -------------------------------------------------------------------------------- 2019-10-24 10:59:52,969 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.11:6123/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 2019-10-24 10:59:53,035 DEBUG org.apache.flink.runtime.entrypoint.component.SessionDispatcherResourceManagerComponentFactory - Starting Dispatcher. 2019-10-24 10:59:53,043 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka.tcp://flink@192.168.10.11:6123/user/dispatcher was granted leadership with fencing token 00000000-0000-0000-0000-000000000000 2019-10-24 10:59:53,055 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.11:6123/user/dispatcher. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 2019-10-24 10:59:53,044 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs. 2019-10-24 10:59:53,069 DEBUG org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka.tcp://flink@192.168.10.11:6123/user/dispatcher accepted leadership with fencing token 00000000000000000000000000000000. Start recovered jobs. 2019-10-24 10:59:53,073 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - ResourceManager akka.tcp://flink@192.168.10.11:6123/user/resourcemanager was granted leadership with fencing token 00000000000000000000000000000000 2019-10-24 10:59:53,079 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Starting the SlotManager. 2019-10-24 10:59:53,610 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (StoppedState -> StoppedState) with data () 2019-10-24 10:59:53,629 DEBUG org.apache.flink.mesos.scheduler.ReconciliationCoordinator - State change (Suspended -> Suspended) with data ReconciliationData(Map(),0) 2019-10-24 10:59:53,641 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 10:59:53,642 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 10:59:53,854 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Mesos resource manager started. 2019-10-24 10:59:53,646 INFO org.apache.flink.mesos.scheduler.ConnectionMonitor - Connecting to Mesos... 2019-10-24 10:59:53,877 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (StoppedState -> ConnectingState) with data () 2019-10-24 10:59:53,901 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - State change (Suspended -> Suspended) with data GatherData(List(),List()) 2019-10-24 10:59:53,910 INFO org.apache.flink.mesos.scheduler.ConnectionMonitor - Connected to Mesos as framework ID 048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-0003. 2019-10-24 10:59:53,914 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - State change (Suspended -> Idle) with data GatherData(List(),List()) 2019-10-24 10:59:53,924 DEBUG org.apache.flink.mesos.scheduler.ReconciliationCoordinator - State change (Suspended -> Idle) with data ReconciliationData(Map(),0) 2019-10-24 10:59:54,110 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - Master Info: id: "048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c" ip: 185247936 port: 5050 pid: "master@192.168.10.11:5050" hostname: "192.168.10.11" version: "1.8.1" address { hostname: "192.168.10.11" ip: "192.168.10.11" port: 5050 } 9: "\b\001" 2019-10-24 10:59:54,110 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (ConnectingState -> ConnectedState) with data () 2019-10-24 11:00:03,655 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 11:00:03,655 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 11:00:13,665 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 11:00:13,665 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 11:00:23,675 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request. 2019-10-24 11:00:23,676 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Trigger heartbeat request.