发简信
IP属地：上海
-
Zookeeper+Kafka集群部署
Zookeeper+Kafka集群部署 kafka: kafka_2.11-2.2.0.tar.gzzookeeper: zookeeper-3...
-
Hive时间转换
Hive时间转换 用到hive时间转换总结如下: 转换成小时 req_time是 "2016-11-29 17:47:59"要转换成小时"201...
-
Flink实现Kafka到Mysql的Exactly-OnceFlink实现Kafka到Mysql的Exactly-Once 背景 最近项目中使用Flink消费kafka消息，并将消费的消息存储到mysql...
-
Blink First Time & Flink-sqlBlink First Time & Flink-sql 背景 blink开源，目前在https://github.com/apache/fli...
-
python访问hdfs(namenode是HA)python访问hdfs(namenode是HA) 背景 本文记录用python访问hdfs，hdfs有两个namenode HA模式。主要有h...
-
python字符串如何判断相等
python字符串如何判断相等 1.is来判断 2.id 和 in 看到用in可以判断两个字符串相等 参考：https://blog.csdn....
-
Druid-Tranquility中查询粒度设置为5分钟Druid-Tranquility中查询粒度设置为5分钟 背景 我们知道可以通过tranquility从kafka读取数据写入druid做聚合，...
-
Flink状态（state）管理在代码里配置checkpointcheckPoint简介 为了保证state的容错性，Flink需要对state进行checkpoint。 Checkpoint是Flink实现...
-
Flink JobManager HA高可用Flink JobManager HA高可用 概述 本文主要讲解下Flink standalone下JobManager的HA高可用和Flink...