It seams the problem is with running WordCount.jar. I could run KMeans.jar
without any problems. May be I’ve passed the arguments incorrect.
bin/flink run ./examples/flink-java-examples-0.9-SNAPSHOT-WordCount.jar
file://'pwd'/hemlet.txt file://'pwd'/wordcount-result.txt
> On Feb 22, 2015, at 9
I can’t see any problems there. Can you? Do I need hadoop libraries?
20:59:30,832 INFO org.apache.flink.runtime.jobmanager.JobManager
- Starting JobManager
20:59:31,255 INFO akka.event.slf4j.Slf4jLogger
- Slf4jLogger started
20:59:31,306 INFO R
Hi,
can you have a look at the jobmanager log file in the "log/" directory? I
suspect there was an issue when you've started the JobManager.
On Sun, Feb 22, 2015 at 4:35 PM, Dulaj Viduranga
wrote:
> I tried to run an example program to the first time in FLINK and I got
> this error. I have alre
I tried to run an example program to the first time in FLINK and I got this
error. I have already started FLINK with bin/start-local.sh. Can someone please
help?
21:01:19,898 WARN org.apache.hadoop.util.NativeCodeLoader
- Unable to load native-hadoop library for your plat
