Re: I want run flink program in ubuntu x64 Mult Node Cluster what is configuration?

2018-09-30 Thread Mar_zieh
I run "sudo /start-cluster.sh" but I got this error: sudo: /start-cluster.sh : command not found. Would you please tell me for just one node, is it necessary to configure it? Thank you -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Regarding implementation of aggregate function using a ProcessFunction

2018-09-30 Thread Gaurav Luthra
Hi ken, Mine is very generic use case. Means I am building an aggregation function using flink, which can be configured according to any use case. Actually, It will not be for a specific use case and every user can enter their business logic and use this aggregator to get result. And about windowi

Re: I want run flink program in ubuntu x64 Mult Node Cluster what is configuration?

2018-09-30 Thread Mar_zieh
Hello I run "start-cluster.bat" on windows very easy and it works fine. Even though, when I run "start-cluster.sh" on terminal of Ubuntu, I get these errors: Starting cluster. ./start-cluster.sh: line 48: /home/pooya/IdeaProjects/flink-1.6.0/bin/jobmanager.sh: Permission denied /home/pooya/IdeaP

Re: I want run flink program in ubuntu x64 Mult Node Cluster what is configuration?

2018-09-30 Thread miki haiat
The easiest way to tun it without adding user and root permission is to run it with *sudo command* *sudo /start-cluster.sh* If you want to run high availability cluster you need to follow those instruction [1] 1. https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/jobmanager_high_a

Re: I want run flink program in ubuntu x64 Mult Node Cluster what is configuration?

2018-09-30 Thread Mar_zieh
Hello I run "start-cluster.bat" on windows very easy and it works fine. Even though, when I run "start-cluster.sh" on terminal of ubuntu, I get these errors: Starting cluster. ./start-cluster.sh: line 48: /home/pooya/IdeaProjects/flink-1.6.0/bin/jobmanager.sh: Permission denied /home/pooya/IdeaP

Re: In-Memory Lookup in Flink Operators

2018-09-30 Thread Chirag Dewan
Thanks Lasse, that is rightly put. That's the only solution I can think of too. Only thing which I can't get my head around is using the coMap and coFlatMap functions with such a stream. Since they dont support side outputs, is there a way my lookup map/flatmap function simply consume a stream?