Re: Can't start cluster

2018-10-15 Thread vino yang 
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 Beam Python SDK + Flink Runner, which seems to be a better choice.

You can let Flink run on windnows (JVM is cross-platform), but it is not
recommended, it is recommended to run on unix/linux.

Thanks, vino.

Mar_zieh  于2018年10月15日周一 下午9:07写道：

> 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-archive.2336050.n4.nabble.com/
>

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-archive.2336050.n4.nabble.com/

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-archive.2336050.n4.nabble.com/

Re: Can't start cluster

2017-09-14 Thread AndreaKinn 
SOLVED using binaries.



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Can't start cluster

2017-09-14 Thread AndreaKinn 
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/

Re: Can't start cluster

2017-09-13 Thread AndreaKinn 
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@giordano-2-2-100-1:~$ 



Eron Wright wrote
> 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-SNAPSHOT/
> 
> Please refer to the updated instructions in Flink 1.3 documentation for
> more information:
> https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/cluster_setup.html
> https://ci.apache.org/projects/flink/flink-docs-release-1.3/quickstart/setup_quickstart.html
> 
> 
> On Wed, Sep 13, 2017 at 6:57 AM, AndreaKinn 

> kinn6aer@

>  wrote:
> 
>> 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
>> stop-cluster.shtaskmanager.sh
>> flink.bat  historyserver.sh  pyflink.sh start-local.sh   
>> stop-local.sh
>> zookeeper.sh
>>
>>
>>
>> --
>> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
>> n4.nabble.com/
>>





--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Can't start cluster

2017-09-13 Thread Eron Wright 
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-SNAPSHOT/

Please refer to the updated instructions in Flink 1.3 documentation for
more information:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/cluster_setup.html
https://ci.apache.org/projects/flink/flink-docs-release-1.3/quickstart/setup_quickstart.html


On Wed, Sep 13, 2017 at 6:57 AM, AndreaKinn  wrote:

> 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
> stop-cluster.shtaskmanager.sh
> flink.bat  historyserver.sh  pyflink.sh start-local.shstop-local.sh
> zookeeper.sh
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>

Re: Can't start cluster

2017-09-13 Thread AndreaKinn 
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  
stop-cluster.shtaskmanager.sh
flink.bat  historyserver.sh  pyflink.sh start-local.shstop-local.sh 

zookeeper.sh



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/