问题一:在使用flink-sql-connnect-hbase的时候老是出现这个报错是什么原因呢
问下我在使用flink-sql-connnect-hbase的时候老是出现这个报错是什么原因呢
参考回答:
从截图中来看应该是某个类库不存在,可以先把这个类库加上看看还有没有类似的问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/495257?spm=a2c6h.14164896.0.0.169063bfNaEsRK
问题二:这个用flink sql 读取也是报错是为什么?
这个用flink sql 读取也是报错是为什么?
参考回答:
可能kafka里面混入了脏数据,导致那一条的格式跟你其他的格式不一样。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/489404?spm=a2c6h.14164896.0.0.169063bfNaEsRK
问题三:请问flink sql 写oss有个报错该怎么办?
请问flink sql 写oss 有个Caused by: TimerException{java.lang.UnsupportedOperationException: Cannot sync state to system like S3. Use persist() to create a persistent recoverable intermediate point.}这样的 报错该怎么办呢?
参考回答:
这个错误提示的意思是不能直接将状态同步到像S3这样的系统中,需要使用persist()
方法创建一个持久化的可恢复的中间状态点。这个方法的作用是将当前的状态保存在指定的路径中,以便以后可以从该位置恢复状态。这个方法通常在长时间运行的任务或分布式计算中使用,以避免因故障或其他原因中断导致状态丢失。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/489309?spm=a2c6h.14164896.0.0.169063bfNaEsRK
问题四:大佬们flink-sql写hdfs这个报错是什么情况啊?flink版本:1.14.6
大佬们flink-sql写hdfs这个报错是什么情况啊?flink版本:1.14.6
参考回答:
应该是flink 写文件系统的bug。
” Are you writing CSV data by any chance? In this case you might be hitting https://issues.apache.org/jira/browse/FLINK-30049“ “https://issues.apache.org/jira/browse/FLINK-30049”
=====================================================================================================
此 issue 的 创建细节 为 :Jingsong Lee created issue - 17/Nov/22 02:49. 其中 Jingsong Lee 为 李劲松 是 flin 1.16.0 版本的 PMC
这样看来, 在flink 开发团队已经意识到此问题,目前此issue的 状态是:Status: OPEN / Resolution:Unresolved https://issues.apache.org/jira/browse/FLINK-30049
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/493648?spm=a2c6h.14164896.0.0.169063bfNaEsRK
问题五:请问flink-sql写hive这个报错是什么情况啊?配置没问题啊,重跑任务就会成功,偶发性的失败
请问flink-sql写hive这个报错是什么情况啊?配置没问题啊,重跑任务就会成功,偶发性的失败
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/495490?spm=a2c6h.14164896.0.0.169063bfNaEsRK