问题一:flinksql 连接oracle时间长 Closed Connection报错有方案解决不?
请问大神我flinksql 连接oracle时间长 Closed Connection报错有方案解决不?
参考回答:
java代码中可以使用连接池每隔一秒去select 1
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/454501?spm=a2c6h.14164896.0.0.281f63bfl2yXyZ
问题二:Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条数据造的不符合字段格式,导致报错,然后该flink作业就无法继续running了,请问该如何处理呢?
Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条数据造的不符合字段格式,导致报错,然后该flink作业就无法继续running了,请问该如何处理呢?
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/471939?spm=a2c6h.14164896.0.0.281f63bfl2yXyZ
问题三:问一下各位大佬,flink sql写入ES报错,但是相关的jar已经导入,怎么办?
参考回答:
导入以后 flink服务重启一下
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/453785?spm=a2c6h.14164896.0.0.584763bfwMokEV
问题四:flink sql 写入drds,报错,显示分库分表键无法做更新操作
flink sql 写入drds,报错,显示分库分表键无法做更新操作
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/437895?spm=a2c6h.14164896.0.0.584763bfwMokEV
问题五:各位大佬请问FlinkCDC 用sql方式同步的时候,sql有一些聚合操作用的是数据库的内存还是flink集群的内存 我抽取oracle,一段时间后报错ORA-04036: 实例使用的 PGA 内存超出 PGA_AGGREGATE_LIMIT
各位大佬请问FlinkCDC 用sql方式同步的时候,sql有一些聚合操作用的是数据库的内存还是flink集群的内存 我抽取oracle,一段时间后报错ORA-04036: 实例使用的 PGA 内存超出 PGA_AGGREGATE_LIMIT
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/458474?spm=a2c6h.14164896.0.0.584763bfwMokEV