Flink gurus!
I have built Flink from source. I find that the executables are all at:
<workspace>/flink-dist/target/flink-1.6-SNAPSHOT-bin/flink-1.6-SNAPSHOT.
However, when I try to run start-scala-shell.sh local from the bin subfolder of this folder, it does not seem to run the simple wordcount example. Am I doing it right? How else do people test out the distribution of the Flink sources that the have just built?
Regards,
Kedar
PS- A tentative thread dump on JobManager shows that many threads are just waiting on some condition variable. Appears like a livelock. The task manager has one main thread which is also waiting.