Alex Chen created FLINK-9298:
--------------------------------
Summary: setup_quickstart hanging
Key: FLINK-9298
URL: https://issues.apache.org/jira/browse/FLINK-9298
Project: Flink
Issue Type: Bug
Reporter: Alex Chen
Well, I follow tutorial
([https://ci.apache.org/projects/flink/flink-docs-master/quickstart/setup_quickstart.html)].
Regardless there are several typos like log files name incorrect, flink was
hanging executing `
bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000`, looks
like:
```
➜ build-target git:(master) bin/flink run
examples/streaming/SocketWindowWordCount.jar --port 9000
Starting execution of program
(hanging)
```
Below are logs
```
➜ log git:(master) ls -l
total 136
-rw-r--r-- 1 wander staff 6189 5 5 04:34 flink-wander-client-localhost.log
-rw-r--r-- 1 wander staff 17823 5 5 04:34
flink-wander-standalonesession-0-localhost.log
-rw-r--r-- 1 wander staff 0 5 5 04:33
flink-wander-standalonesession-0-localhost.out
-rw-r--r-- 1 wander staff 38220 5 5 04:34
flink-wander-taskexecutor-0-localhost.log
-rw-r--r-- 1 wander staff 0 5 5 04:33
flink-wander-taskexecutor-0-localhost.out
➜ log git:(master) cat flink-wander-client-localhost.log
2018-05-05 04:34:19,210 INFO org.apache.flink.client.cli.CliFrontend
-
--------------------------------------------------------------------------------
2018-05-05 04:34:19,212 INFO org.apache.flink.client.cli.CliFrontend
- Starting Command Line Client (Version: 1.6-SNAPSHOT,
Rev:5ac4d29, Date:04.05.2018 @ 22:03:32 CST)
2018-05-05 04:34:19,212 INFO org.apache.flink.client.cli.CliFrontend
- OS current user: wander
2018-05-05 04:34:19,732 INFO org.apache.flink.client.cli.CliFrontend
- Current Hadoop/Kerberos user: wander
2018-05-05 04:34:19,733 INFO org.apache.flink.client.cli.CliFrontend
- JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation -
1.8/25.144-b01
2018-05-05 04:34:19,733 INFO org.apache.flink.client.cli.CliFrontend
- Maximum heap size: 1820 MiBytes
2018-05-05 04:34:19,733 INFO org.apache.flink.client.cli.CliFrontend
- JAVA_HOME:
/Library/Java/JavaVirtualMachines/jdk1.8.0_144.jdk/Contents/Home
2018-05-05 04:34:19,735 INFO org.apache.flink.client.cli.CliFrontend
- Hadoop version: 2.4.1
2018-05-05 04:34:19,735 INFO org.apache.flink.client.cli.CliFrontend
- JVM Options:
2018-05-05 04:34:19,735 INFO org.apache.flink.client.cli.CliFrontend
-
-Dlog.file=/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/log/flink-wander-client-localhost.log
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
-
-Dlog4j.configuration=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/log4j-cli.properties
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
-
-Dlogback.configurationFile=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/logback.xml
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- Program Arguments:
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- run
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- examples/streaming/SocketWindowWordCount.jar
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- --port
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- 9000
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
- Classpath:
:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-dist_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-python_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-shaded-hadoop2-uber-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/log4j-1.2.17.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar:::
2018-05-05 04:34:19,736 INFO org.apache.flink.client.cli.CliFrontend
-
--------------------------------------------------------------------------------
2018-05-05 04:34:19,744 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.address, localhost
2018-05-05 04:34:19,745 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.port, 6123
2018-05-05 04:34:19,745 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.heap.mb, 1024
2018-05-05 04:34:19,745 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.heap.mb, 1024
2018-05-05 04:34:19,745 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-05 04:34:19,746 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: parallelism.default, 1
2018-05-05 04:34:19,747 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: web.port, 8081
2018-05-05 04:34:20,132 INFO
org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set
to wander (auth:SIMPLE)
2018-05-05 04:34:20,175 INFO org.apache.flink.client.cli.CliFrontend
- Running 'run' command.
2018-05-05 04:34:20,193 INFO org.apache.flink.client.cli.CliFrontend
- Building program from JAR file
2018-05-05 04:34:20,320 WARN org.apache.flink.configuration.Configuration
- Config uses deprecated configuration key 'jobmanager.rpc.address'
instead of proper key 'rest.address'
2018-05-05 04:34:20,648 INFO org.apache.flink.runtime.rest.RestClient
- Rest client endpoint started.
2018-05-05 04:34:20,649 INFO org.apache.flink.client.cli.CliFrontend
- Starting execution of program
2018-05-05 04:34:20,650 INFO
org.apache.flink.client.program.rest.RestClusterClient - Starting
program in interactive mode (detached: false)
2018-05-05 04:34:21,542 INFO
org.apache.flink.client.program.rest.RestClusterClient - Submitting job
0a19ebf0165d91bd997b06ecc5a301f1 (detached: false).
2018-05-05 04:34:21,542 INFO
org.apache.flink.client.program.rest.RestClusterClient - Requesting blob
server port.
2018-05-05 04:34:22,224 INFO
org.apache.flink.client.program.rest.RestClusterClient - Uploading jar
files.
2018-05-05 04:34:22,261 INFO
org.apache.flink.client.program.rest.RestClusterClient - Submitting job
graph
➜ log git:(master) cat flink-wander-standalonesession-0-localhost.log
2018-05-05 04:33:59,413 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
--------------------------------------------------------------------------------
2018-05-05 04:33:59,416 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting
StandaloneSessionClusterEntrypoint (Version: 1.6-SNAPSHOT, Rev:5ac4d29,
Date:04.05.2018 @ 22:03:32 CST)
2018-05-05 04:33:59,416 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current
user: wander
2018-05-05 04:34:00,084 WARN org.apache.hadoop.util.NativeCodeLoader
- Unable to load native-hadoop library for your platform... using
builtin-java classes where applicable
2018-05-05 04:34:00,497 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current
Hadoop/Kerberos user: wander
2018-05-05 04:34:00,497 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: Java
HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.144-b01
2018-05-05 04:34:00,498 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Maximum heap
size: 981 MiBytes
2018-05-05 04:34:00,498 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JAVA_HOME:
/Library/Java/JavaVirtualMachines/jdk1.8.0_144.jdk/Contents/Home
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop
version: 2.4.1
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM Options:
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xms1024m
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xmx1024m
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
-Dlog.file=/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/log/flink-wander-standalonesession-0-localhost.log
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
-Dlog4j.configuration=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/log4j.properties
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
-Dlogback.configurationFile=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/logback.xml
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Program
Arguments:
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --configDir
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
--executionMode
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - cluster
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Classpath:
:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-dist_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-python_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-shaded-hadoop2-uber-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/log4j-1.2.17.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar:::
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
--------------------------------------------------------------------------------
2018-05-05 04:34:00,514 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Registered UNIX
signal handlers for [TERM, HUP, INT]
2018-05-05 04:34:00,540 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.address, localhost
2018-05-05 04:34:00,540 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.port, 6123
2018-05-05 04:34:00,540 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.heap.mb, 1024
2018-05-05 04:34:00,540 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.heap.mb, 1024
2018-05-05 04:34:00,540 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-05 04:34:00,541 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: parallelism.default, 1
2018-05-05 04:34:00,541 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: web.port, 8081
2018-05-05 04:34:00,561 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting
StandaloneSessionClusterEntrypoint.
2018-05-05 04:34:00,561 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install default
filesystem.
2018-05-05 04:34:00,590 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install
security context.
2018-05-05 04:34:00,694 INFO
org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set
to wander (auth:SIMPLE)
2018-05-05 04:34:00,740 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Initializing
cluster services.
2018-05-05 04:34:00,817 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Trying to start
actor system at localhost:6123
2018-05-05 04:34:03,268 INFO akka.event.slf4j.Slf4jLogger
- Slf4jLogger started
2018-05-05 04:34:03,519 INFO akka.remote.Remoting
- Starting remoting
2018-05-05 04:34:04,069 INFO akka.remote.Remoting
- Remoting started; listening on addresses
:[akka.tcp://flink@localhost:6123]
2018-05-05 04:34:04,114 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Actor system
started at akka.tcp://flink@localhost:6123
2018-05-05 04:34:04,137 WARN org.apache.flink.configuration.Configuration
- Config uses deprecated configuration key 'jobmanager.rpc.address'
instead of proper key 'rest.address'
2018-05-05 04:34:04,163 INFO org.apache.flink.runtime.blob.BlobServer
- Created BLOB server storage directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/blobStore-b8c122a4-ce47-4a88-a2fb-5bdd0fa9899c
2018-05-05 04:34:04,166 INFO org.apache.flink.runtime.blob.BlobServer
- Started BLOB server at 0.0.0.0:62256 - max concurrent requests:
50 - max backlog: 1000
2018-05-05 04:34:04,214 INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics
reporter configured, no metrics will be exposed/reported.
2018-05-05 04:34:04,237 INFO
org.apache.flink.runtime.dispatcher.FileArchivedExecutionGraphStore -
Initializing FileArchivedExecutionGraphStore: Storage directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/executionGraphStore-4245e28d-0153-49f2-b1bc-6dff9025f145,
expiration time 3600000, maximum cache size 52428800 bytes.
2018-05-05 04:34:04,391 INFO org.apache.flink.runtime.blob.TransientBlobCache
- Created BLOB cache storage directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/blobStore-08563911-253a-4e15-b11c-11dc4ad45981
2018-05-05 04:34:04,432 WARN org.apache.flink.configuration.Configuration
- Config uses deprecated configuration key 'jobmanager.rpc.address'
instead of proper key 'rest.address'
2018-05-05 04:34:04,434 WARN
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Upload
directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/flink-web-d8089de2-7a7c-45fb-bee7-764eccbe7783/flink-web-upload
does not exist, or has been deleted externally. Previously uploaded files are
no longer available.
2018-05-05 04:34:04,437 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Created
directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/flink-web-d8089de2-7a7c-45fb-bee7-764eccbe7783/flink-web-upload
for file uploads.
2018-05-05 04:34:04,455 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest
endpoint.
2018-05-05 04:34:06,016 INFO
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined
location of main cluster component log file:
/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/log/flink-wander-standalonesession-0-localhost.log
2018-05-05 04:34:06,017 INFO
org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined
location of main cluster component stdout file:
/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/log/flink-wander-standalonesession-0-localhost.out
2018-05-05 04:34:06,381 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint
listening at localhost:8081
2018-05-05 04:34:06,381 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
http://localhost:8081 was granted leadership with
leaderSessionID=00000000-0000-0000-0000-000000000000
2018-05-05 04:34:06,381 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend
listening at http://localhost:8081.
2018-05-05 04:34:06,465 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Starting RPC endpoint for
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
akka://flink/user/resourcemanager .
2018-05-05 04:34:06,613 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Starting RPC endpoint for
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/dispatcher .
2018-05-05 04:34:06,691 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
ResourceManager akka.tcp://flink@localhost:6123/user/resourcemanager was
granted leadership with fencing token 00000000000000000000000000000000
2018-05-05 04:34:06,693 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting
the SlotManager.
2018-05-05 04:34:06,737 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher
akka.tcp://flink@localhost:6123/user/dispatcher was granted leadership with
fencing token 00000000000000000000000000000000
2018-05-05 04:34:06,738 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all
persisted jobs.
2018-05-05 04:34:07,654 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Register
TaskManager fc29082c6860d199b5acbecedcd321f2 at the SlotManager.
2018-05-05 04:34:22,363 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job
0a19ebf0165d91bd997b06ecc5a301f1 (Socket Window WordCount).
2018-05-05 04:34:22,402 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Starting RPC endpoint for
org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_0 .
2018-05-05 04:34:22,422 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Initializing job Socket Window WordCount
(0a19ebf0165d91bd997b06ecc5a301f1).
2018-05-05 04:34:22,427 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Using restart strategy NoRestartStrategy for Socket Window
WordCount (0a19ebf0165d91bd997b06ecc5a301f1).
2018-05-05 04:34:22,445 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Starting RPC endpoint for
org.apache.flink.runtime.jobmaster.slotpool.SlotPool at
akka://flink/user/8cb943f6-45f1-479a-8fb4-5462f9b6ec2e .
2018-05-05 04:34:22,513 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers
via failover strategy: full graph restart
2018-05-05 04:34:22,548 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Running initialization on master for job Socket Window WordCount
(0a19ebf0165d91bd997b06ecc5a301f1).
2018-05-05 04:34:22,549 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Successfully ran initialization on master in 0 ms.
2018-05-05 04:34:22,606 INFO org.apache.flink.runtime.jobmaster.JobMaster
- No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880)
2018-05-05 04:34:22,624 INFO
org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager
runner for job Socket Window WordCount (0a19ebf0165d91bd997b06ecc5a301f1) was
granted leadership with session id 00000000-0000-0000-0000-000000000000 at
akka.tcp://flink@localhost:6123/user/jobmanager_0.
2018-05-05 04:34:22,626 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Starting execution of job Socket Window WordCount
(0a19ebf0165d91bd997b06ecc5a301f1)
2018-05-05 04:34:22,632 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Socket
Window WordCount (0a19ebf0165d91bd997b06ecc5a301f1) switched from state CREATED
to RUNNING.
2018-05-05 04:34:22,635 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Socket
Stream -> Flat Map (1/1) (1eda0dd264ee85000dac465e3a47a2d4) switched from
CREATED to SCHEDULED.
2018-05-05 04:34:22,655 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve
slot request, no ResourceManager connected. Adding as pending request
14ec8946b428b43ad0f5953fdd118c34
2018-05-05 04:34:22,660 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) switched from CREATED to SCHEDULED.
2018-05-05 04:34:22,667 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Attempting to register at ResourceManager
akka.tcp://flink@localhost:6123/user/resourcemanager
2018-05-05 04:34:22,673 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Resolved ResourceManager address, beginning registration
2018-05-05 04:34:22,673 INFO org.apache.flink.runtime.jobmaster.JobMaster
- Registration at ResourceManager attempt 1 (timeout=100ms)
2018-05-05 04:34:22,675 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registering job manager
[email protected]://flink@localhost:6123/user/jobmanager_0
for job 0a19ebf0165d91bd997b06ecc5a301f1.
2018-05-05 04:34:22,685 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
Registered job manager
[email protected]://flink@localhost:6123/user/jobmanager_0
for job 0a19ebf0165d91bd997b06ecc5a301f1.
2018-05-05 04:34:22,687 INFO org.apache.flink.runtime.jobmaster.JobMaster
- JobManager successfully registered at ResourceManager, leader id:
00000000000000000000000000000000.
2018-05-05 04:34:22,687 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting slot
with profile ResourceProfile\{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource
manager (request = 14ec8946b428b43ad0f5953fdd118c34).
2018-05-05 04:34:22,688 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request
slot with profile ResourceProfile\{cpuCores=-1.0, heapMemoryInMB=-1,
directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job
0a19ebf0165d91bd997b06ecc5a301f1 with allocation id
72280cb07ad40bab6a4fa6c5e38cb156.
2018-05-05 04:34:22,808 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Socket
Stream -> Flat Map (1/1) (1eda0dd264ee85000dac465e3a47a2d4) switched from
SCHEDULED to DEPLOYING.
2018-05-05 04:34:22,808 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying
Source: Socket Stream -> Flat Map (1/1) (attempt #0) to localhost
2018-05-05 04:34:22,821 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:34:22,822 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(attempt #0) to localhost
2018-05-05 04:34:23,016 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) switched from DEPLOYING to RUNNING.
2018-05-05 04:34:23,135 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Socket
Stream -> Flat Map (1/1) (1eda0dd264ee85000dac465e3a47a2d4) switched from
DEPLOYING to RUNNING.
➜ log git:(master) cat flink-wander-taskexecutor-0-localhost.log
2018-05-05 04:33:59,799 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
--------------------------------------------------------------------------------
2018-05-05 04:33:59,801 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting
TaskManager (Version: 1.6-SNAPSHOT, Rev:5ac4d29, Date:04.05.2018 @ 22:03:32 CST)
2018-05-05 04:33:59,801 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - OS current
user: wander
2018-05-05 04:34:00,113 WARN org.apache.hadoop.util.NativeCodeLoader
- Unable to load native-hadoop library for your platform... using
builtin-java classes where applicable
2018-05-05 04:34:00,497 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Current
Hadoop/Kerberos user: wander
2018-05-05 04:34:00,497 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - JVM: Java
HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.144-b01
2018-05-05 04:34:00,498 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Maximum heap
size: 922 MiBytes
2018-05-05 04:34:00,498 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - JAVA_HOME:
/Library/Java/JavaVirtualMachines/jdk1.8.0_144.jdk/Contents/Home
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Hadoop
version: 2.4.1
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - JVM Options:
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - -XX:+UseG1GC
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - -Xms922M
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - -Xmx922M
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
-XX:MaxDirectMemorySize=8388607T
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
-Dlog.file=/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/log/flink-wander-taskexecutor-0-localhost.log
2018-05-05 04:34:00,509 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
-Dlog4j.configuration=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/log4j.properties
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
-Dlogback.configurationFile=file:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf/logback.xml
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Program
Arguments:
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - --configDir
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/conf
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Classpath:
:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-dist_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-python_2.11-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/flink-shaded-hadoop2-uber-1.6-SNAPSHOT.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/log4j-1.2.17.jar:/Users/wander/Documents/Apocalypse/repos/flink/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar:::
2018-05-05 04:34:00,510 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner -
--------------------------------------------------------------------------------
2018-05-05 04:34:00,514 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Registered UNIX
signal handlers for [TERM, HUP, INT]
2018-05-05 04:34:00,525 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Maximum number
of open file descriptors is 10240.
2018-05-05 04:34:00,534 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.address, localhost
2018-05-05 04:34:00,534 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.port, 6123
2018-05-05 04:34:00,534 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.heap.mb, 1024
2018-05-05 04:34:00,535 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.heap.mb, 1024
2018-05-05 04:34:00,535 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2018-05-05 04:34:00,535 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: parallelism.default, 1
2018-05-05 04:34:00,536 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: web.port, 8081
2018-05-05 04:34:00,750 INFO
org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set
to wander (auth:SIMPLE)
2018-05-05 04:34:01,759 WARN org.apache.flink.configuration.Configuration
- Config uses deprecated configuration key 'jobmanager.rpc.address'
instead of proper key 'rest.address'
2018-05-05 04:34:01,781 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-05 04:34:01,782 INFO
org.apache.flink.runtime.util.LeaderRetrievalUtils - TaskManager
will try to connect for 10000 milliseconds before falling back to heuristics
2018-05-05 04:34:01,797 INFO org.apache.flink.runtime.net.ConnectionUtils
- Retrieved new target address localhost/127.0.0.1:6123.
2018-05-05 04:34:02,222 INFO org.apache.flink.runtime.net.ConnectionUtils
- Trying to connect to address localhost/127.0.0.1:6123
2018-05-05 04:34:02,223 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address 'localhost/127.0.0.1': Connection
refused (Connection refused)
2018-05-05 04:34:02,226 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:02,228 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,228 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,229 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,229 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,230 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,230 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,231 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,231 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,231 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,232 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,232 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:02,233 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:02,233 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:02,233 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:02,233 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:02,234 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,235 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,235 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,236 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,236 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,236 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,236 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,237 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,237 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,237 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,238 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:02,238 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:02,238 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:02,238 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:02,239 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:02,641 INFO org.apache.flink.runtime.net.ConnectionUtils
- Trying to connect to address localhost/127.0.0.1:6123
2018-05-05 04:34:02,642 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address 'localhost/127.0.0.1': Connection
refused (Connection refused)
2018-05-05 04:34:02,646 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:02,648 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,648 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,649 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,649 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,650 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,650 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,651 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,651 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,652 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,653 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,654 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:02,654 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:02,655 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:02,655 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:02,655 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:02,656 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,657 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,657 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,657 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,658 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,658 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,658 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,658 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,659 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,659 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:02,659 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:02,660 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:02,660 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:02,661 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:02,661 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:03,463 INFO org.apache.flink.runtime.net.ConnectionUtils
- Trying to connect to address localhost/127.0.0.1:6123
2018-05-05 04:34:03,464 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address 'localhost/127.0.0.1': Connection
refused (Connection refused)
2018-05-05 04:34:03,465 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:03,465 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,466 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,466 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,466 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,467 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,467 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,467 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,468 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,468 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,468 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,468 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:03,468 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:03,469 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:03,469 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:03,469 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:03,470 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:7936:534d:6a84:1c2c%utun2': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,470 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:6440:2b67:8931:e2ba%utun1': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,470 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:cc86:d814:4302:69b6%utun0': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,471 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:44d6:ddff:fe87:17ea%awdl0': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,471 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:d9a0:3309:1bdc:8d55': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,471 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:4016:bdaa:6a0b:7450': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,471 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:444a:8608:4ae9:f171': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,472 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:f010:d2bb:bf51:6472': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,472 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:3981:bd57:ff87:d449': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,472 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/2001:da8:201:3512:819:1182:911b:5ae4': Can't assign requested address
(connect failed)
2018-05-05 04:34:03,472 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address
'/fe80:0:0:0:845:898a:6fca:e9a3%en0': Can't assign requested address (connect
failed)
2018-05-05 04:34:03,473 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/10.2.15.163': Connection refused
(Connection refused)
2018-05-05 04:34:03,473 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/fe80:0:0:0:0:0:0:1%lo0': Can't
assign requested address (connect failed)
2018-05-05 04:34:03,473 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/0:0:0:0:0:0:0:1': Can't assign
requested address (connect failed)
2018-05-05 04:34:03,474 INFO org.apache.flink.runtime.net.ConnectionUtils
- Failed to connect from address '/127.0.0.1': Connection refused
(Connection refused)
2018-05-05 04:34:05,078 INFO org.apache.flink.runtime.net.ConnectionUtils
- Trying to connect to address localhost/127.0.0.1:6123
2018-05-05 04:34:05,079 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - TaskManager
will use hostname/address 'localhost' (127.0.0.1) for communication.
2018-05-05 04:34:05,079 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Starting
AkkaRpcService at localhost:0.
2018-05-05 04:34:05,973 INFO akka.event.slf4j.Slf4jLogger
- Slf4jLogger started
2018-05-05 04:34:06,111 INFO akka.remote.Remoting
- Starting remoting
2018-05-05 04:34:06,337 INFO akka.remote.Remoting
- Remoting started; listening on addresses
:[akka.tcp://flink@localhost:62258]
2018-05-05 04:34:06,374 INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics
reporter configured, no metrics will be exposed/reported.
2018-05-05 04:34:06,386 INFO org.apache.flink.runtime.blob.PermanentBlobCache
- Created BLOB cache storage directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/blobStore-f0523648-8e39-4745-9700-685419bcc7a4
2018-05-05 04:34:06,392 INFO org.apache.flink.runtime.blob.TransientBlobCache
- Created BLOB cache storage directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/blobStore-ff6dad56-2dd9-4df2-9089-ca46865bf5f5
2018-05-05 04:34:06,412 INFO
org.apache.flink.runtime.io.network.netty.NettyConfig - NettyConfig
[server address: localhost/127.0.0.1, server port: 0, ssl enabled: false,
memory segment size (bytes): 32768, transport type: NIO, number of server
threads: 1 (manual), number of client threads: 1 (manual), server connect
backlog: 0 (use Netty's default), client connect timeout (sec): 120,
send/receive buffer size (bytes): 0 (use Netty's default)]
2018-05-05 04:34:06,497 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file
directory '/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T': total 464 GB,
usable 220 GB (47.41% usable)
2018-05-05 04:34:06,613 INFO
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 102
MB for network buffer pool (number of memory segments: 3278, bytes per segment:
32768).
2018-05-05 04:34:06,816 INFO
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.
2018-05-05 04:34:06,817 INFO
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.
2018-05-05 04:34:06,822 INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Starting the
network environment and its components.
2018-05-05 04:34:06,898 INFO
org.apache.flink.runtime.io.network.netty.NettyClient - Successful
initialization (took 57 ms).
2018-05-05 04:34:06,939 INFO
org.apache.flink.runtime.io.network.netty.NettyServer - Successful
initialization (took 41 ms). Listening on SocketAddress /127.0.0.1:62259.
2018-05-05 04:34:06,944 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Limiting
managed memory to 0.7 of the currently free heap space (641 MB), memory will be
allocated lazily.
2018-05-05 04:34:06,964 INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager
uses directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/flink-io-aa1398ab-99b1-44f4-ba10-172bb23495af
for spill files.
2018-05-05 04:34:07,061 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messages have
a max timeout of 10000 ms
2018-05-05 04:34:07,097 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
- Starting RPC endpoint for
org.apache.flink.runtime.taskexecutor.TaskExecutor at
akka://flink/user/taskmanager_0 .
2018-05-05 04:34:07,132 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Attempting to
register at ResourceManager
akka.tcp://flink@localhost:6123/user/resourcemanager
(00000000000000000000000000000000)
2018-05-05 04:34:07,133 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Start job
leader service.
2018-05-05 04:34:07,137 INFO org.apache.flink.runtime.filecache.FileCache
- User file cache uses directory
/var/folders/kn/3cmyzc1d6j13kfj5nsbdbcr00000gn/T/flink-dist-cache-a7e9bd87-95df-4f8b-bed7-f6f3df1ed350
2018-05-05 04:34:07,540 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved
ResourceManager address, beginning registration
2018-05-05 04:34:07,541 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at
ResourceManager attempt 1 (timeout=100ms)
2018-05-05 04:34:07,676 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful
registration at resource manager
akka.tcp://flink@localhost:6123/user/resourcemanager under registration id
fc29082c6860d199b5acbecedcd321f2.
2018-05-05 04:34:22,694 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot
request 72280cb07ad40bab6a4fa6c5e38cb156 for job
0a19ebf0165d91bd997b06ecc5a301f1 from resource manager with leader id
00000000000000000000000000000000.
2018-05-05 04:34:22,697 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot
for 72280cb07ad40bab6a4fa6c5e38cb156.
2018-05-05 04:34:22,697 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job
0a19ebf0165d91bd997b06ecc5a301f1 for job leader monitoring.
2018-05-05 04:34:22,701 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register
at job manager akka.tcp://flink@localhost:6123/user/jobmanager_0 with leader id
00000000-0000-0000-0000-000000000000.
2018-05-05 04:34:22,719 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved
JobManager address, beginning registration
2018-05-05 04:34:22,721 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at
JobManager attempt 1 (timeout=100ms)
2018-05-05 04:34:22,747 INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful
registration at job manager akka.tcp://flink@localhost:6123/user/jobmanager_0
for job 0a19ebf0165d91bd997b06ecc5a301f1.
2018-05-05 04:34:22,749 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish
JobManager connection for job 0a19ebf0165d91bd997b06ecc5a301f1.
2018-05-05 04:34:22,755 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved
slots to the leader of job 0a19ebf0165d91bd997b06ecc5a301f1.
2018-05-05 04:34:22,756 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot
72280cb07ad40bab6a4fa6c5e38cb156.
2018-05-05 04:34:22,893 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
Source: Socket Stream -> Flat Map (1/1).
2018-05-05 04:34:22,894 INFO org.apache.flink.runtime.taskmanager.Task
- Source: Socket Stream -> Flat Map (1/1)
(1eda0dd264ee85000dac465e3a47a2d4) switched from CREATED to DEPLOYING.
2018-05-05 04:34:22,895 INFO org.apache.flink.runtime.taskmanager.Task
- Creating FileSystem stream leak safety net for task Source:
Socket Stream -> Flat Map (1/1) (1eda0dd264ee85000dac465e3a47a2d4) [DEPLOYING]
2018-05-05 04:34:22,903 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task Source: Socket Stream -> Flat Map
(1/1) (1eda0dd264ee85000dac465e3a47a2d4) [DEPLOYING].
2018-05-05 04:34:22,909 INFO org.apache.flink.runtime.blob.BlobClient
- Downloading
0a19ebf0165d91bd997b06ecc5a301f1/p-359eb43f04888ff6e2453f086964b44e957fdce5-c3a34fd1df71991fc420b8cd41c0e9ab
from localhost/127.0.0.1:62256
2018-05-05 04:34:22,923 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1).
2018-05-05 04:34:22,923 INFO org.apache.flink.runtime.taskmanager.Task
- Window(TumblingProcessingTimeWindows(5000),
ProcessingTimeTrigger, ReduceFunction$1, PassThroughWindowFunction) -> Sink:
Print to Std. Out (1/1) (c91a7366d8a89f65f2cbc0326d7d778d) switched from
CREATED to DEPLOYING.
2018-05-05 04:34:22,924 INFO org.apache.flink.runtime.taskmanager.Task
- Creating FileSystem stream leak safety net for task
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) [DEPLOYING]
2018-05-05 04:34:22,924 INFO org.apache.flink.runtime.taskmanager.Task
- Loading JAR files for task
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) [DEPLOYING].
2018-05-05 04:34:22,931 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network:
Window(TumblingProcessingTimeWindows(5000), ProcessingTimeTrigger,
ReduceFunction$1, PassThroughWindowFunction) -> Sink: Print to Std. Out (1/1)
(c91a7366d8a89f65f2cbc0326d7d778d) [DEPLOYING].
2018-05-05 04:34:22,931 INFO org.apache.flink.runtime.taskmanager.Task
- Registering task at network: Source: Socket Stream -> Flat Map
(1/1) (1eda0dd264ee85000dac465e3a47a2d4) [DEPLOYING].
2018-05-05 04:34:23,005 INFO org.apache.flink.runtime.taskmanager.Task
- Window(TumblingProcessingTimeWindows(5000),
ProcessingTimeTrigger, ReduceFunction$1, PassThroughWindowFunction) -> Sink:
Print to Std. Out (1/1) (c91a7366d8a89f65f2cbc0326d7d778d) switched from
DEPLOYING to RUNNING.
2018-05-05 04:34:23,048 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880)
2018-05-05 04:34:23,132 INFO org.apache.flink.runtime.taskmanager.Task
- Source: Socket Stream -> Flat Map (1/1)
(1eda0dd264ee85000dac465e3a47a2d4) switched from DEPLOYING to RUNNING.
2018-05-05 04:34:23,135 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880)
2018-05-05 04:34:23,150 WARN org.apache.flink.metrics.MetricGroup
- The operator name Window(TumblingProcessingTimeWindows(5000),
ProcessingTimeTrigger, ReduceFunction$1, PassThroughWindowFunction) exceeded
the 80 characters length limit and was truncated.
2018-05-05 04:34:23,251 INFO
org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction -
Connecting to server socket localhost:9000
2018-05-05 04:34:23,271 INFO
org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing
heap keyed state backend with stream factory.
```
Since out files contains no result, there must be something wrong. Is this run
properly on your local environment? I'd like to know whether it is an issue
about my environment.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
