Run time error

Open suresh-s opened this issue 6 years ago • 0 comments

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

Jun 22 '19 10:06 suresh-s