简介 Spring Cloud Ribbon是一个基于HTTP和TCP的客户端负载均衡工具，它基于Netflix Ribbon实现。通过Spring Cloud的封装，可以让...
发简信
IP属地：北京
-
-
coding........
-
Flink Job 调度[toc] 介绍 Flink 是如何调度 Job，以及如何在 JobManager 上维护并跟踪 Job 状态。 调度 Flink 通过任务槽（Task slot）定义执行资...
-
Flink Checkpoint 和 Large State 调优Overview 为了使 Flink 应用程序能够可靠地大规模运行，必须满足两个条件： 应用程序需要能够可靠地获取 Checkpoint 在发生故障后，需要足够的资源追上（c...
-
Flink State 和 Fault Tolerance（四）
State Snapshot 定义 Snapshot – 是 Flink 作业状态全局一致镜像的通用术语。快照包括指向每个数据源的指针（例如，到文件或 Kafka 分区的偏移...
-
Flink State 和 Fault Tolerance（三）
[toc] Savepoint Savepoint 和 Checkpoint 的区别 Savepoint 是命令触发的 Checkpoint，对流式程序做一次完整的快照并将结...
-
Flink Side Outputs
Side Output 功能从 Flink 1.3.0 版本开始提供，FLINK-4460[https://issues.apache.org/jira/browse/FLI...
-
Flink State 和 Fault Tolerance（二）Checkpoint Flink 中的 State 在上一篇中介绍过，Flink 中的每个方法或算子都能够是有状态的，为了使 State 容错，需要为 State 创建 ch...
-
Flink State 和 Fault Tolerance（一）
Overview 有状态函数（Stateful function）和算子（Operator）在处理独立的数据或事件时存储数据，使得状态（State）成为任何复杂算子中的关键部...
-
Flink EventTime 和 Watermark（1.13）时间概念 时间在流式计算中起很重要的作用，Flink 提供了3种时间模型：EventTime、ProcessingTime、IngestionTime（1.13 版本已经不再...
-
Flink User-defined Source & Sink主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/so...
-
Flink Metrics主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/ops/metri...
-
Flink SQL Connector（二）- JDBC & Hive
JDBC 更详细信息参考 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connecto...
-
Flink SQL Connector（一）- Format & Kafka
Format Flink 提供了一套与表连接器（table connector）一起使用的表格式（table format）。表格式是一种存储格式，定义了如何把二进制数据映射...
-
Flink SQL Query 语法（四）- Rattern Recognition
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sq...
-
Flink SQL Query 语法（三）- Join
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sq...
-
Flink SQL Query 语法（二）
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sq...
-
Flink SQL Query 语法（一）
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sq...
-
Flink SQL Create 语法
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sq...
-
Flink Table & SQL 时间属性
主要引用官方文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/co...
