Hi Mar_zieh,
For questions about Python, you can ask Chesnay, I try to answer.
Pyflink.bat is a script for running Flink programs for flink-python*.jar.
You can see the implementation of it. Flink supports Jython.
Also, if Python is your main programming language, you can try using the
Apache Bea
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
SOLVED using binaries.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Just a question:
>From download page I have to download binaries or source package?
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I followed the guide to install flink on the cluster but no one target folder
appears in /flink-dist
> giordano@giordano-2-2-100-1:~/flink-1.3.2/flink-dist$ ls
> pom.xml src
Actually there are no results finding target folder
> giordano@giordano-2-2-100-1:~$ find . -name target
> giordano@giorda
It appears that you're building Flink from source, and attempting to start
the cluster from the 'flink-dist/src/...' directory. Please use
'flink-dist/target/...' instead since that's where the built distribution
is located. For example, check:
flink-dist/target/flink-1.4-SNAPSHOT-bin/flink-1.4
I printed also /flink-bin/bin folder:
> root@giordano-2-2-100-1:~/flink-1.3.2/flink-dist/src/main/flink-bin/bin#
> ls
> config.sh flink-console.sh jobmanager.sh start-cluster.sh
> start-zookeeper-quorum.sh stop-zookeeper-quorum.sh
flink flink-daemon.sh pyflink.batstart-local.bat
Hi,
I'm trying to deploy on a flink cluster the jar of my program.
Unfortunately I have a problem when I call on the first node:
> root@giordano-2-2-100-1:~# sudo
> ./flink-1.3.2/flink-dist/src/main/flink-bin/bin/start-cluster.sh
> Starting cluster.
> find: ‘/home/giordano/flink-1.3.2/flink-dist/s
