问题一:在使用flink-sql-connnect-hbase的时候老是出现这个报错是什么原因呢
问下我在使用flink-sql-connnect-hbase的时候老是出现这个报错是什么原因呢
参考答案:
看错误应该是HBASE没有安装正确,/tmp/hbase-hdfs/hbase/lib是HBase的安装目录下的一个子目录,用于存放HBase的相关依赖文件(JAR包等),所以,你检查下这个文件存不存在。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/495257?spm=a2c6h.13066369.question.46.6f064d5c33iOWa
问题二:大佬们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.13066369.question.47.6f064d5ceyXlxL
问题三:有大佬碰到过这个报错吗?
有大佬碰到过这个报错吗 Caused by: java.lang.IllegalAccessError: tried to access method io.debezium.config.Instantiator.getInstanceWithProvidedConstructorType(Ljava/lang/String;Ljava/util/function/Supplier;Ljava/lang/Class;Ljava/lang/Object;)Ljava/lang/Object; from class io.debezium.connector.oracle.OracleConnectorConfig$ConnectorAdapter$2 at io.debezium.connector.oracle.OracleConnectorConfig$ConnectorAdapter$2.getInstance(OracleConnectorConfig.java:668) at io.debezium.connector.oracle.OracleConnectorConfig.(OracleConnectorConfig.java:425) at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:48) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:759) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)
flink 版本 1.15 flink oracle cdc版本 2.3.0
参考答案:
"flinkcdc mysql和oracle的包冲突了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/497200?spm=a2c6h.13066369.question.48.6f064d5cOMTwHF
问题四:请教一下 这个报错是什么原因导致的?缺少什么jar包吗?
请教一下 这个报错是什么原因导致的?缺少什么jar包吗?flink sql sink hudi
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/497225?spm=a2c6h.13066369.question.51.6f064d5cyrxQNp
问题五:我想问一下我使用 ./flink stop -p 停止任务并触发保存点会报错。
我想问一下我使用 ./flink stop -p 停止任务并触发保存点会报错。但是使用./flink savepoint 就没问题,是怎么回事呢?
参考答案:
可能是因为您在使用 "./flink stop -p" 命令时,Flink 集群中的某些组件出现了故障或网络不稳定,导致无法成功触发保存点。而使用 "./flink savepoint" 命令时,它会自动检测集群环境并选择最适合的方式创建保存点,因此可能会更加稳定。建议您检查 Flink 集群的状态和网络连接,并尝试重新执行 "./flink stop -p" 命令。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/494731?spm=a2c6h.13066369.question.50.6f064d5cSrsusj