Flink使用shell終端(local模式)

2021-09-29 22:03:07 字數 878 閱讀 8829

-l 開啟監聽模式,用於指定nc將處於監聽模式。通常這樣代表著為乙個服務等待客戶端來鏈結指定的介面。

-p 《通訊埠》:設定本地主機使用的通訊埠。有可能會關閉。

flink附帶了乙個整合的互動式scala shell,它可以在本地模式和群集模式中使用。通過flink的scala-shell終端程式可以快速上手flink,並可以對簡單的flink任務進行除錯和測試。類似於spark的shell終端。

要將shell與整合的flink集群一起使用,只需執行:bin/start-scala-shell.sh local。該命令整合了flink的執行環境,所以不需要啟動flink集群。

scala shell支援batch和streaming。啟動後會自動預先繫結兩個不同的執行環境。可以使用』benv』和』senv』變數來分別訪問batch和streaming環境。

./start-scala-shell.sh –help

檢視幫助資訊,該命令支援remote和yarn集群模式,並且可以通過該命令來新增外部依賴的jar包。

./start-scala-shell.sh local

print()命令會自動將指定的任務傳送到jobmanager執行,並在終端中顯示計算結果。

也可以將結果寫入檔案。但是,在這種情況下,就需要呼叫execute,來執行程式:

benv.execute.(「myprogram」)

注:只有local模式下才會把輸出列印到終端,若是集群模式將不會列印到終端。

注:在streaming環境下,列印操作不會直接觸發執行。

shell 終端的各種使用特性

q 不要列印script started script end 的資訊 下面這條命令 可以保證在登入了遠端shell的情況下,首先執行一段自定義命令,然後保持輸入輸出不關閉 echo echo yes cat dev tty script dev null ssh d其核心就是中間的cat命令使用了...

Shell 終端列印

參考書籍 linux shell 指令碼攻略 能夠執行列印的方法有很多,格式也各不相同,主要有如下幾個 echo printf echo命令 echo是用於終端列印的基本命令。預設情況下,echo在每次呼叫後會新增乙個換行符。可使用標誌 n來忽略結尾的換行符。可接受雙引號字串內的轉義序列作為引數,採...

shell終端的快捷方式的使用

一 自動補齊 tab 這個技巧很多人都應該會了,就是當輸入命令,目錄或者是檔名的時候按 tab 鍵。系統就會幫你補齊可能要輸入的東西,如果有多個選擇系統會列表出來。你可以看清楚之後再多輸入乙個或多個 charactor 再按 tab 實驗 ec 按 tab 補齊為 echo 二 查詢和執行歷史命令 ...