Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
Caused by: java.lang.NumberFormatException: For input string: "true"
filinCdc 的sql,多表的时候总报这个错,请问下该怎么解决呀?就单表查询了一次
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
问题描述: 您在使用Flink执行包含多表查询的SQL时遇到异常,具体错误信息为:Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy Caused by: java.lang.NumberFormatException: For input string: "true"
。您提到单表查询未出现问题。
原因分析:
java.lang.NumberFormatException: For input string: "true"
,该问题可能是由于Flink作业配置中某处期望一个数值类型的参数,却错误地接收到了字符串"true",导致无法将其转换为数字。解决步骤:
true
/false
)错误地用于需要数值类型参数的上下文。flink-conf.yaml
),确保所有配置的值与其对应的预期类型相匹配。特别注意是否有误将布尔型配置以字符串形式赋值的情况,例如应为rest.flamegraph.enabled: true
而非直接写成字符串形式的值。NumberFormatException
发生的上下文,这有助于更精确地识别出是哪个参数或配置引发了该问题。注意事项:
通过上述步骤,您可以定位并解决因不匹配的数据类型引发的异常,确保多表查询能够顺利执行。
你好,我是AI助理
可以解答问题、推荐解决方案等