问题一:Flink的ctas/cdas有开源计划和安排吗?
Flink的ctas/cdas有开源计划和安排吗?
参考答案:
没有哈
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581178
问题二:我要用flink同步mysql数据到Hologres,有近100个表,mysql线程池要配置多少?
我要用 flink 同步mysql 数据到Hologres,有近100个表 ,那 我mysql 源表 的线程池 要配置多少?配置选项connection.pool.size。 connection.pool.size 我配置少了,它跑不起来 ,等待超时;配置多了,又怕影响到mysql 的连接使用
参考答案:
对于mysql压力太大了,越少越好,走走ctas/cdas同步。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581177
问题三:Flink为什么在把测试数据写到OSS文件的时候,Session集群任务成功了,但查不到数据呢?
Flink为什么在把测试数据写到OSS文件的时候,Session集群任务成功了,但实际上在OSS查不到数据呢?
参考答案:
调试会将 sink 置换为 print sink,不会往物理表写数据的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581175
问题四:Flink1.17 ds连接器最近会发布吧?
Flink1.17 ds连接器最近会发布吧?
参考答案:
是的,Flink 1.17的ds连接器即将发布。具体发布时间可能会受到一些因素的影响,如开发进度、测试和发布流程等。因此,具体的发布时间可能会在Flink社区发布公告或通知时公布。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/581174
问题五:Flink这个问题怎么解决?
Flink这个问题怎么解决?帮忙看下这个工单, 000GJABZ10 ,你们售后反馈是计算资源的问题,但我觉得不是,帮忙评估下 我这个job就同步一个表,目前总的数据量就几万条,更新也很少,我观察了确认是没有数据写入的,但在作业运维平台的时间一直显示有6s业务延时
参考答案:
从您的问题描述来看,尽管您的作业只是同步一个表并且数据量不大,但仍然存在6秒的业务延时。这种情况可能与Flink的内部处理机制有关。在Flink中,对于流式数据的处理通常会采用窗口操作或者基于时间的JOIN等算子,这些算子可能会引入一定的延迟。
特别是当使用到维表JOIN时,需要注意Flink SQL的维表JOIN目前仅支持对当前时刻维表快照的关联(处理时间语义),而不支持事实表rowtime所对应的的维表快照(事件时间语义)。此外,Flink Table API中的动态表(Dynamic Tables)也是随着新数据的到来不停地更新结果,这也可能是导致延时的一个因素。
关于本问题的更多回答可点击进行查看: