1.文档编写目的 SQL Stream Builder(SSB)是Cloudera提供的基于Flink-SQL的实时流计算Web开发平台，它提供了一个交互式的Flink SQL编辑器，让用户可以方便的使用SQL访问一个source比如Kafka中的数据写入到一个sink比如Hiv...

维表关联系列目录:一、维表服务与Flink异步IO二、Mysql维表关联：全量加载三、Hbase维表关联：LRU策略四、Redis维表关联：实时查询五、kafka维表关联：广播方式六、自定义异步查询...

作者：董伟柯，腾讯 CSIG 高级工程师 综述 Flink 作为流式数据处理框架的领跑者，在吞吐量、时延、准确型、容错性等方面都有优异的表现。在 API 方面，它为用户提供了较底层的 DataStream API，也推出了 Table API 和 SQL 等编...

在Flink实战系列之自定义RetractStreamTableSink中介绍了如何编写自定义RetractStreamTableSink，Flink 中提供了另外一种可Redo模式的UpsertStreamTableSink，与RetractStreamTableSink不同的是：...

一、两阶段提交概述二、两阶段提交实现分析三、StreamingFileSink分析四、事务性输出实现五、最终一致性实现

flink exactly-once系列目录：一、两阶段提交概述二、两阶段提交实现分析三、StreamingFileSink分析四、事务性输出实现五、最终一致性实现前几篇分析到Flink 是可以通过状态与checkpoint机制实现内部Exactly-Once 的语...

一、两阶段提交概述二、两阶段提交实现分析三、StreamingFileSink分析四、事务性输出实现五、最终一致性实现

flink任务日志指的是任务系统日志与用户代码里面log方式打印的日志，这些日志信息都可以在flink web页面上看到，目前任务的部署模式都是on yarn, 那么在yarn页面也可以看到，这些日志信息在开发环境或者测试环境量都是很小...

在【两阶段提交概述】中介绍了两阶段提交的基本思路以及如何根据checkpoint机制来实现两阶段提交思路，flink给出来两阶段提交抽象实现TwoPhaseCommitSinkFunction与具体实现FlinkKafkaProducer011。...

二、TwoPhaseCommitSinkFunction与FlinkKafkaProducer源码分析