阿里云文档 2025-01-17

Sink变更兼容性

本文为您介绍Sink变更的可兼容性和不可兼容性详情。

问答 2024-11-30 来自:开发者社区

flink的sink算子,一直都有部分task处于初始化阶段,但是如果用print打印则能正常运行

flink在sink时,总有几个sink的task处于初始化阶段,即使把sink的并行度设为1,还是会处于初始化阶段

阿里云文档 2024-07-10

SQL变更的其他兼容性限制

本文为您介绍变更SQL除Query、Source和Sink之外的其他限制。

问答 2024-01-17 来自:开发者社区

Flink的 Sink 算子初始化时间过长 导致 ck 超时 这个有什么配置可以优化吗?

Flink的 Sink 算子初始化时间过长 导致 ck 超时 这个有什么配置可以优化吗?

问答 2023-06-29 来自:开发者社区

大佬们,我们有个Flink场景,根据数据中带的tag写入到不同sink中,同时sink的初始化是根?

大佬们,我们有个Flink场景,根据数据中带的tag写入到不同sink中,同时sink的初始化是根据外部存储动态生成的,这个有解决方案吗?

问答 2023-06-04 来自:开发者社区

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原?

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原因?他这个tm日志一直再刷ProducerId,是是什么意思?

问答 2022-10-24 来自:开发者社区

flink kafkasink sink一致初始化起不来 有什么好的解决或者检查的办法么?

flink kafkasink sink一致初始化起不来 有什么好的解决或者检查的办法么?

问答 2020-05-25 来自:开发者社区

当flink job中存在两个sink分别为mysql和phoenix。在初始化获取jd#Flink

当flink job中存在两个sink分别为mysql和phoenix。在初始化获取jdbc连接时遇到以下情况,Class.forName(driver);无法加载类,陷入阻塞状态。若去掉两者中的一个则能正常加载。代码如下:#Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注