I have built Flink from source. I find that the executables are all at:
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?
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.