2018-05-18 12:55:16,624 INFO  org.apache.flink.client.CliFrontend                           - --------------------------------------------------------------------------------
2018-05-18 12:55:16,626 INFO  org.apache.flink.client.CliFrontend                           -  Starting Command Line Client (Version: 1.3.0, Rev:760eea8, Date:26.05.2017 @ 14:06:53 UTC)
2018-05-18 12:55:16,626 INFO  org.apache.flink.client.CliFrontend                           -  Current user: enrique
2018-05-18 12:55:16,626 INFO  org.apache.flink.client.CliFrontend                           -  JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.171-b11
2018-05-18 12:55:16,626 INFO  org.apache.flink.client.CliFrontend                           -  Maximum heap size: 1758 MiBytes
2018-05-18 12:55:16,626 INFO  org.apache.flink.client.CliFrontend                           -  JAVA_HOME: /usr/jdk1.8.0_171
2018-05-18 12:55:16,628 INFO  org.apache.flink.client.CliFrontend                           -  Hadoop version: 2.3.0
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -  JVM Options:
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -Dlog.file=/home/enrique/flink/log/flink-enrique-client-debian.log
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -Dlog4j.configuration=file:/home/enrique/flink/conf/log4j-cli.properties
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -Dlogback.configurationFile=file:/home/enrique/flink/conf/logback.xml
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -  Program Arguments:
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     run
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -d
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -p
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     8
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     -c
2018-05-18 12:55:16,629 INFO  org.apache.flink.client.CliFrontend                           -     org.inria.flink.readFromHdfs
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -     hbase-flink-persistence/target/hbase-test-1.0-SNAPSHOT.jar
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -     3000
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -     8
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -     9000
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -     /home/enrique/tmp
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           -  Classpath: /home/enrique/flink/lib/flink-python_2.10-1.3.0.jar:/home/enrique/flink/lib/flink-shaded-hadoop2-uber-1.3.0.jar:/home/enrique/flink/lib/log4j-1.2.17.jar:/home/enrique/flink/lib/slf4j-log4j12-1.7.7.jar:/home/enrique/flink/lib/flink-dist_2.10-1.3.0.jar:::
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           - --------------------------------------------------------------------------------
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           - Using configuration directory /home/enrique/flink/conf
2018-05-18 12:55:16,630 INFO  org.apache.flink.client.CliFrontend                           - Trying to load configuration file
2018-05-18 12:55:16,635 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:16,636 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:16,636 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:16,636 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:16,636 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:16,637 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:16,637 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:16,637 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:16,891 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:16,891 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:16,891 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:16,891 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:16,892 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:16,892 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:16,892 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:16,892 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:16,930 INFO  org.apache.flink.runtime.security.modules.HadoopModule        - Hadoop user set to enrique (auth:SIMPLE)
2018-05-18 12:55:16,963 INFO  org.apache.flink.client.CliFrontend                           - Running 'run' command.
2018-05-18 12:55:16,971 INFO  org.apache.flink.client.CliFrontend                           - Building program from JAR file
2018-05-18 12:55:17,071 INFO  org.apache.flink.client.CliFrontend                           - Cluster configuration: Standalone cluster with JobManager at localhost/127.0.0.1:6123
2018-05-18 12:55:17,072 INFO  org.apache.flink.client.CliFrontend                           - Using address localhost:6123 to connect to JobManager.
2018-05-18 12:55:17,072 INFO  org.apache.flink.client.CliFrontend                           - JobManager web interface address http://localhost:8081
2018-05-18 12:55:17,072 INFO  org.apache.flink.client.CliFrontend                           - Starting execution of program
2018-05-18 12:55:17,072 INFO  org.apache.flink.client.program.StandaloneClusterClient       - Starting program in interactive mode
2018-05-18 12:55:17,089 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:17,089 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:17,090 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:17,100 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:17,101 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:17,101 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:17,101 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:17,101 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:17,101 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:17,102 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:17,102 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:17,123 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:17,124 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:17,125 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:17,139 INFO  org.apache.flink.api.java.ExecutionEnvironment                - The job has 0 registered types and 0 default Kryo serializers
2018-05-18 12:55:17,163 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:17,163 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:17,163 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:17,163 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:17,164 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:17,164 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:17,164 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:17,164 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:18,001 WARN  org.apache.flink.client.program.DetachedEnvironment           - Job was executed in detached mode, the results will be available on completion.
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.memory.preallocate, false
2018-05-18 12:55:18,006 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-18 12:55:18,007 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.web.port, 8081
2018-05-18 12:55:18,065 INFO  org.apache.flink.client.program.StandaloneClusterClient       - Starting client actor system.
2018-05-18 12:55:18,066 INFO  org.apache.flink.runtime.util.LeaderRetrievalUtils            - Trying to select the network interface and address to use by connecting to the leading JobManager.
2018-05-18 12:55:18,067 INFO  org.apache.flink.runtime.util.LeaderRetrievalUtils            - TaskManager will try to connect for 10000 milliseconds before falling back to heuristics
2018-05-18 12:55:18,069 INFO  org.apache.flink.runtime.net.ConnectionUtils                  - Retrieved new target address localhost/127.0.0.1:6123.
2018-05-18 12:55:18,533 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
2018-05-18 12:55:18,616 INFO  Remoting                                                      - Starting remoting
2018-05-18 12:55:18,826 INFO  Remoting                                                      - Remoting started; listening on addresses :[akka.tcp://[email protected]:37005]
2018-05-18 12:55:19,021 INFO  org.apache.flink.client.program.StandaloneClusterClient       - Submitting Job with JobID: 0600a18c6b3f554d9f75c7477991382e. Returning after job submission.
2018-05-18 12:55:19,023 INFO  org.apache.flink.runtime.client.JobClient                     - Checking and uploading JAR files
2018-05-18 12:55:19,036 INFO  org.apache.flink.runtime.blob.BlobClient                      - Blob client connecting to akka.tcp://flink@localhost:6123/user/jobmanager
2018-05-18 12:55:19,758 INFO  org.apache.flink.client.CliFrontend                           - Job has been submitted with JobID 0600a18c6b3f554d9f75c7477991382e
2018-05-18 12:55:19,765 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator         - Shutting down remote daemon.
2018-05-18 12:55:19,771 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator         - Remote daemon shut down; proceeding with flushing remote transports.
2018-05-18 12:55:19,885 INFO  akka.remote.RemoteActorRefProvider$RemotingTerminator         - Remoting shut down.