问题一:Flink SQL JDBC connector不能checkpoint怎么办
Flink开发者们,你们好:
我在使用flink开发过程中遇到一个问题,在使用jdbc做维度表关联时,该算子很快就finished了,从而导致无法正常的checkoint(我看源码中checkpoint前会检查所有算子状态必须为running),请问目前有什么参数可以使jdbc不finished或者在算子finished后依然可以checkpoint么?如果没有,那对这种情况的支持是否列入flink未来版本的开发计划中?
期待你们的回信
祝各位工作顺利,谢谢*来自志愿者整理的flink邮件归档
参考回答:
hi, 请问使用的Flink版本是什么呢?猜测你应该是写成普通的join方式了,可参考 [1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sql/queries.html#joins
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/359156?spm=a2c6h.13262185.0.0.51804c79pMhZZN
问题二:沃特MySQL cdc时态表join怎么办?
mysql cdc表 和kafka表关联,应该怎么写,有对应示例吗?*来自志愿者整理的flink邮件归档
参考回答:
可以参考 hhttps://github.com/leonardBang/flink-sql-etl/tree/master/flink-demo/flink-temporal-join-demo
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/359158?spm=a2c6h.13262185.0.0.51804c79pMhZZN
问题三:Flink Native Kubernetes 部署模式下,如何开启Queryable State?
各位好: 请教Flink 1.12.1 在Flink Native Kubernets部署模式下,如何开启Queryable State呢?官网提供了Standaleon K8S下开启的说明(https://ci.apache.org/projects/flink/flink-docs-stable/deployment/resource-providers/standalone/kubernetes.html#enabling-queryable-state),但Native K8S部署模式下,无论是Session还是Application 模式,Flink相关k8s spec基本都是由flink代码生成,尤其是Queryable State端口以及相关K8S Service没有非常便利的自动生成及部署办法。*来自志愿者整理的flink邮件归档
参考回答:
和Standalone一样,你可以按照自己创建一个taskmanager-query-state-service,然后把selector修改一下就好了
native会自动添加如下的label,可以filter出来属于一个Flink cluster的TaskManager
app:
component: taskmanager
type: flink-native-kubernetes
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/359159?spm=a2c6h.13262185.0.0.51804c79pMhZZN
问题四:Flink on Native K8S模式下如何配置StandBy做高可用?
Flink on K8S Standalone模式下可以通过yaml启多个JM,但是在Native K8S模式下要如果做呢?有文档资料介绍吗?谢谢!*来自志愿者整理的flink邮件归档
参考回答:
目前已经有了一个ticket来跟进了,https://issues.apache.org/jira/browse/FLINK-17707
应该在1.13里面可以支持
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/359160?spm=a2c6h.13262185.0.0.51804c79pMhZZN
问题五:FileSystemTableSink支持自定义分隔符写入吗?
Hi,有个疑问:
FileSystemTableSink 目前看是有csv和json的普通文本写入。
后续能支持配置 “字段分隔符” 写入文件系统吗?*来自志愿者整理的flink邮件归档
参考回答:
通过设置properties(csv.field-delimiter)可以指定分隔符。不过只能指定单字符。多字符分割不支持。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/359161?spm=a2c6h.13262185.0.0.51804c79pMhZZN