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
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
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
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
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
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
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
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
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
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.
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
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
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/
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
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
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,
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
17 matches
Mail list logo