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

?

①cd?/home/appleyuchi/bigdat

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

③打開下面的路徑:

④pip install flake8

⑤Settings->External Tools

上面就是官方文檔的意思了,這么操作下來(lái)根本沒法運(yùn)行.

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

我們繼續(xù)嘗試[4]

?

右鍵選擇Mark Directory as->Sources Root

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

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

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

enjoyment,Apache Flink,cool,Apache Flink

運(yùn)行的代碼:

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

實(shí)驗(yàn)運(yùn)行結(jié)果在上述代碼文件的統(tǒng)一路徑下面生成sink.csv

cat sink.csv

Apache Flink,2
cool,1
enjoyment,1

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

命令行運(yùn)行pyflink的方式則是:

$FLINK_HOME/bin/flink run -py /home/appleyuchi/桌面/實(shí)驗(yàn)/wordcount.py

Reference:

[1]Importing Flink into an IDE

[2]PyCharm搭建Spark開發(fā)環(huán)境 + 第一個(gè)pyspark程序

[3]pycharm not updating with environment variables

[4]Apache Flink 說(shuō)道系列- Python Table API 開發(fā)環(huán)境搭建

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。