Re: 向您请教pyflink在windows上运行的问题，我第一次接触flink。

[jincheng sun]

很高兴收到您的邮件，我不太确定您具体看的是哪一个视频，所以很难确定您遇到的问题原因。您可以参考官方文档[1],
同时我个人博客里有一些3分钟的视频和文档入门教程[2]，您可以先查阅一下。如又问题，可以保持邮件沟通，可以在我的博客留言！

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/tutorials/python_table_api.html
[2] https://enjoyment.cool/

Best,
Jincheng



xu1990xaut <[hidden email]> 于2020年3月24日周二 下午11:36写道：

> 您好，之前在哔哩哔哩上看过您讲的视频。  也跟着视频动手做了。
> 我用的flink1.10，在pip的时候是直接pip install apache-flink，结果默认就是1.10版本。
> 然后我在pycharm中运行word-count这个脚本时，一直不出结果，也不报错。   请问这是什么原因。
> 我也装了jdk，另外页面访问flink8081那个端口也可以出来界面。  我是第一次接触flink，在网上也搜过这个问题，
> 可是一直没有得到答案。  麻烦您，给小弟指点指点，   谢谢您了。
>
>
>
>

[jincheng sun]

上面视频中对应的word_count示例的源码应该是这个：
https://github.com/sunjincheng121/enjoyment.code/blob/master/myPyFlink/enjoyment/word_count.py运行完成之后计算结果应该是写到sink_file
= 'sink.csv'文件里面去了。你可以将这个文件的路径打印出来，查看这个文件内容。

另外如果您只是为了学习入门的话，建议你查阅[1][2], 我让想整理了解PyFlink最新的状况，可以查看[3]。

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/python/installation.html
[2]
https://enjoyment.cool/2020/01/22/Three-Min-Series-How-PyFlink-does-ETL/#more
[3]
https://www.bilibili.com/video/BV1W7411o7Tj?from=search&seid=14518199503613218690

Best,
Jincheng
-------------
Twitter: https://twitter.com/sunjincheng121
-------------


xu1990xaut <[hidden email]> 于2020年3月25日周三 下午2:23写道：

> 孙老师您好，我之前在网上看的是这个视频《【Apache Flink 进阶教程】14课. Apache Flink Python API
> 的现状及未来规划》。 今天我也在虚拟机下试了，还是无法运行。
> 我用的是flink1.10，python3.6。  麻烦老师指点指点。
>
>
>
>
>
>
> 在 2020-03-25 11:32:29，"jincheng sun" <[hidden email]> 写道：
>
> 很高兴收到您的邮件，我不太确定您具体看的是哪一个视频，所以很难确定您遇到的问题原因。您可以参考官方文档[1],
> 同时我个人博客里有一些3分钟的视频和文档入门教程[2]，您可以先查阅一下。如又问题，可以保持邮件沟通，可以在我的博客留言！
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/tutorials/python_table_api.html
> [2] https://enjoyment.cool/
>
> Best,
> Jincheng
>
>
>
> xu1990xaut <[hidden email]> 于2020年3月24日周二 下午11:36写道：
>
>> 您好，之前在哔哩哔哩上看过您讲的视频。  也跟着视频动手做了。
>> 我用的flink1.10，在pip的时候是直接pip install apache-flink，结果默认就是1.10版本。
>> 然后我在pycharm中运行word-count这个脚本时，一直不出结果，也不报错。   请问这是什么原因。
>> 我也装了jdk，另外页面访问flink8081那个端口也可以出来界面。  我是第一次接触flink，在网上也搜过这个问题，
>> 可是一直没有得到答案。  麻烦您，给小弟指点指点，   谢谢您了。
>>
>>
>>
>>
>
>
>
>

[jincheng sun]

第一行错误信息是没有安装 bash ？

xu1990xaut <[hidden email]> 于2020年3月26日周四 下午12:12写道：

孙老师，我按照您视频里的方法把flink包安装好了。  但是运行您提供得demo时出现下面这个错误。  我在网上找了好久还是没解决。 望老师再指点指点。

在 2020-03-25 15:47:49，"jincheng sun" <[hidden email]> 写道：

哦，PyFlink目前不支持windows。

Best,

Jincheng

-------------

Twitter: https://twitter.com/sunjincheng121

-------------

xu1990xaut <[hidden email]> 于2020年3月25日周三 下午2:55写道：

谢谢孙老师。   我用的就是这个示例。    另外我看到python下又两个flink版本，一个是import flink，一个是import pyflink。 pyflink是不是不能在windows下运行？  

python下的flink我确定是安装正确的。    运行flink是也启动了start-cluster.bat（start-clust.sh），但是pycharm控制台很久不出结果，cpu的占用率也正常。 

我实在不知道是哪里问题。   

在 2020-03-25 14:44:25，"jincheng sun" <[hidden email]> 写道：

上面视频中对应的word_count示例的源码应该是这个： https://github.com/sunjincheng121/enjoyment.code/blob/master/myPyFlink/enjoyment/word_count.py运行完成之后计算结果应该是写到sink_file = 'sink.csv'文件里面去了。你可以将这个文件的路径打印出来，查看这个文件内容。

另外如果您只是为了学习入门的话，建议你查阅[1][2], 我让想整理了解PyFlink最新的状况，可以查看[3]。

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/python/installation.html

[2] https://enjoyment.cool/2020/01/22/Three-Min-Series-How-PyFlink-does-ETL/#more

[3] https://www.bilibili.com/video/BV1W7411o7Tj?from=search&seid=14518199503613218690

Best,

Jincheng

-------------

Twitter: https://twitter.com/sunjincheng121

-------------

xu1990xaut <[hidden email]> 于2020年3月25日周三 下午2:23写道：

孙老师您好，我之前在网上看的是这个视频《【Apache Flink 进阶教程】14课. Apache Flink Python API 的现状及未来规划》。 今天我也在虚拟机下试了，还是无法运行。  

我用的是flink1.10，python3.6。  麻烦老师指点指点。

在 2020-03-25 11:32:29，"jincheng sun" <[hidden email]> 写道：

很高兴收到您的邮件，我不太确定您具体看的是哪一个视频，所以很难确定您遇到的问题原因。您可以参考官方文档[1], 同时我个人博客里有一些3分钟的视频和文档入门教程[2]，您可以先查阅一下。如又问题，可以保持邮件沟通，可以在我的博客留言！

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/tutorials/python_table_api.html

[2] https://enjoyment.cool/

Best,

Jincheng

xu1990xaut <[hidden email]> 于2020年3月24日周二 下午11:36写道：

您好，之前在哔哩哔哩上看过您讲的视频。  也跟着视频动手做了。   

我用的flink1.10，在pip的时候是直接pip install apache-flink，结果默认就是1.10版本。 

然后我在pycharm中运行word-count这个脚本时，一直不出结果，也不报错。   请问这是什么原因。 

我也装了jdk，另外页面访问flink8081那个端口也可以出来界面。  我是第一次接触flink，在网上也搜过这个问题，

可是一直没有得到答案。  麻烦您，给小弟指点指点，   谢谢您了。