RE: Table API Compilation Error in Flink

Hi Xingcan, I have included the below portion in my pom.xml. Still the same error is coming. org.apache.flink flink-streaming-scala_2.11 1.4.0 Regards, Nagananda M From: Xingcan Cui [mailto:xingc...@gmail.com] Sent: Monday, March 05, 2018 1:01 PM To: Nagananda M C

Re: Table API Compilation Error in Flink

Hi Nagananda, adding `flink-streaming-scala_${scala version}` to your maven dependency would solve this. Best, Xingcan > On 5 Mar 2018, at 2:21 PM, Nagananda M wrote: > > Hi All, > Am trying to compile a sample program in apache flink using TableEnvironment > and facing some issue in compi

Table API Compilation Error in Flink

Hi All, Am trying to compile a sample program in apache flink using TableEnvironment and facing some issue in compilation for the addition of the below line. "StreamTableEnvironment tableEnv = StreamTableEnvironment.getTableEnvironment(env);" The error is as below "cannot access org.apache.flin

Task Slots allocation

I am using flink 1.4.0 in standalone cluster mode I have a job with a graph like a Source(parallelism 3) -> Filter(parallelism 3) -> Map(parallelism 1) -> sink(parallelism 3) As per the understanding, max number of tasks slots should be bounded by the max parallelism, which in this case is 3. Th

bin/start-cluster.sh won't start jobmanager on master machine

Hi all, ​​When I execute bin/start-cluster.sh on the master machine, actually the command `nohup /bin/bash -l bin/jobmanager.sh start cluster ...` is exexuted, which does not open the job manager properly. I think there might be something wrong with the `-l` argument, since when I use the `bin/jo

Akka wants to connect with username "flink"

Hey there, For my master thesis I'm trying to set up a flink standalone cluster on 4 nodes. I've worked along the documentation which pretty neatly explains how to set it up. But when I start the cluster there is a warning and when I'm trying to run a job, there is an error with the same messag