準備spark環境：

linux啟動Spark本地模式（Local模式）_怪只怪滿眼盡是人間煙火-CSDN博客首先安裝java環境下載spark：wget https://archive.apache.org/dist/spark/spark-2.3.0/spark-2.3.0-bin-hadoop2.7.tgz創建解析文件：mkdir /opt/inputcd /opt/input/touch wenjian.txt文件中輸入測試內容：hello azhello spark金庸防火墻：CentOS7systemctl stop firewalldCentOShttps://qushen.blog.csdn.net/article/details/122997521

下載 seatunnel：

wget https://github.com/InterestingLab/seatunnel/releases/download/v1.5.7/seatunnel-1.5.7.zip -O seatunnel-1.5.7.zip

解壓，并采用軟連接重命名：

unzip seatunnel-1.5.7.zip ln -s seatunnel-1.5.7.zip seatunnel

編輯 config/seatunnel-env.sh, 指定必須環境配置如SPARK_HOME

編輯 config/application.conf, 它決定了seatunnel啟動后，數據輸入，處理，輸出的方式和邏輯。

spark {# seatunnel defined streaming batch duration in secondsspark.streaming.batchDuration = 5spark.app.name = "seatunnel"spark.ui.port = 13000 }input {socketStream {} }filter {split {fields = ["msg", "name"]delimiter = ","} }output {stdout {} }

重啟啟動一個窗口，啟動netcat server用于發送數據，輸入：

nc -l -p 9999

啟動seatunnel

./bin/start-seatunnel.sh --master local[4] --deploy-mode client --config ./config/application.conf

?然后，切換到netcat server那個窗口，發送數據：

Hello World, Gary

seatunnel日志打印出:

總結

以上是生活随笔為你收集整理的Apache seaTunnel的本地启动的全部內容，希望文章能夠幫你解決所遇到的問題。

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