问题一:Flink报错:Session cluster version 'vvr-x.x.x-flink-1.1x' must be consistent with the SQL version 'vvr-x.x.x-flink-1.1x', please align the session cluster version with the version used in SQL.
Flink报错:Session cluster version 'vvr-x.x.x-flink-1.1x' must be consistent with the SQL version 'vvr-x.x.x-flink-1.1x', please align the session cluster version with the version used in SQL.
参考答案:
【报错详情】
Session cluster version 'vvr-x.x.x-flink-1.1x' must be consistent with the SQL version 'vvr-x.x.x-flink-1.1x', please align the session cluster version with the version used in SQL.
【报错原因】
session集群的版本需要和作业的版本保持一致,可以调整作业的版本,或者调整session集群的版本。
【解决方案】
可以调整作业的版本,在开发界面->高级配置->引擎版本调整。或者调整session集群的版本,可以在session集群->编辑->配置->引擎版本修改session集群版本。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476360?spm=a2c6h.13066369.question.38.6f064d5c3rxsNF
问题二:实时计算Flink报错Column 'ccid' is NOT NULL, however, a null value is being written into it. You can set job configuration 'table.exec.sink.not-null-enforcer'='drop' to suppress this exception and drop such records silently.
实时计算Flink报错Column 'ccid' is NOT NULL, however, a null value is being written into it. You can set job configuration 'table.exec.sink.not-null-enforcer'='drop' to suppress this exception and drop such records silently.
参考答案:
报错的原因是用户写入的结果表建表的时候声明了该字段为非空值,但是有空值写入,可以在更多配置添加 table.exec.sink.not-null-enforcer: drop' 这个配置来忽略空值写入解决这个报错,即删除掉这条为空的数据,不往下游结果表写,或者在建表的时候不声明字段非空。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/475271?spm=a2c6h.13066369.question.37.6f064d5cxy4jqS
问题三:flink有遇到这样的问题吗?任务跑一段时间,突然报错关于checkpoint导致任务停止。是为啥?
请问有遇到这样的问题吗?就是任务跑了一段时间,突然报错关于checkpoint的,导致任务停止。这是一般什么原因导致了?
参考答案:
你这个日志不完整,你往上看看,一般checkpoint失败,会有显示具体是哪一个checkpoint在哪个taskmannerger上失败
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/500244?spm=a2c6h.13066369.question.40.6f064d5cADJvQp
问题四:这个报错是什么原因?
org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler [] - Exception occurred in REST handler: Job dc0c020140fda687ba5f3442b0ca6d7f not found 这个报错是什么原因?
参考答案:
表明,你的REST处理程序在处理“job”元素时遇到了问题。具体来说,它指出你的REST处理程序在处理“dc0c020140fda687ba5f3442b0ca6d7f”时遇到了错误。
这个错误信息可能是由于以下原因之一导致的:
1、你的REST处理程序在处理“job”元素时,没有正确地解析它的内容。请确保你的REST处理程序正确地解析了“job”元素的内容,并且它知道如何处理它。 2、你的REST处理程序在处理“job”元素时,尝试处理的是一个不存在的元素。请确保你的REST处理程序正确地处理了“job”元素,并且它知道如何处理不存在的元素。 3、你的REST处理程序在处理“job”元素时,尝试处理的是一个无效的元素。请确保你的REST处理程序正确地处理了“job”元素,并且它知道如何处理无效的元素。 为了解决这个问题,你可以检查你的REST处理程序的日志,查看它是如何处理“job”元素的。如果你不确定如何处理“job”元素,请查阅你的REST处理程序的文档,以了解如何正确地处理它。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/499592?spm=a2c6h.13066369.question.41.6f064d5clo0u21
问题五:有没有大佬flink消费rabbitmq报错?
有没有大佬flink消费rabbitmq报错,跪求指导,之前没搞过
参考答案:
看flink官网,都有说明。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/492270?spm=a2c6h.13066369.question.40.6f064d5cZaeWYX