Zookeeper+Kafka集群部署 kafka: kafka_2.11-2.2.0.tar.gzzookeeper: zookeeper-3...
Hive時間轉(zhuǎn)換 用到hive時間轉(zhuǎn)換總結(jié)如下: 轉(zhuǎn)換成小時 req_time是 "2016-11-29 17:47:59"要轉(zhuǎn)換成小時"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中查詢粒度設(shè)置為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...