flink為各種儲存系統（如kafka，kinesis，elasticsearch和jdbc資料庫系統）提供了豐富的聯結器。
它還具有連續的檔案系統源，用於監視以時間分割槽方式寫入檔案的目錄和接收器
如果kafka版本為0.8或者0.9
匯入flink-connector-kafka-0.8_2.11-1.6.1.jar/flink-connector-kafka-0.9_2.11-1.6.1.jar
和flink-connector-kafka-base_2.11-1.6.1.jar 即可。
如果kafka版本為0.10
出去flink-connector-kafka-0.10_2.11-1.6.1.jar 和flink-connector-kafka-base_2.11-1.6.1.jar以外，還需要匯入乙個老版本的(比如flink-connector-kafka-0.9_2.11-1.6.1.jar)才可以
如果是水印（事件時間場景），則方法processwatermark將會被呼叫
Flink狀態管理儲存
state一般指乙個具體的task operator的狀態。而checkpoint則表示了乙個flink job，在乙個特定時刻的乙份全域性狀態快照，即包含了所有task operator的狀態。儲存機制 statebackend 狀態後端 預設情況下，state 會儲存在 taskmanager ...
此篇為各種感悟各種吐槽
may 呵呵 我是乙個水貨acmer.3.19 其實我是很想上去的，我就暗暗對自己說，別再像高中一樣害怕提問，害怕丟臉.大學，也不去想太多的神馬浮雲神馬，只希望能改變一些高中的劣習.具體來說不就是神馬害怕提問，考試心態有時激動，拼命的在乎自己的言論.也因此有了自己的性格，也或者有了某些成績或某些結果...
為各種主機環境程式設計
由於windows環境本身的特性，有很多因素隨使用者偏愛或配置而不同。下列因素會影響發 布到其他計算機的應用程式 螢幕解析度和顏色濃度。字型。windows版本。輔助應用程式。dll位置。一 螢幕解析度和顏色濃度 windows桌面的大小和計算機上可用的顏色數是可配置的並依賴於安裝的硬體。在開發程 ...