问题一:Flink报错Has not enough ip address: abnormal event detected from kubernetes
Flink报错Has not enough ip address: abnormal event detected from kubernetes
参考答案:
虚拟机没有可用IP,控制台虚拟交换机中可用新建可用IP,详情点此查看。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476355?spm=a2c6h.13066369.question.18.6f064d5c0iPFHH
问题二:Flink报错k8s LeaderElection renew loop gets interrupted java.lang.InterruptedException: sleep interrupted
Flink报错k8s LeaderElection renew loop gets interrupted java.lang.InterruptedException: sleep interrupted
参考答案:
只要有“sleep interrupted”的这个leader错误就不是问题,它是个单独的线程,给jm进程发停止信号的时候,线程没有处理就会报interrupted的错误。 这种都出现在作业停止的时候,可以忽略的。作业finished所以shutdown。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476345?spm=a2c6h.13066369.question.17.6f064d5cLx0Klp
问题三:Flink报错org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Too many ongoing snapshots. Increase kafka producers pool size or decrease number of concurrent checkpoints
Flink报错org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Too many ongoing snapshots. Increase kafka producers pool size or decrease number of concurrent checkpoints
参考答案:
【报错原因】
checkpoint超时时长设置太短,失败了几次就会报错。
【解决方案】
建议用户调大checkpoint的超时时长,超时时长参数,execution.checkpointing.timeout。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476372?spm=a2c6h.13066369.question.20.6f064d5crlD8l8
问题四:Flink报错:Incompatible types for sink column 'xxx' at position x.
Flink报错:Incompatible types for sink column 'xxx' at position x.
参考答案:
【报错详情】
org.apache.flink.table.api.ValidationException: SQL validation failed. Column types of query result and sink for 'vvp.default.xxx' do not match. Cause: Incompatible types for sink column 'xxx' at position x. Query schema: [xxx: xxx, xxx: xxx] Sink schema: [xxx: xxx, xxx: xxx] at org.apache.flink.table.sqlserver.utils.FormatValidatorExceptionUtils.newValidationException(FormatValidatorExceptionUtils.java:41)
【报错原因】
DML select 的表字段类型 与 DDL 建表语句定义的字段类型不匹配。
【解决方案】
位置在x位置存在字段类型不匹配,请检查DML select 的表字段类型与DDL建表语句定义的字段类型,顺序及类型均需保持一致。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/476363?spm=a2c6h.13066369.question.21.6f064d5cKBVRb5
问题五:实时计算Flink报错The difference between the request time and the current time is too large
实时计算Flink报错The difference between the request time and the current time is too large
参考答案:
可参考QA:报错:The difference between the request time and the current time is too large
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/475556?spm=a2c6h.13066369.question.22.6f064d5coD1GxM