痛点：假如我们在FLink的WebUI Metrics页面发现有一个SubTask每秒处理的数据明显比其他低，又或者在CheckPoint页面，发现有一个SubTask的Ch...
发简信
IP属地：广东
-
Flink如何快速定位SubTask在哪台机器哪个进程中执行 -
Flink 流流关联( Interval Join)总结
Flink对流流JOIN的支持 Flink对于join的支持有多种支持，可参考 Flink Join类型， 本文主要讨论Time interval join支持Table A...
-
Kafka+Spark Streaming如何保证exactly once语义在Kafka、Storm、Flink、Spark Streaming等分布式流处理系统中（没错，Kafka本质上是流处理系统，不是单纯的“消息队列”），存在三种消息传递语义（...
-
离线部署 Cloudera Manager 5 和 CDH 5.12.1 及使用 CDH 部署 Hadoop 集群服务历时一天半，着实废了不少功夫。整个搭建过程，是参考这篇文章和大神的部署文档。 一、系统环境配置 前提是/etc/hostname已经修改过了。并且要注意，hostname中不...
-
今日头条Go建千亿级微服务的实践
今日头条当前后端服务超过80%的流量是跑在 Go 构建的服务上。微服务数量超过100个，高峰 QPS 超过700万，日处理请求量超过3000亿，是业内最大规模的 Go 应用。...
-
MySQL binlog 增量数据解析服务MySQL binlog 增量数据解析服务 介绍如何借助于 MySQL 的 Master-slave 协议实现 MySQL 增量数据获取服务 1. 起因 做过后端开发的同学都...
