Flink 1.4.2的安裝
依賴需求
- Java 1.8.0
- Scala code runner version 2.11.2
- Hadoop2.7
配置安裝
首先解壓安裝包flink-1.4.2-bin-hadoop27-scala_2.11.tgz
|
[[email protected] conf]# tar -xvzf flink-1.4.2-bin-hadoop27-scala_2.11.tgz |
然後建立軟連線
|
[[email protected] hadoop]# ln -s flink-1.4.2 flink |
最後，在/etc/profile最後面新增如下環境變數：
|
#set flink export FLINK_HOME=/opt/software/hadoop/flink export PATH=$FLINK_HOME/bin:$PATH |
使之生效：source /etc/profile
啟動
|
[[email protected]]# start-local.sh |
日誌
|
[[email protected]]# tail /opt/software/hadoop/flink/log/flink-*-jobmanager-*.log |
關閉
|
|
檢視&測試
啟動Flink後，可以用jps命令檢視TaskManager程序是否存在。
啟動命令列
啟動任務
|
flink run examples/streaming/SocketWindowWordCount.jar --port 9999 |
檢視結果
在一個視窗中輸入資訊：
|
[[email protected]# ~]# nc -l 9999 |
另外一個視窗檢視日誌結果：
|
|
常見問題
1 org.apache.flink.client.program.ProgramInvocationException: Neither a 'Main-Class', nor a 'program-class' entry was found in the jar file.
原因：命令列引數錯誤
解決：調整引數位置
flink run -c myMain myApp.jar
flink run -c myMain.class myApp.jar
flink run -c myMain.scala myApp.jar
flink run -c my.package.myMain myApp.jar
flink run -c my.package.myMain.class myApp.jar
flink run -c my.package.myMain.scala myApp.jar
相關推薦
Flink 1.4.2的安裝
依賴需求 Java 1.8.0 Scala code runner version 2.11.2 Hadoop2.7 配置安裝 首先解壓安裝包flink-1.4.2-bin-hadoop27-scala_2.11.tgz [[email pro
Flink 1.4.2 版本踩過的坑
0x1 摘要 最近業務要實時統計半小時維度的UV、PV資料，經過調研準備用Flink時間窗來實現，主要是Flink對eventTime的支援，可以做到更精準的統計，由於第一次嘗試使用Flink，所以過程中遇到不少問題，記錄下來方便後續查閱。 0x2 執行計劃輸出JSON問題 Flink對
elasticsearch2.4.2安裝(1)
es1. 解壓elasticsearch.2.4.2；3個節點 2. 修改config/elasticsearch.yml (註意要頂格寫，冒號後面要加一個空格) NIE-00: 192.168.1.100 a)cluster.name: ns-cluster (同一集群要一樣)b)node.na
VS2017 + CUDA 9.2 + CUDNN 7.1.4 + tensorflow 安裝
h5py with floating blank col 進行 ima inf height 參照步驟：https://blog.csdn.net/weixin_42359147/article/details/80622306 坑：安裝完成後 import tensor
keepalived-1.4.2實踐：安裝與測試
一、下載安裝1、作業系統：CentOS 7.4，先確保安裝了openssl，安裝方法： yum -y install openssl-devel沒有OpenSSL的話，configure會報錯： !!! OpenSSL is not properly installed on
Ubuntu 18.04 + CUDA 9.2 + cuDNN 7.1.4 + Caffe2 安裝
安裝Ubuntu 18.04 Ubuntu 18.04的安裝參考官網步驟，很容易安裝。我在安裝的時候比較坎坷，拿到了一個有問題的U盤，寫入ISO後，啟動一直啟動不了。 主要步驟如下： 1. 下載系統。 2. 下載Rufus工具，也可以是其他的，只要能燒錄
Mac下安裝Flink的local模式（flink-1.0.2）
1.本地執行 下載 進入下載頁面。如果你想讓Flink與Hadoop進行互動（如HDFS或者HBase），請選擇一個與你的Hadoop版本相匹配的Flink包。當你不確定或者只是想執行在本地檔案系統上，請選擇Hadoop 1.2.x對應的包。 2.環境
在RedHat9.0下安裝Subversion 1.4.2
使用了多年的CVS，苦來酸甜都嚐遍。一直垂涎subversion，卻沒有機會。而今機緣巧合得以在部門內推廣subversion， 不亦悅乎。因部門開發需要使用RedHat9.0，伺服器一直使用這個版本的linux沒有升級。9.0自帶的subversion版本太低(0.17.1
jQuery treeTable v 1.4.2
ica select angularjs ron tree repeat style cond 4.2 angularJs版本： 如圖所示即為treeTable的效果，三個紅色框每個微一級 外科>骨科>骨科一病區 html： <table class=
【轉】Poco 1.4.2 HTTPClientSession/HTTPRequest 使用使用代理(proxy)需要註意的一點
方法 xxx and aid csdn 代理 ref cpp logs Poco 1.4.2 HTTPClientSession/HTTPClientSession 在使用代理的時候，request的URI不能包含協議和主機。否則會出錯。 不使用代理的時候，以下代碼能正
1.4.2 暫停與恢復Activity
devel 過程 信號 fun ide 然而 -a 動作 好的 在正常使用app時，前端的activity有時會被其他可見的組件阻塞(obstructed)，從而導致當前的activity進入Pause狀態。例如，當打開一個半透明的activity時(例如以對話框的形式)，
Unity Shaders and Effects Cookbook (4-1)(4-2)靜態立方體貼圖的創建與使用
sampler lba into 現實生活 rate valid ase pro 執行 開始學習第4章 - 著色器的反射看完了1、2節，來記錄一下。反射主要是利用了 Cubemap 立方體貼圖。認識Cubemap立方體貼圖。就如同名字所說。在一個立方體上有6張圖。就這樣
V-4-2 安裝vCenter組件
vcenter加載vCenter的安裝映像。並且運行光盤下的autorun.exe。出現如下畫面，選擇vCenter Single Sign-On（以下簡稱為SSO）點擊安裝。安裝SSO如下圖設置SSO帳號密碼，這個帳號重要。下圖的表示SSO的帳號用戶名為[email protected]
k8s 1.5.2 安裝腳本
ride sed baseurl x86 x86_64 1.5 exit nbsp pro 1 #!/bin/bash 2 export RED=‘\E[1;31m‘ 3 export RES=‘\E[0m‘ 4 export GRN=‘\E[1;32m‘
elasticsearch2.4.2安裝(2) --插件marvel
es1. online install : 執行 bin/elasticsearch install licencebin/elasticsearch install marvel-agent 2. offline install 2.1 首先下載 licence：license-2.4.4.zipma
從零開始搭建系統1.4——MySql安裝及配置
get com class sql安裝 lan mysql安裝 ref logs sql 從零開始搭建系統1.4——MySql安裝及配置從零開始搭建系統1.4——MySql安裝及配置
1.4.2
for threesum sta 1.4 ID std import nbsp mod question: Modify ThreeSum to work properly even when the int values are so large that adding
1.4.2埋點JS實現
track.js //函式可對字串進行編碼，防止中文亂碼 function jt_encode(str){ //進行URL編碼 return encodeURI(str); } //螢幕解析度 function jt_get_screen(){ var c = ""; if (self
Hollong 低功耗藍芽4.0/4.1/4.2 BLE Sniffer協議分析儀
名稱：緯圖Hollong BLE藍芽 監控分析儀 品牌：ViewTool/緯圖 型號：VTH201A 典型應用： - 抓取BLE藍芽傳輸資料，分析資料傳輸協議； - 實時捕獲、顯示、分析、過濾協議資料，減少除錯時間，加速產品進入市場； - 協助開發除錯BLE相關
Hollong 藍芽4.0/4.1/4.2 BLE協議監控分析儀
品牌：ViewTool/緯圖型號：VTH201A 典型應用： - 抓取BLE藍芽傳輸資料，分析資料傳輸協議； - 協助開發除錯BLE相關軟體，韌體； - 實時捕獲、顯示、解析、過濾和偵測協議錯誤，減少除錯時間，加速產品進入市場； - 幫助學習BLE藍芽傳輸協議； &nb