Zookeeper+Kafka集群部署 kafka: kafka_2.11-2.2.0.tar.gzzookeeper: zookeeper-3...
Hive時間轉換 用到hive時間轉換總結如下: 轉換成小時 req_time是 "2016-11-29 17:47:59"要轉換成小時"201...
Flink實現(xiàn)Kafka到Mysql的Exactly-Once 背景 最近項目中使用Flink消費kafka消息,并將消費的消息存儲到mysql...
Blink First Time & Flink-sql 背景 blink開源契耿,目前在https://github.com/apache/fli...
python訪問hdfs(namenode是HA) 背景 本文記錄用python訪問hdfs瞒大,hdfs有兩個namenode HA模式。主要有h...
python字符串如何判斷相等 1.is來判斷 2.id 和 in 看到用in可以判斷兩個字符串相等 參考:https://blog.csdn....
Druid-Tranquility中查詢粒度設置為5分鐘 背景 我們知道可以通過tranquility從kafka讀取數(shù)據(jù)寫入druid做聚合搪桂,...
checkPoint簡介 為了保證state的容錯性透敌,F(xiàn)link需要對state進行checkpoint。 Checkpoint是Flink實現(xiàn)...
Flink JobManager HA高可用 概述 本文主要講解下Flink standalone下JobManager的HA高可用和Flink...