最新在线上更新了代码之后导致了任务在消费kafka数据的时候,突然就不消费数据了,发现原因在公司的可视化界面中,看不到数据的更新,进入flink监控页面中看到任务没有fail...
发简信
IP属地：上海
-
记录Flink1.9线上checkpoint失败的问题 -
Clickhouse集群搭建
clickhouse官网,也会有集群搭建的内容[https://clickhouse.tech/docs/en/] 搭建前的准备 配置好防火墙以及搭建好zookeeper,这...
-
Spark 连接kafka两种方式及区别(direct和receiver)Kafka Direct 跟Receiver方式的区别 Receiver Receiver是使用Kafka的 High-Level Consumer API来实现的。Rece...
-
Flink-1.10 源码笔记 两阶段提交Flink源码分析 -- 两阶段提交 先简单了解一下处理语义 关于消息的消费、处理语义可以分为三类： 1. at most once : 至多一次，表示一条消息不管后续...
-
Flink sql使用中报错问题以及解决Flink sql 报错问题以及解决 记录在使用Flink sql时出现的问题以及解决方式 1.时间戳问题 消费kafka数据,转换成一个DataStream后,通过tabl...
-
Hadoop - YARNYARN - 资源管理 Hadoop -MapReduceHadoop -HDFS 导读一. Hadoop 1.x 介绍二. Hadoop 2.x 介绍 - 重点三. yar...
-
Hadoop - HDFSHDFS 分布式文件系统 Hadoop -YARNHadoop -MapReduce 导读1.HDFS是什么2.HDFS架构及组件功能介绍3.读写流程 HDFS是什么 HD...