phatak-dev / flink-examples Goto Github PK

I have run using following command. sbt "run-main com.madhukaraphatak.flink.streaming.examples.StreamingWordCount", I got following error message. Could you help me to resolve this

(base) C02PD1HNG3QD:flink-examples sureshs$ sbt "run-main com.madhukaraphatak.flink.streaming.examples.StreamingWordCount"
[info] Loading project definition from /Users/sureshs/Documents/source/phatak-dev-flink-examples/flink-examples/project
[info] Set current project to flink-examples (in build file:/Users/sureshs/Documents/source/phatak-dev-flink-examples/flink-examples/)
[info] Running com.madhukaraphatak.flink.streaming.examples.StreamingWordCount
log4j:WARN No appenders could be found for logger (org.apache.flink.api.scala.ClosureCleaner$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
06/22/2019 16:18:37 Job execution switched to status RUNNING.
06/22/2019 16:18:38 Source: Socket Stream(1/1) switched to SCHEDULED
06/22/2019 16:18:38 Source: Socket Stream(1/1) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(1/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(1/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(2/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(2/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(3/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(3/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(4/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(4/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(5/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(5/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(6/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(6/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(7/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(7/8) switched to DEPLOYING
06/22/2019 16:18:38 Flat Map -> Map(8/8) switched to SCHEDULED
06/22/2019 16:18:38 Flat Map -> Map(8/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(1/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(1/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(2/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(2/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(3/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(3/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(4/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(4/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(5/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(5/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(6/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(6/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(7/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(7/8) switched to DEPLOYING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(8/8) switched to SCHEDULED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(8/8) switched to DEPLOYING
06/22/2019 16:18:38 Source: Socket Stream(1/1) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(1/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(1/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(3/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(7/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(2/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(6/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(5/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(8/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(2/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(3/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(4/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(5/8) switched to RUNNING
06/22/2019 16:18:38 Flat Map -> Map(4/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(6/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(7/8) switched to RUNNING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(8/8) switched to RUNNING
06/22/2019 16:18:38 Source: Socket Stream(1/1) switched to FAILED
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:96)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:748)

06/22/2019 16:18:38 Flat Map -> Map(5/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(7/8) switched to CANCELED
06/22/2019 16:18:38 Job execution switched to status FAILING.
java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:96)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:748)
06/22/2019 16:18:38 Flat Map -> Map(1/8) switched to CANCELING
06/22/2019 16:18:38 Flat Map -> Map(6/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(8/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(4/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(3/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(2/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(1/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(2/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(3/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(4/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(5/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(6/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(7/8) switched to CANCELING
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(8/8) switched to CANCELING
06/22/2019 16:18:38 Flat Map -> Map(1/8) switched to CANCELED
06/22/2019 16:18:38 Flat Map -> Map(2/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(1/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(2/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(3/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(4/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(7/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(8/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(5/8) switched to CANCELED
06/22/2019 16:18:38 aggregation -> Sink: Unnamed(6/8) switched to CANCELED
06/22/2019 16:18:38 Job execution switched to status FAILED.
[error] (run-main-0) org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:714)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:96)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:748)
[trace] Stack trace suppressed: run last compile:runMain for the full output.
java.lang.RuntimeException: Nonzero exit code: 1
at scala.sys.package$.error(package.scala:27)
[trace] Stack trace suppressed: run last compile:runMain for the full output.
[error] (compile:runMain) Nonzero exit code: 1
[error] Total time: 2 s, completed 22 Jun, 2019 4:18:38 PM