1. 云栖社区>
  2. 全部标签>
  3. #并行度#
并行度

#并行度#

已有0人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

在 Flink 算子中使用多线程如何保证不丢数据?

本人通过分析痛点、同步批量请求优化为异步请求、多线程 Client 模式、Flink 算子内多线程实现以及总结四部分帮助大家理解 Flink 中使用多线程的优化及在 Flink 算子中使用多线程如何保证不丢数据。

大数据 线程 数据处理 同步 API string exception 多线程 void 流计算 kafka checkpoint flink 算子 并行度

1
GO