參考[1],但是官方文檔有些簡略,還是需要消化一下才行

?

①cd?/home/appleyuchi/bigdat

②git clone?https://gitee.com/mirrors/apache-flink.git

③打開下面的路徑:

④pip install flake8

⑤Settings->External Tools

上面就是官方文檔的意思了,這么操作下來根本沒法運行.

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

我們繼續嘗試[4]

?

右鍵選擇Mark Directory as->Sources Root

python -m pip install apache-flink(pycharm里面也是搜索這個)

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

提前在/home/appleyuchi/桌面/source.csv寫入

enjoyment,Apache Flink,cool,Apache Flink

運行的代碼:

https://gitee.com/appleyuchi/PyFlink/blob/master/wordcount.py

實驗運行結果在上述代碼文件的統一路徑下面生成sink.csv

cat sink.csv

Apache Flink,2
cool,1
enjoyment,1

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

命令行運行pyflink的方式則是:

$FLINK_HOME/bin/flink run -py /home/appleyuchi/桌面/實驗/wordcount.py

Reference:

[1]Importing Flink into an IDE

[2]PyCharm搭建Spark開發環境 + 第一個pyspark程序

[3]pycharm not updating with environment variables

[4]Apache Flink 說道系列- Python Table API 開發環境搭建

總結

以上是生活随笔為你收集整理的Pycharm中配置Pyflink的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。