Re: Flink 1.2.1 JobManager Election Deadlock

2019-06-12 Thread Mar_zieh
Dear guys Hello I have cluster of three physical nodes with docker installed on each of them. I configured Mesos,Hadoop,Marathon and Zookeeper;they were run without any problems. Then, I ran a Flink application on Marathon. After that, I could open Flink UI on firefox. I tested a program on Flink

Running Flink on Marathon

2019-04-28 Thread Mar_zieh
I have three physical nodes with docker installed on them. I have one docker container with Mesos, Marathon, Hadoop and Flink. I configured Master node and Slave nodes for Mesos,Zookeeper and Marathon. I do these works step by step. First, In Master node, I enter to docker container with this comma

Re: Taskmanager unable to rejoin job manager

2019-04-25 Thread Mar_zieh
Hello I want to run flink on apache Mesos with Marathon and I configure Zookeeper too; so I run "mesos-appmaster.sh"; but it shows me this error: 2019-04-25 13:53:18,160 INFO org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager - Mesos resource manager started. 2019-04-25 13:5

Command exited with status 1 in running Flink on marathon

2019-03-03 Thread Mar_zieh
I want to run my flink program on Mesos cluster via marathon. I created an application with this Json file in Marathon: { "id": "flink", "cmd": "/home/flink-1.7.0/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.task

Re: Automate Job submission with container

2019-03-03 Thread Mar_zieh
I want to run my flink program on Mesos cluster via marathon. I created an application with this Json file in Marathon: { "id": "flink", "cmd": "/home/flink-1.7.0/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.tasks.me

Re: Automate Job submission with container

2019-03-03 Thread Mar_zieh
I want to run my flink program on Mesos cluster via marathon. I created an application with this Json file in Marathon: { "id": "flink", "cmd": "/home/flink-1.7.0/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.tasks.me

Re: Automate Job submission with container

2019-03-03 Thread Mar_zieh
I want to run my flink program on Mesos cluster via marathon. I created an application with this Json file in Marathon: { "id": "flink", "cmd": "/home/flink-1.7.0/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.tasks.me

Re: Run Time Exception

2018-11-15 Thread Mar_zieh
Hello guys I have wrote this code. I could print the whole file, but I want to read the file line by line and process each line separately. would you please help how I can do that? ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment(); DataSet transactions = env.readTe

Re: Run Time Exception

2018-11-15 Thread Mar_zieh
Hello guys I have wrote this code. I could print the whole file, but I want to read the file line by line and process each line separately. would you please help how I can do that? ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment(); DataSet transactions = env.readTe

cannot find symbol of "fromargs"

2018-10-24 Thread Mar_zieh
Hello I am new in Flink. I want to write a program in stream processing. I added this line to my program: ParameterTool mmm = new ParameterTool.fromArgs(args); But I got this error: cannot find symbol of "fromargs" would you please let me know how to solve this error? Thank you in advance.

Re: Can't start cluster

2018-10-15 Thread Mar_zieh
Hello I have two question, would you please answer to me? Please tell me "what is "pyflink.bat" for?" Does Flink support python or not? Moreover, I want to have multiprocessing with Flink on windows. Is it possible? Thank you in advance -- Sent from: http://apache-flink-user-mailing-list-ar

Re: Can't start cluster

2018-10-15 Thread Mar_zieh
Hello I have two question, would you please answer to me? Please tell me "what is "pyflink.bat" for?" Does Flink support python or not? Moreover, I want to have multiprocessing with Flink on windows. Is it possible? Thank you in advance -- Sent from: http://apache-flink-user-mailing-list-ar

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: 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 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: Can't access Flink Dashboard at 8081, running Flink program using Eclipse

2018-09-03 Thread Mar_zieh
Hello I added these dependencies to "pom.xml"; also, I added configuration to my code like these: Configuration config = new Configuration(); config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true); StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(getP,

Re: FoldFunction accumulator checkpointing

2018-09-01 Thread Mar_zieh
Hello I wrote example of "Monitoring the Wikipedia Edit Stream" in Intellij Idea, but I got errors on "acc.f0 , acc.f1" which was like this: Error:(39, 28) java: cannot find symbol symbol: variable f0 location: variable acc of type scala.Tuple2 Would you please tell me how to solve this pr