flink logs

/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/bin/java "-javaagent:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar=51816:/Applications/IntelliJ IDEA.app/Contents/bin" -Dfile.encoding=UTF-8 -classpath /Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_162.jdk/Contents/Home/lib/tools.jar:/Users/kamer/predictors/flink-scala-project/target/classes:/Users/kamer/.m2/repository/org/apache/flink/flink-scala_2.11/1.4.2/flink-scala_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-core/1.4.2/flink-core-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-annotations/1.4.2/flink-annotations-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-metrics-core/1.4.2/flink-metrics-core-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/kamer/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/kamer/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/kamer/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/kamer/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/kamer/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/Users/kamer/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-java/1.4.2/flink-java-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-shaded-asm/5.0.4-2.0/flink-shaded-asm-5.0.4-2.0.jar:/Users/kamer/.m2/repository/org/scala-lang/scala-reflect/2.11.11/scala-reflect-2.11.11.jar:/Users/kamer/.m2/repository/org/scala-lang/scala-compiler/2.11.11/scala-compiler-2.11.11.jar:/Users/kamer/.m2/repository/org/scala-lang/modules/scala-xml_2.11/1.0.5/scala-xml_2.11-1.0.5.jar:/Users/kamer/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.11/1.0.4/scala-parser-combinators_2.11-1.0.4.jar:/Users/kamer/.m2/repository/org/slf4j/slf4j-api/1.7.7/slf4j-api-1.7.7.jar:/Users/kamer/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/kamer/.m2/repository/org/apache/flink/force-shading/1.4.2/force-shading-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-streaming-scala_2.11/1.4.2/flink-streaming-scala_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-streaming-java_2.11/1.4.2/flink-streaming-java_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-runtime_2.11/1.4.2/flink-runtime_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-queryable-state-client-java_2.11/1.4.2/flink-queryable-state-client-java_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-hadoop-fs/1.4.2/flink-hadoop-fs-1.4.2.jar:/Users/kamer/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-shaded-netty/4.0.27.Final-2.0/flink-shaded-netty-4.0.27.Final-2.0.jar:/Users/kamer/.m2/repository/commons-cli/commons-cli/1.3.1/commons-cli-1.3.1.jar:/Users/kamer/.m2/repository/org/javassist/javassist/3.18.2-GA/javassist-3.18.2-GA.jar:/Users/kamer/.m2/repository/com/typesafe/akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/kamer/.m2/repository/com/typesafe/config/1.3.0/config-1.3.0.jar:/Users/kamer/.m2/repository/org/scala-lang/modules/scala-java8-compat_2.11/0.7.0/scala-java8-compat_2.11-0.7.0.jar:/Users/kamer/.m2/repository/com/typesafe/akka/akka-stream_2.11/2.4.20/akka-stream_2.11-2.4.20.jar:/Users/kamer/.m2/repository/org/reactivestreams/reactive-streams/1.0.0/reactive-streams-1.0.0.jar:/Users/kamer/.m2/repository/com/typesafe/ssl-config-core_2.11/0.2.1/ssl-config-core_2.11-0.2.1.jar:/Users/kamer/.m2/repository/com/typesafe/akka/akka-protobuf_2.11/2.4.20/akka-protobuf_2.11-2.4.20.jar:/Users/kamer/.m2/repository/com/typesafe/akka/akka-slf4j_2.11/2.4.20/akka-slf4j_2.11-2.4.20.jar:/Users/kamer/.m2/repository/org/clapper/grizzled-slf4j_2.11/1.0.2/grizzled-slf4j_2.11-1.0.2.jar:/Users/kamer/.m2/repository/com/github/scopt/scopt_2.11/3.5.0/scopt_2.11-3.5.0.jar:/Users/kamer/.m2/repository/org/xerial/snappy/snappy-java/1.1.4/snappy-java-1.1.4.jar:/Users/kamer/.m2/repository/com/twitter/chill_2.11/0.7.4/chill_2.11-0.7.4.jar:/Users/kamer/.m2/repository/com/twitter/chill-java/0.7.4/chill-java-0.7.4.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-clients_2.11/1.4.2/flink-clients_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-optimizer_2.11/1.4.2/flink-optimizer_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-shaded-guava/18.0-2.0/flink-shaded-guava-18.0-2.0.jar:/Users/kamer/.m2/repository/org/apache/sling/org.apache.sling.commons.json/2.0.6/org.apache.sling.commons.json-2.0.6.jar:/Users/kamer/.m2/repository/org/scala-lang/scala-library/2.11.11/scala-library-2.11.11.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-table_2.11/1.4.2/flink-table_2.11-1.4.2.jar:/Users/kamer/.m2/repository/org/apache/flink/flink-shaded-jackson/2.7.9-2.0/flink-shaded-jackson-2.7.9-2.0.jar:/Users/kamer/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar:/Users/kamer/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar org.apache.flink.quickstart.DataStreamtotableapi --input /Users/kamer/Telesign/result/voice_result/voice.csv
12:10:49,756 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit does not contain a setter for field modificationTime
12:10:49,757 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit is not a valid POJO type because not all fields are valid POJO fields.
12:10:52,504 INFO  org.apache.flink.streaming.api.environment.LocalStreamEnvironment  - Running job on local embedded Flink mini cluster
12:10:52,650 INFO  org.apache.flink.runtime.minicluster.FlinkMiniCluster         - Starting FlinkMiniCluster.
12:10:52,657 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl           - No metrics reporter configured, no metrics will be exposed/reported.
12:10:53,032 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
12:10:53,060 INFO  org.apache.flink.runtime.blob.BlobServer                      - Created BLOB server storage directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/blobStore-fc3b55ff-3da8-4632-afec-c5bc1b2d17cf
12:10:53,067 INFO  org.apache.flink.runtime.blob.BlobServer                      - Started BLOB server at 0.0.0.0:51819 - max concurrent requests: 50 - max backlog: 1000
12:10:53,160 INFO  org.apache.flink.runtime.jobmanager.MemoryArchivist           - Started memory archivist akka://flink/user/archive_1
12:10:53,161 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager at akka://flink/user/jobmanager_1.
12:10:53,162 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Proposing leadership to contender org.apache.flink.runtime.jobmanager.JobManager@7b679040 @ akka://flink/user/jobmanager_1
12:10:53,168 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration  - Messages have a max timeout of 10000 ms
12:10:53,171 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices     - Temporary file directory '/var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T': total 233 GB, usable 87 GB (37.34% usable)
12:10:53,227 INFO  org.apache.flink.runtime.jobmanager.JobManager                - JobManager akka://flink/user/jobmanager_1 was granted leadership with leader session ID Some(555fdce8-485c-42fb-b3c4-18f7ca66526b).
12:10:53,230 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Received confirmation of leadership for leader akka://flink/user/jobmanager_1 , session=555fdce8-485c-42fb-b3c4-18f7ca66526b
12:10:53,238 INFO  org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager  - Trying to associate with JobManager leader akka://flink/user/jobmanager_1
12:10:53,247 INFO  org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager  - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager_1#1933865052] - leader session 555fdce8-485c-42fb-b3c4-18f7ca66526b
12:10:53,705 INFO  org.apache.flink.runtime.io.network.buffer.NetworkBufferPool  - Allocated 363 MB for network buffer pool (number of memory segments: 11616, bytes per segment: 32768).
12:10:53,715 WARN  org.apache.flink.runtime.query.QueryableStateUtils            - Could not load Queryable State Client Proxy. Probable reason: flink-queryable-state-runtime is not in the classpath. To enable Queryable State, please move the flink-queryable-state-runtime jar from the opt to the lib folder.
12:10:53,715 WARN  org.apache.flink.runtime.query.QueryableStateUtils            - Could not load Queryable State Server. Probable reason: flink-queryable-state-runtime is not in the classpath. To enable Queryable State, please move the flink-queryable-state-runtime jar from the opt to the lib folder.
12:10:53,717 INFO  org.apache.flink.runtime.io.network.NetworkEnvironment        - Starting the network environment and its components.
12:10:53,719 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices     - Limiting managed memory to 1144 MB, memory will be allocated lazily.
12:10:53,723 INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager          - I/O manager uses directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/flink-io-c77e0433-3218-48b4-887c-f8a7a0cda7fc for spill files.
12:10:53,727 INFO  org.apache.flink.runtime.filecache.FileCache                  - User file cache uses directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/flink-dist-cache-772efa95-f7dd-4547-987e-c5cca71f5181
12:10:53,740 INFO  org.apache.flink.runtime.filecache.FileCache                  - User file cache uses directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/flink-dist-cache-c821cb10-9361-4a62-9e5c-8494a10fa864
12:10:53,741 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Starting TaskManager actor at akka://flink/user/taskmanager_1#286906061.
12:10:53,743 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - TaskManager data connection information: d2c15533c111c177b85d6d222ce75dd6 @ localhost (dataPort=-1)
12:10:53,744 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - TaskManager has 1 task slot(s).
12:10:53,746 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Memory usage stats: [HEAP: 378/832/3641 MB, NON HEAP: 45/46/-1 MB (used/committed/max)]
12:10:53,750 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Trying to register at JobManager akka://flink/user/jobmanager_1 (attempt 1, timeout: 500 milliseconds)
12:10:53,752 INFO  org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager  - TaskManager d2c15533c111c177b85d6d222ce75dd6 has started.
12:10:53,754 INFO  org.apache.flink.runtime.instance.InstanceManager             - Registered TaskManager at localhost (akka://flink/user/taskmanager_1) as fa3f1dfd7e665695aa6811fb85c72c63. Current number of registered hosts is 1. Current number of alive task slots is 1.
12:10:53,757 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Successful registration at JobManager (akka://flink/user/jobmanager_1), starting network stack and library cache.
12:10:53,761 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Determined BLOB server address to be localhost/127.0.0.1:51819. Starting BLOB cache.
12:10:53,764 INFO  org.apache.flink.runtime.blob.PermanentBlobCache              - Created BLOB cache storage directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/blobStore-9ab790d3-e844-4ba5-9caa-0c6d011814e4
12:10:53,765 INFO  org.apache.flink.runtime.blob.TransientBlobCache              - Created BLOB cache storage directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/blobStore-c6d196bb-e516-4873-ac5b-aab80493f210
12:10:53,775 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Received SubmitJobAndWait(JobGraph(jobId: 90060c57dc3b191dc51d80be444e24bc)) but there is no connection to a JobManager yet.
12:10:53,775 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Received job this job (90060c57dc3b191dc51d80be444e24bc).
12:10:53,776 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Disconnect from JobManager null.
12:10:53,779 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Connect to JobManager Actor[akka://flink/user/jobmanager_1#1933865052].
12:10:53,780 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1933865052] with leader session id 555fdce8-485c-42fb-b3c4-18f7ca66526b.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1933865052] with leader session id 555fdce8-485c-42fb-b3c4-18f7ca66526b.
12:10:53,780 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Sending message to JobManager akka://flink/user/jobmanager_1 to submit job this job (90060c57dc3b191dc51d80be444e24bc) and wait for progress
12:10:53,782 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Upload jar files to job manager akka://flink/user/jobmanager_1.
12:10:53,794 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Submit job to the job manager akka://flink/user/jobmanager_1.
12:10:53,796 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Submitting job 90060c57dc3b191dc51d80be444e24bc (this job).
12:10:53,802 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Using restart strategy NoRestartStrategy for 90060c57dc3b191dc51d80be444e24bc.
12:10:53,818 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job recovers via failover strategy: full graph restart
12:10:53,877 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Running initialization on master for job this job (90060c57dc3b191dc51d80be444e24bc).
12:10:53,877 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Successfully ran initialization on master in 0 ms.
12:10:53,895 INFO  org.apache.flink.runtime.jobmanager.JobManager                - No state backend has been configured, using default state backend (Memory / JobManager)
12:10:53,904 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Job 90060c57dc3b191dc51d80be444e24bc was successfully submitted to the JobManager akka://flink/deadLetters.
12:10:53,904 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Scheduling job 90060c57dc3b191dc51d80be444e24bc (this job).
12:10:53,904 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job this job (90060c57dc3b191dc51d80be444e24bc) switched from state CREATED to RUNNING.
12:10:53,906 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from CREATED to SCHEDULED.
12:10:53,906 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Job execution switched to status RUNNING.
03/20/2018 12:10:53	Job execution switched to status RUNNING.
12:10:53,907 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to SCHEDULED 
03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to SCHEDULED 
12:10:53,916 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from CREATED to SCHEDULED.
12:10:53,918 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from SCHEDULED to DEPLOYING.
12:10:53,918 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to SCHEDULED 
03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to SCHEDULED 
12:10:53,918 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom File Source (1/1) (attempt #0) to localhost
12:10:53,918 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to DEPLOYING 
03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to DEPLOYING 
12:10:53,923 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from SCHEDULED to DEPLOYING.
12:10:53,923 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (attempt #0) to localhost
12:10:53,924 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to DEPLOYING 
03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to DEPLOYING 
12:10:53,951 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Received task Source: Custom File Source (1/1)
12:10:53,951 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from CREATED to DEPLOYING.
12:10:53,951 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) [DEPLOYING]
12:10:53,955 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) [DEPLOYING].
12:10:53,958 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) [DEPLOYING].
12:10:53,963 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from DEPLOYING to RUNNING.
12:10:53,964 INFO  org.apache.flink.streaming.runtime.tasks.StreamTask           - No state backend has been configured, using default state backend (Memory / JobManager)
12:10:53,968 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Received task Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1)
12:10:53,969 INFO  org.apache.flink.runtime.taskmanager.Task                     - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from CREATED to DEPLOYING.
12:10:53,969 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) [DEPLOYING]
12:10:53,970 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) [DEPLOYING].
12:10:53,977 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from DEPLOYING to RUNNING.
12:10:53,978 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to RUNNING 
03/20/2018 12:10:53	Source: Custom File Source(1/1) switched to RUNNING 
12:10:53,981 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) [DEPLOYING].
12:10:53,983 INFO  org.apache.flink.runtime.taskmanager.Task                     - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from DEPLOYING to RUNNING.
12:10:53,983 INFO  org.apache.flink.streaming.runtime.tasks.StreamTask           - No state backend has been configured, using default state backend (Memory / JobManager)
12:10:53,984 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from DEPLOYING to RUNNING.
12:10:53,985 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to RUNNING 
03/20/2018 12:10:53	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to RUNNING 
12:10:54,008 INFO  org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction  - No state to restore for the ContinuousFileMonitoringFunction.
12:10:54,018 INFO  org.apache.flink.core.fs.FileSystem                           - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available.
12:10:54,048 INFO  org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator  - No state to restore for the ContinuousFileReaderOperator (taskIdx=0).
12:10:54,050 INFO  org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction  - Forwarding split: [0] file:/Users/kamer/Telesign/result/voice_result/voice.csv mod@ 1513675388000 : 0 + 524209124
12:10:54,257 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from RUNNING to FINISHED.
12:10:54,257 INFO  org.apache.flink.runtime.taskmanager.Task                     - Freeing task resources for Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7).
12:10:54,259 INFO  org.apache.flink.runtime.taskmanager.Task                     - Ensuring all FileSystem streams are closed for task Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) [FINISHED]
12:10:54,262 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Custom File Source (f6a321fe82a2134450128ebb339123c7)
12:10:54,278 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom File Source (1/1) (f6a321fe82a2134450128ebb339123c7) switched from RUNNING to FINISHED.
12:10:54,279 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:54	Source: Custom File Source(1/1) switched to FINISHED 
03/20/2018 12:10:54	Source: Custom File Source(1/1) switched to FINISHED 
12:10:59,084 INFO  org.apache.flink.runtime.taskmanager.Task                     - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from RUNNING to FINISHED.
12:10:59,084 INFO  org.apache.flink.runtime.taskmanager.Task                     - Freeing task resources for Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a).
12:10:59,086 INFO  org.apache.flink.runtime.taskmanager.Task                     - Ensuring all FileSystem streams are closed for task Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) [FINISHED]
12:10:59,086 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Un-registering task and sending final execution state FINISHED to JobManager for task Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (70e934fffd9c7bd0c4e6c1185795bf4a)
12:10:59,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed (1/1) (70e934fffd9c7bd0c4e6c1185795bf4a) switched from RUNNING to FINISHED.
12:10:59,087 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:59	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to FINISHED 
03/20/2018 12:10:59	Split Reader: Custom File Source -> Map -> Filter -> Filter -> Timestamps/Watermarks -> from: (a, b, c, d, e, f, g, h, i, j, k, l, m, n, p, q, r, s, t, v, w) -> select: (a) -> to: Row -> Map -> Sink: Unnamed(1/1) switched to FINISHED 
12:10:59,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job this job (90060c57dc3b191dc51d80be444e24bc) switched from state RUNNING to FINISHED.
12:10:59,088 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - 03/20/2018 12:10:59	Job execution switched to status FINISHED.
03/20/2018 12:10:59	Job execution switched to status FINISHED.
12:10:59,088 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Stopping checkpoint coordinator for job 90060c57dc3b191dc51d80be444e24bc
12:10:59,088 INFO  org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore  - Shutting down
12:10:59,092 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Terminate JobClientActor.
12:10:59,092 INFO  org.apache.flink.runtime.client.JobClient                     - Job execution complete
12:10:59,092 INFO  org.apache.flink.runtime.client.JobSubmissionClientActor      - Disconnect from JobManager Actor[akka://flink/user/jobmanager_1#1933865052].
12:10:59,092 INFO  org.apache.flink.runtime.minicluster.FlinkMiniCluster         - Stopping FlinkMiniCluster.
12:10:59,105 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Stopping TaskManager akka://flink/user/taskmanager_1#286906061.
12:10:59,106 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Stopping JobManager akka://flink/user/jobmanager_1.
12:10:59,106 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Disassociating from JobManager
12:10:59,108 INFO  org.apache.flink.runtime.blob.PermanentBlobCache              - Shutting down BLOB cache
12:10:59,119 INFO  org.apache.flink.runtime.blob.TransientBlobCache              - Shutting down BLOB cache
12:10:59,120 INFO  org.apache.flink.runtime.blob.BlobServer                      - Stopped BLOB server at 0.0.0.0:51819
12:10:59,121 INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager          - I/O manager removed spill file directory /var/folders/qm/q2yz9v4557l7sz55d0syl2jcykwbvx/T/flink-io-c77e0433-3218-48b4-887c-f8a7a0cda7fc
12:10:59,121 INFO  org.apache.flink.runtime.io.network.NetworkEnvironment        - Shutting down the network environment and its components.
12:10:59,136 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Task manager akka://flink/user/taskmanager_1 is completely shut down.

Process finished with exit code 0