问题一:Flink 将所有的 TaskManager 都走这个 JobManager 来管理吗?
最近我们有从 Flink On Yarn 转到 K8S 的需求,我自己做了下测试,直接将之前的 Thin Jar 发布到 container,然后挂载通用 NAS 里面的Dependency ,好像也完全可以,几乎0迁移成本。但是有个小小的问题就是,我如何确定 JobManager 的位置呢?或者,我可以启动一个 JobManager 的 Container ,然后将所有的 TaskManager 都走这个 JobManager 来管理吗?官网上的那个示例,我不太确定是什么意思
参考答案:
有默认标签可以定位到pod,你也可以启动时自己加标签
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/616181
问题二:在Flink为什么checkpointing.interval设置的1分钟。但是实际上却不是?
在Flink 为什么我的checkpointing.interval 设置的 1 分钟。但是实际上却是 3分钟才执行一次checkpoint呢?
参考答案:
你在界面上设置这个参数,平台以那个为高优设置。默认是180s,也就是三分钟。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/614519
问题三:Flink在source端进行了CTAS不支持的操作后,是否支持手动在sink端进行相应调整?
Flink在source端进行了CTAS不支持的操作后,是否支持手动在sink端进行相应调整?
参考答案:
只能在sink端对应的库或者仓上自己操作,不是Flink操作
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/614517
问题四:Flink使用cdas语法同步mysql数据到sr serverless支持动态加表吗?
Flink使用cdas语法同步mysql数据到sr serverless支持动态加表吗?
参考答案:
根据文档中的描述,是支持的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/614515
问题五:flink读oss的时候 能跳过首行么?
flink读oss的时候 能跳过首行么?
参考答案:
文档中并没有涉及跳过首行的概念。
关于本问题的更多回答可点击进行查看: