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实现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读取数据写入druid做聚合,...
checkPoint简介 为了保证state的容错性,Flink需要对state进行checkpoint。 Checkpoint是Flink实现...
Flink JobManager HA高可用 概述 本文主要讲解下Flink standalone下JobManager的HA高可用和Flink...