错误信息
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.lang.String cannot be cast to java.math.BigDecimal at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:812) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:246) at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1054) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836) at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
原因
一般都是字段比较，类型不匹配导致的，错误信息中出现了 'cannot be cast to'，这个错误容易在SQL中出现
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/70024433/viewspace-2984842/ ，如需转载，请注明出处，否则将追究法律责任。
请登录后发表评论
登录
全部评论
