问题一:阿里云的Flink是如何动态加载Java udf的呢?
阿里云的Flink是如何动态加载Java udf的呢?现在用的开源的Flink,没找到动态加载Flink的相关文档的。我看阿里云的Flink有这部分的功能,想了解下是如何做到的
参考回答:
没这个能力哈,需要重启作业。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572563
问题二:Flink中failover后,会创建新的jobId吗?
Flink中failover后,会创建新的jobId吗?想确认一下这一点,因为我发现每次手动停止启动的时候会创建新的jobid
参考回答:
不会,你那种手动的会。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572561
问题三:实时计算flink配置catalog的时候,这些选项分别得怎么填的?我找到的信息好像会有问题
实时计算flink配置catalog的时候,这些选项分别得怎么填的?我找到的信息好像会有问题
参考回答:
你看下配没配白名单,或者你配的用户有没有那个库的访问权限。https://help.aliyun.com/zh/flink/user-guide/manage-hologres-catalogs?spm=a2c4g.11186623.0.0.593834a9iydyoG
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572560
问题四:这个重启次数是什么时候会增加?flink会自动重启吗?重启会产生新的jobId吗?
这个重启次数是什么时候会增加?flink会自动重启吗?重启会产生新的jobId吗?
参考回答:
failover
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572559
问题五:请问Flink CDC这个以后可以支持为每个表设置分片的column吗?
请问Flink CDC这个以后可以支持为每个表设置分片的column吗?
参考回答:
可以的,合理需求,可以在GitHub上开个issue
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572314