This repository has examples for Apache flink.
sbt clean package
Load the project into eclipse or IntelliJ to run
Flink Examples
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
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.