问题一:Flink这个异常历史, 怎么控制, 每次重启job的时候,不要被删掉了?
Flink这个异常历史, 怎么控制, 每次重启job的时候,不要被删掉了?
参考答案:
这一条报错信息应该是关键:caused by: com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.connectexception: an exception occurred in the change event producer. this connector will be stopped. PostgresSQL的numeric类型如果不设置精度的时候,会默认采用最大上限的精度。因此debezium在解析时把它当作了Struct类型,然而默认值0被解析为Numeric,两者不匹配。
解决方案: 建议升级到vvr8.x以上版本
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/641778
问题二:Flink这个问题怎么解决?
Flink这个问题怎么解决?807版本开启'table.optimizer.source-merge.enabled' = 'true';后,比如我有两个source,配置了两个server_id,那么使用的source_merge后使用的是哪个server_id呢?
参考答案:
一开始使用哪个,后面还是使用这个的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/649386
问题三:Flink这个问题怎么解决?
Flink这个问题怎么解决?Class conflicts, detailed context: ClassNotFoundException: com.ververica.cdc.debezium.DebeziumDeserializationSchema
Class conflicts, detailed context: ClassNotFoundException: com.ververica.cdc.debezium.DebeziumDeserializationSchema
at java.net.URLClassLoader.findClass(URLClassLoader.java:387) ~[?:1.8.0_372]
at org.apache.flink.util.EncryptedFlinkUserCodeClassLoader.f
参考答案:
您看看这篇文档呢
https://help.aliyun.com/zh/flink/developer-reference/cdc-connector?spm=a2c4g.11186623.0.i3
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/620505
问题四:Flink这个问题要怎么排查呢?
自定义了一个表函数 ,解析数据信息 检查时提示: Argument name conflict, there are at least two argument names that are the same. 我将返回参数改为1个了还是提示参数名冲突,Flink这个问题要怎么排查呢?
参考答案:
把flink引擎版本调成806试试呢 ,原因: VVR 8.0.7版本在支持named args新功能时引入的检查逻辑触发了原有自定义函数方法分析的缺陷,导致误报。解决方案: 切换使用其他版本,如8.0.6;如需继续使用8.0.7版本,可以尝试修改自定义函数eval 方法中的局部变量声明方式,保证在声明式初始化(变量赋初值)可以避免此报错。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/654888
问题五:Flink这个提示是不是有点问题hologres也可以?
Flink这个提示是不是有点问题hologres也可以?
参考答案:
您看一下解释呢,只要是符合的都可以
这是文档链接:https://help.aliyun.com/zh/flink/user-guide/start-a-deployment?spm=a2c4g.11186623.0.i4
关于本问题的更多回答可点击进行查看: