2018-01-03 04:23:34,637 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -------------------------------------------------------------------------------- 2018-01-03 04:23:34,647 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting Mesos AppMaster (Version: 1.4.0, Rev:3a9d9f2, Date:06.12.2017 @ 03:08:40 PST) 2018-01-03 04:23:34,647 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - OS current user: root 2018-01-03 04:23:34,825 DEBUG org.apache.hadoop.metrics2.lib.MutableMetricsFactory - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess with annotation @org.apache.hadoop.metrics2.annotation.Metric(about=, sampleName=Ops, always=false, type=DEFAULT, valueName=Time, value=[Rate of successful kerberos logins and latency (milliseconds)]) 2018-01-03 04:23:34,839 DEBUG org.apache.hadoop.metrics2.lib.MutableMetricsFactory - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginFailure with annotation @org.apache.hadoop.metrics2.annotation.Metric(about=, sampleName=Ops, always=false, type=DEFAULT, valueName=Time, value=[Rate of failed kerberos logins and latency (milliseconds)]) 2018-01-03 04:23:34,839 DEBUG org.apache.hadoop.metrics2.lib.MutableMetricsFactory - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.getGroups with annotation @org.apache.hadoop.metrics2.annotation.Metric(about=, sampleName=Ops, always=false, type=DEFAULT, valueName=Time, value=[GetGroups]) 2018-01-03 04:23:34,841 DEBUG org.apache.hadoop.metrics2.impl.MetricsSystemImpl - UgiMetrics, User and group related metrics 2018-01-03 04:23:35,469 DEBUG org.apache.hadoop.security.Groups - Creating new Groups object 2018-01-03 04:23:35,472 DEBUG org.apache.hadoop.util.NativeCodeLoader - Trying to load the custom-built native-hadoop library... 2018-01-03 04:23:35,478 DEBUG org.apache.hadoop.util.NativeCodeLoader - Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path 2018-01-03 04:23:35,478 DEBUG org.apache.hadoop.util.NativeCodeLoader - java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib 2018-01-03 04:23:35,478 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2018-01-03 04:23:35,478 DEBUG org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback - Falling back to shell based 2018-01-03 04:23:35,479 DEBUG org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback - Group mapping impl=org.apache.hadoop.security.ShellBasedUnixGroupsMapping 2018-01-03 04:23:35,822 DEBUG org.apache.hadoop.util.Shell - Failed to detect a valid hadoop home directory java.io.IOException: HADOOP_HOME or hadoop.home.dir are not set. at org.apache.hadoop.util.Shell.checkHadoopHome(Shell.java:265) at org.apache.hadoop.util.Shell.(Shell.java:290) at org.apache.hadoop.util.StringUtils.(StringUtils.java:76) at org.apache.hadoop.security.Groups.parseStaticMapping(Groups.java:93) at org.apache.hadoop.security.Groups.(Groups.java:77) at org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:240) at org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:255) at org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:232) at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:718) at org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:703) at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:605) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.runtime.util.EnvironmentInformation.getHadoopUser(EnvironmentInformation.java:96) at org.apache.flink.runtime.util.EnvironmentInformation.logEnvironmentInfo(EnvironmentInformation.java:285) at org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner.main(MesosApplicationMasterRunner.java:131) 2018-01-03 04:23:36,349 DEBUG org.apache.hadoop.util.Shell - setsid exited with exit code 0 2018-01-03 04:23:36,349 DEBUG org.apache.hadoop.security.Groups - Group mapping impl=org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback; cacheTimeout=300000; warningDeltaMs=5000 2018-01-03 04:23:36,364 DEBUG org.apache.hadoop.security.UserGroupInformation - hadoop login 2018-01-03 04:23:36,366 DEBUG org.apache.hadoop.security.UserGroupInformation - hadoop login commit 2018-01-03 04:23:36,389 DEBUG org.apache.hadoop.security.UserGroupInformation - using local user:UnixPrincipal: root 2018-01-03 04:23:36,390 DEBUG org.apache.hadoop.security.UserGroupInformation - UGI loginUser:root (auth:SIMPLE) 2018-01-03 04:23:36,391 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Current Hadoop/Kerberos user: root 2018-01-03 04:23:36,391 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.141-b15 2018-01-03 04:23:36,391 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Maximum heap size: 27305 MiBytes 2018-01-03 04:23:36,391 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - JAVA_HOME: /usr/lib/jvm/java-8-openjdk-amd64/jre 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Hadoop version: 2.4.1 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - JVM Options: 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dlog.file=/mnt/mesos/sandbox/flink--mesos-appmaster-DNN-G08-232.log 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dlog4j.configuration=file:/flink-1.4.0/conf/log4j.properties 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dlogback.configurationFile=file:/flink-1.4.0/conf/logback.xml 2018-01-03 04:23:36,399 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Program Arguments: 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dblob.server.port=31854 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Djobmanager.heap.mb=256 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Djobmanager.rpc.port=31853 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Djobmanager.web.port=31852 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dmesos.artifact-server.port=31855 2018-01-03 04:23:36,400 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dmesos.initial-tasks=1 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dmesos.resourcemanager.tasks.cpus=1 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dmesos.resourcemanager.tasks.mem=1024 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dtaskmanager.heap.mb=512 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dtaskmanager.memory.preallocate=true 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dtaskmanager.numberOfTaskSlots=1 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dparallelism.default=1 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Djobmanager.rpc.address=DNN-G08-232 2018-01-03 04:23:36,401 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dmesos.resourcemanager.framework.role=* 2018-01-03 04:23:36,402 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -Dsecurity.kerberos.login.use-ticket-cache=true 2018-01-03 04:23:36,402 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Classpath: /flink-1.4.0/lib/flink-python_2.11-1.4.0.jar:/flink-1.4.0/lib/flink-shaded-hadoop2-uber-1.4.0.jar:/flink-1.4.0/lib/log4j-1.2.17.jar:/flink-1.4.0/lib/slf4j-log4j12-1.7.7.jar:/flink-1.4.0/lib/flink-dist_2.11-1.4.0.jar::/etc/hadoop/conf/: 2018-01-03 04:23:36,402 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - -------------------------------------------------------------------------------- 2018-01-03 04:23:36,412 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Registered UNIX signal handlers for [TERM, HUP, INT] 2018-01-03 04:23:36,427 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - All environment variables: {PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin, FLINK_DISPATCHER_MESOS_ROLE=*, HADOOP_CONF_DIR=/etc/hadoop/conf/, MARATHON_APP_LABEL_DCOS_SERVICE_NAME=flink, MARATHON_APP_LABELS=DCOS_SERVICE_SCHEME DCOS_PACKAGE_SOURCE DCOS_SERVICE_NAME DCOS_SERVICE_PORT_INDEX DCOS_PACKAGE_VERSION DCOS_PACKAGE_NAME, HOST=50.1.100.232, LIBPROCESS_PORT=31856, MESOS_SANDBOX=/mnt/mesos/sandbox, FLINK_CONF_DIR=/flink-1.4.0/conf, MARATHON_APP_RESOURCE_DISK=0.0, PWD=/var/lib/runit/service/flink, MARATHON_APP_RESOURCE_GPUS=0, PORT=31852, LIBPROCESS_IP=50.1.100.232, MARATHON_APP_RESOURCE_CPUS=1.0, FLINK_MESOS_ARTIFACT_SERVER_PORT=31855, MARATHON_APP_LABEL_DCOS_PACKAGE_NAME=flink, FLINK_DISPATCHER_MESOS_HOSTATTRIBUTE=, MARATHON_APP_DOCKER_IMAGE=mesosphere/dcos-flink:1.4.0-1.0, MESOS_TASK_ID=flink.d86999e7-f03d-11e7-bf80-4ac25a8eaeeb, MARATHON_APP_VERSION=2018-01-03T04:23:27.231Z, FLINK_TASK_MANAGER_MEM=1024, FLINK_TASK_MANAGER_CPUS=1, MARATHON_APP_LABEL_DCOS_PACKAGE_SOURCE=https://universe.mesosphere.com/repo, SHLVL=0, MARATHON_APP_LABEL_DCOS_SERVICE_PORT_INDEX=0, FLINK_BIN_DIR=/flink-1.4.0/bin, PORT0=31852, FLINK_APP_MASTER_CPUS=1, MESOS_CONTAINER_NAME=mesos-2d0d09db-8b28-4137-be2a-bf60a584a3b1, JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64/jre, MARATHON_APP_LABEL_DCOS_SERVICE_SCHEME=http, FLINK_JOBMANAGER_RPC_PORT=31853, DCOS_SERVICE_NAME=flink, MARATHON_APP_RESOURCE_MEM=1024.0, PORT_10000=31852, FLINK_LOG_DIR=/mnt/mesos/sandbox, FLINK_SECURITY_USE_TICKET_CACHE=true, MARATHON_APP_ID=/flink, MESOS_NATIVE_JAVA_LIBRARY=/usr/lib/libmesos.so, FLINK_TASK_MANAGER_HEAP=512, PORT_10003=31855, PORT_10004=31856, PORT_10001=31853, PORT_10002=31854, FLINK_APP_MASTER_MEM=1024, PORT1=31853, PORT2=31854, PORT3=31855, PORT4=31856, FLINK_TASK_SLOTS=1, APPLICATION_WEB_PROXY_BASE=/service/flink, FLINK_PARALLELISM_DEFAULT=1, FLINK_LOG_LEVEL=DEBUG, FLINK_UI_WEB_PROXY_BASE=/service/flink, FLINK_APP_MASTER_HEAP=256, FLINK_HOME=/flink-1.4.0, FLINK_TASK_MANAGER_MEM_PREALLOCATION=true, FLINK_BLOB_SERVER_PORT=31854, FLINK_JOBMANAGER_WEB_PORT=31852, FLINK_LIB_DIR=/flink-1.4.0/lib, MARATHON_APP_LABEL_DCOS_PACKAGE_VERSION=1.4.0.-1, FLINK_JAVA_OPTS= -Dblob.server.port=31854 -Djobmanager.heap.mb=256 -Djobmanager.rpc.port=31853 -Djobmanager.web.port=31852 -Dmesos.artifact-server.port=31855 -Dmesos.initial-tasks=1 -Dmesos.resourcemanager.tasks.cpus=1 -Dmesos.resourcemanager.tasks.mem=1024 -Dtaskmanager.heap.mb=512 -Dtaskmanager.memory.preallocate=true -Dtaskmanager.numberOfTaskSlots=1 -Dparallelism.default=1 -Djobmanager.rpc.address=DNN-G08-232 -Dmesos.resourcemanager.framework.role=* -Dsecurity.kerberos.login.use-ticket-cache=true, FLINK_DISPATCHER_MESOS_SECRET=, HOSTNAME=DNN-G08-232, FLINK_USER=root, FLINK_DISPATCHER_MESOS_PRINCIPAL=, FLINK_EXTRA_ARGS=, HOME=/root, PORTS=31852,31853,31854,31855,31856, FLINK_TASK_MANAGER_COUNT=1} 2018-01-03 04:23:36,450 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.master, zk://leader.mesos:2181/mesos 2018-01-03 04:23:36,450 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.failover-timeout, 60 2018-01-03 04:23:36,450 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.initial-tasks, 1 2018-01-03 04:23:36,451 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.container.type, mesos 2018-01-03 04:23:36,451 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.container.image.name, openjdk:8-jre 2018-01-03 04:23:36,451 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.cpus, 1 2018-01-03 04:23:36,451 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: mesos.resourcemanager.tasks.mem, 1024 2018-01-03 04:23:36,451 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123 2018-01-03 04:23:36,452 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.heap.mb, 256 2018-01-03 04:23:36,452 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.heap.mb, 512 2018-01-03 04:23:36,452 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2018-01-03 04:23:36,452 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.memory.preallocate, false 2018-01-03 04:23:36,452 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 1 2018-01-03 04:23:36,453 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.web.port, 8081 2018-01-03 04:23:36,458 DEBUG org.apache.flink.core.fs.FileSystem - Loading extension file systems via services 2018-01-03 04:23:36,473 DEBUG org.apache.flink.core.fs.FileSystem - Added file system maprfs:org.apache.flink.runtime.fs.maprfs.MapRFsFactory 2018-01-03 04:23:36,574 DEBUG org.apache.flink.runtime.util.HadoopUtils - Cannot find hdfs-default configuration-file path in Flink config. 2018-01-03 04:23:36,574 DEBUG org.apache.flink.runtime.util.HadoopUtils - Cannot find hdfs-site configuration-file path in Flink config. 2018-01-03 04:23:36,575 DEBUG org.apache.flink.runtime.util.HadoopUtils - Could not find Hadoop configuration via any of the supported methods (Flink configuration, environment variables). 2018-01-03 04:23:36,733 DEBUG org.apache.hadoop.security.UserGroupInformation - hadoop login 2018-01-03 04:23:36,733 DEBUG org.apache.hadoop.security.UserGroupInformation - hadoop login commit 2018-01-03 04:23:36,733 DEBUG org.apache.hadoop.security.UserGroupInformation - using local user:UnixPrincipal: root 2018-01-03 04:23:36,734 DEBUG org.apache.hadoop.security.UserGroupInformation - UGI loginUser:root (auth:SIMPLE) 2018-01-03 04:23:36,734 INFO org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set to root (auth:SIMPLE) 2018-01-03 04:23:37,072 DEBUG org.apache.hadoop.security.UserGroupInformation - PrivilegedAction as:root (auth:SIMPLE) from:org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) 2018-01-03 04:23:37,077 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - App Master Hostname to use: DNN-G08-232 2018-01-03 04:23:38,487 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2018-01-03 04:23:38,542 DEBUG akka.event.EventStream - logger log1-Slf4jLogger started 2018-01-03 04:23:38,545 DEBUG akka.event.EventStream - Default Loggers started 2018-01-03 04:23:38,564 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as the default logging framework 2018-01-03 04:23:38,584 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 96 2018-01-03 04:23:38,603 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Buffer.address: available 2018-01-03 04:23:38,604 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available 2018-01-03 04:23:38,604 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available 2018-01-03 04:23:38,605 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true 2018-01-03 04:23:38,605 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - Java version: 8 2018-01-03 04:23:38,606 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false 2018-01-03 04:23:38,606 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - sun.misc.Unsafe: available 2018-01-03 04:23:38,612 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.noJavassist: false 2018-01-03 04:23:38,740 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - Javassist: available 2018-01-03 04:23:38,740 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 2018-01-03 04:23:38,740 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model) 2018-01-03 04:23:38,740 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false 2018-01-03 04:23:38,774 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false 2018-01-03 04:23:38,774 DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512 2018-01-03 04:23:38,842 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0x2b2a106a703ca290 (took 2 ms) 2018-01-03 04:23:40,359 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled 2018-01-03 04:23:40,359 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 65536 2018-01-03 04:23:40,364 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - Loopback interface: lo (lo, 0:0:0:0:0:0:0:1%lo) 2018-01-03 04:23:40,364 DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - /proc/sys/net/core/somaxconn: 128 2018-01-03 04:23:40,379 INFO org.apache.flink.mesos.util.MesosArtifactServer - Mesos Artifact Server Base URL: http://DNN-G08-232:39063/49ce9b00-510c-4454-a880-94cba27bc1d1/, listening at 50.1.100.232:39063 2018-01-03 04:23:40,418 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - TaskManagers will be created with 1 task slots 2018-01-03 04:23:40,418 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - TaskManagers will be started with container size 1024 MB, JVM heap size 424 MB, JVM direct memory limit -1 MB, 1.0 cpus 2018-01-03 04:23:40,420 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Trying to start actor system at dnn-g08-232:31853 2018-01-03 04:23:40,431 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Using akka configuration Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"fork-join-executor":{"parallelism-factor":2},"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":31853,"connection-timeout":"20 s","hostname":"dnn-g08-232","maximum-frame-size":"10485760b","port":31853,"tcp-nodelay":"on","transport-class":"akka.remote.transport.netty.NettyTransport"}},"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"}})) 2018-01-03 04:23:40,642 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2018-01-03 04:23:40,645 DEBUG akka.event.EventStream - logger log1-Slf4jLogger started 2018-01-03 04:23:40,719 DEBUG akka.event.EventStream - Default Loggers started 2018-01-03 04:23:41,030 INFO akka.remote.Remoting - Starting remoting 2018-01-03 04:23:41,172 DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Using select timeout of 500 2018-01-03 04:23:41,172 DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Epoll-bug workaround enabled = false 2018-01-03 04:23:41,419 INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink@dnn-g08-232:31853] 2018-01-03 04:23:41,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Actor system started at akka.tcp://flink@dnn-g08-232:31853 2018-01-03 04:23:41,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Actor system bound to hostname dnn-g08-232. 2018-01-03 04:23:41,434 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting Artifact Server 2018-01-03 04:23:41,441 WARN org.apache.flink.runtime.clusterframework.overlays.HadoopConfOverlay - Unable to locate a Hadoop configuration; HDFS will use defaults. 2018-01-03 04:23:41,650 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.JavassistTypeParameterMatcherGenerator - Generated: org.apache.flink.shaded.netty4.io.netty.util.internal.__matchers__.org.apache.flink.shaded.netty4.io.netty.handler.codec.http.router.RoutedMatcher 2018-01-03 04:23:41,935 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting Web Frontend 2018-01-03 04:23:41,949 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'jobmanager.web.port' instead of proper key 'web.port' 2018-01-03 04:23:41,950 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting JobManager Web Frontend 2018-01-03 04:23:41,969 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'jobmanager.web.port' instead of proper key 'web.port' 2018-01-03 04:23:41,970 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager log file: /mnt/mesos/sandbox/flink--mesos-appmaster-DNN-G08-232.log 2018-01-03 04:23:41,970 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager stdout file: /mnt/mesos/sandbox/flink--mesos-appmaster-DNN-G08-232.out 2018-01-03 04:23:41,970 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-58ed6835-dfb3-42e5-8617-f6c039d5ba17 for the web interface files 2018-01-03 04:23:41,971 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-4cf9b05f-43e8-49e6-a18e-e6a5dc435f97 for web frontend JAR file uploads 2018-01-03 04:23:42,623 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web frontend listening at DNN-G08-232:31852 2018-01-03 04:23:42,643 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting JobManager actor 2018-01-03 04:23:42,725 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported. 2018-01-03 04:23:42,757 DEBUG org.apache.flink.runtime.jobmanager.JobManager - No archive directory was configured. Jobs will not be archived. 2018-01-03 04:23:42,826 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-f9b93da8-1d27-4246-ba62-984328cda733 2018-01-03 04:23:42,830 DEBUG org.apache.flink.util.NetUtils - Trying to open socket on port 31854 2018-01-03 04:23:42,835 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:31854 - max concurrent requests: 50 - max backlog: 1000 2018-01-03 04:23:43,338 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting Mesos Flink Resource Manager 2018-01-03 04:23:43,418 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Mesos framework to allocate 1 initial tasks 2018-01-03 04:23:43,419 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Mesos framework tolerates 1 failed tasks before giving up 2018-01-03 04:23:43,419 INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/archive 2018-01-03 04:23:43,419 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Starting process reapers for JobManager 2018-01-03 04:23:43,420 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Starting JobManager at akka.tcp://flink@dnn-g08-232:31853/user/jobmanager. 2018-01-03 04:23:43,422 INFO org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner - Mesos JobManager started 2018-01-03 04:23:43,422 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Initializing Mesos resource master 2018-01-03 04:23:43,432 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Registering as new framework. 2018-01-03 04:23:43,432 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - -------------------------------------------------------------------------------- 2018-01-03 04:23:43,432 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Mesos Info: 2018-01-03 04:23:43,432 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Master URL: zk://leader.mesos:2181/mesos 2018-01-03 04:23:43,432 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Framework Info: 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - ID: (none) 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Name: Flink 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Failover Timeout (secs): 60.0 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Role: * 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Principal: (none) 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Host: DNN-G08-232 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - LIBPROCESS_IP: 50.1.100.232 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - LIBPROCESS_PORT: 31856 2018-01-03 04:23:43,433 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Web UI: http://DNN-G08-232:31852 2018-01-03 04:23:43,434 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - -------------------------------------------------------------------------------- 2018-01-03 04:23:43,633 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - JobManager akka.tcp://flink@dnn-g08-232:31853/user/jobmanager was granted leadership with leader session ID Some(00000000-0000-0000-0000-000000000000). 2018-01-03 04:23:44,427 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (StoppedState -> StoppedState) with data () 2018-01-03 04:23:44,437 INFO org.apache.flink.mesos.scheduler.ConnectionMonitor - Connecting to Mesos... 2018-01-03 04:23:44,438 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (StoppedState -> ConnectingState) with data () 2018-01-03 04:23:44,522 DEBUG org.apache.flink.mesos.scheduler.ReconciliationCoordinator - State change (Suspended -> Suspended) with data ReconciliationData(Map(),0) 2018-01-03 04:23:44,526 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Received new leading JobManager akka.tcp://flink@dnn-g08-232:31853/user/jobmanager. Connecting. 2018-01-03 04:23:44,526 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Trying to associate with JobManager leader akka.tcp://flink@dnn-g08-232:31853/user/jobmanager 2018-01-03 04:23:44,532 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Resource manager registration: RegisterResourceManager akka://flink/user/Mesos_Resource_Master 2018-01-03 04:23:44,534 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - State change (Suspended -> Suspended) with data GatherData(List(),List()) 2018-01-03 04:23:44,537 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#1457842918] - leader session 00000000-0000-0000-0000-000000000000 2018-01-03 04:23:44,933 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Scheduling Mesos task taskmanager-00001 with (1024.0 MB, 1.0 cpus). 2018-01-03 04:23:44,935 DEBUG org.apache.flink.mesos.scheduler.ReconciliationCoordinator - State change (Suspended -> Idle) with data ReconciliationData(Map(),0) 2018-01-03 04:23:44,936 INFO org.apache.flink.mesos.scheduler.ConnectionMonitor - Connected to Mesos as framework ID 5865e700-bd58-4b24-b906-5658c364e45a-0010. 2018-01-03 04:23:44,936 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Now gathering offers for at least 1 task(s). 2018-01-03 04:23:45,020 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - State change (Suspended -> GatheringOffers) with data GatherData(List(LaunchableMesosWorker{taskID=value: "taskmanager-00001" taskRequest=Request{cpus=1.0memory=1024.0}}),List()) 2018-01-03 04:23:45,021 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - Master Info: id: "5865e700-bd58-4b24-b906-5658c364e45a" ip: 3882090802 port: 5050 pid: "master@50.1.100.231:5050" hostname: "50.1.100.231" version: "1.4.0" address { hostname: "50.1.100.231" ip: "50.1.100.231" port: 5050 } 2018-01-03 04:23:45,021 DEBUG org.apache.flink.mesos.scheduler.ConnectionMonitor - State change (ConnectingState -> ConnectedState) with data () 2018-01-03 04:23:45,025 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor - State change (Suspended -> Suspended) with data StateData(New(value: "taskmanager-00001" )) 2018-01-03 04:23:45,025 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor - State change (Suspended -> New) with data StateData(New(value: "taskmanager-00001" )) 2018-01-03 04:23:50,032 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:23:50,034 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:23:50,035 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:23:50,038 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=2, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:23:50,039 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:23:53,060 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.JavassistTypeParameterMatcherGenerator - Generated: org.apache.flink.shaded.netty4.io.netty.util.internal.__matchers__.org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequestMatcher 2018-01-03 04:23:53,098 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector - -Dorg.apache.flink.shaded.netty4.io.netty.leakDetectionLevel: simple 2018-01-03 04:23:53,110 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.JavassistTypeParameterMatcherGenerator - Generated: org.apache.flink.shaded.netty4.io.netty.util.internal.__matchers__.org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectMatcher 2018-01-03 04:23:53,115 DEBUG org.apache.flink.shaded.netty4.io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144 2018-01-03 04:23:53,130 DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.Cleaner0 - java.nio.ByteBuffer.cleaner(): available 2018-01-03 04:23:55,051 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:23:55,051 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:23:55,051 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:23:55,052 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:23:55,052 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:00,071 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:00,072 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:00,072 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:00,072 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:00,073 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:05,091 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:05,092 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:05,092 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:05,092 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:05,093 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:10,111 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:10,112 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:10,112 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:10,112 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:10,112 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:15,131 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:15,131 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:15,131 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:15,132 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:15,132 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:20,151 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:20,151 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:20,152 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:20,152 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:20,152 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:25,171 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:25,171 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:25,172 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:25,172 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:25,172 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:30,192 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:30,192 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:30,192 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:30,192 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:30,192 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:32,291 DEBUG org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Loading missing file from classloader: /index.html 2018-01-03 04:24:32,306 DEBUG org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Responding with file '/tmp/flink-web-58ed6835-dfb3-42e5-8617-f6c039d5ba17/index.html' 2018-01-03 04:24:35,211 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:35,212 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:35,212 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:35,212 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:35,212 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:40,232 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:40,232 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:40,232 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:40,232 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:40,233 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:45,252 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:45,252 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:45,252 INFO com.netflix.fenzo.TaskScheduler - Purging inactive VMs 2018-01-03 04:24:45,252 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:45,253 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:45,253 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:50,271 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:50,271 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:50,271 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:50,272 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:50,272 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:24:55,291 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:24:55,292 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:24:55,292 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:24:55,292 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:24:55,292 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:00,311 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:00,312 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:00,312 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:00,312 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:00,313 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:05,331 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:05,331 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:05,331 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:05,332 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:05,332 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:10,351 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:10,352 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:10,352 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:10,352 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:10,352 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:15,371 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:15,372 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:15,372 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:15,372 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:15,372 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:20,391 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:20,391 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:20,392 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:20,392 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:20,392 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:25,411 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:25,412 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:25,412 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:25,412 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:25,412 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:30,432 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:30,432 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:30,432 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:30,432 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:30,432 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:32,311 DEBUG org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Responding with file '/tmp/flink-web-58ed6835-dfb3-42e5-8617-f6c039d5ba17/index.html' 2018-01-03 04:25:35,452 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:35,452 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:35,452 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:35,452 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:35,453 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:39,803 ERROR org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Caught exception java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) at sun.nio.ch.IOUtil.read(IOUtil.java:192) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) at org.apache.flink.shaded.netty4.io.netty.buffer.UnpooledUnsafeDirectByteBuf.setBytes(UnpooledUnsafeDirectByteBuf.java:447) at org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:881) at org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:241) at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:119) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) at java.lang.Thread.run(Thread.java:748) 2018-01-03 04:25:40,471 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:40,472 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:40,472 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:40,472 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:40,472 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:45,491 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:45,492 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:45,492 INFO com.netflix.fenzo.TaskScheduler - Purging inactive VMs 2018-01-03 04:25:45,492 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:45,492 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:45,492 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:50,511 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:50,511 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:50,512 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:50,512 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:50,512 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:25:55,531 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:25:55,532 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:25:55,532 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:25:55,532 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:25:55,532 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:00,551 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:00,551 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:00,551 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:00,551 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:00,552 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:05,572 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:05,572 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:05,572 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:05,572 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:05,573 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:10,591 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:10,591 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:10,592 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:10,592 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:10,592 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=1, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:15,611 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:15,612 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:15,612 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:15,612 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:15,612 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:20,631 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:20,631 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:20,631 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:20,631 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:20,632 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:25,651 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:25,651 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:25,651 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:25,652 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:25,652 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:30,671 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:30,671 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:30,671 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:30,671 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:30,672 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0} 2018-01-03 04:26:32,322 ERROR org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Caught exception java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) at sun.nio.ch.IOUtil.read(IOUtil.java:192) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380) at org.apache.flink.shaded.netty4.io.netty.buffer.UnpooledUnsafeDirectByteBuf.setBytes(UnpooledUnsafeDirectByteBuf.java:447) at org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:881) at org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:241) at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:119) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) at java.lang.Thread.run(Thread.java:748) 2018-01-03 04:26:32,329 DEBUG org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler - Responding with file '/tmp/flink-web-58ed6835-dfb3-42e5-8617-f6c039d5ba17/index.html' 2018-01-03 04:26:35,691 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 1 task(s) against 0 new offer(s) plus outstanding offers. 2018-01-03 04:26:35,691 DEBUG com.netflix.fenzo.TaskScheduler - Found 0 VMs with non-zero offers to assign from 2018-01-03 04:26:35,691 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2018-01-03 04:26:35,691 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 1 task(s) are not yet launched. 2018-01-03 04:26:35,691 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator - SchedulingResult{resultMap={}, failures={}, leasesAdded=0, leasesRejected=0, runtime=0, numAllocations=0, totalVMsCount=0, idleVMsCount=0}