Flink run指定save point时,任务启动失败
-
Flink standalone session cluster 安装与配置
Flink standalone session cluster 安装与配置
-
Flink清洗Nginx日志
FLink 清洗 nginx request log and reponse log
-
使用 Apache Curator 实现 ZooKeeper 分布式锁
使用 Apache ZooKeeper 作为分布式协调服务,结合 Apache Curator 客户端库实现分布式锁,通过 InterProcessMutex 管理锁的获取与释放,并附真实测试日志与主备切换场景分析。
-
Zookeeper遇到网络异常log
Zookeeper遇到网络异常出现的log
-
FlinkJob GeoLite2 Guide
Flink 使用GeoLite2实时解析IP的Geolocation Info.
-
Flink Quick Start With Command
Flink 通过shell command ,快速创建项目。
-
Flink job query data form clickhouse
在基于Clickhouse实时数仓架构中,部分需求需要使用Flink Job的MapFunction 以及 UDF 中读取Clickhouse数据.
-
Kafka公网通信的安全问题--Kafka broker配置PLAINTEXT和SASL_SSL双协议
在多云数据处理/同步的场景下,需要对Kafka通信数据进行加密和身份认证保证安全。Kafka broker 配置多协议混合, 内网使用PLAINTEXT协议, 公网使用SASL_SSL
-
Hexo blog site start and deploy github pages
配置Hexo blog , 并deploy github pages