关于Flink SQL语句内的函数名和内建函数名称对应不上的问题

flink 1.18.0 例如我写下一条SQL： select * from KafkaTable where id is not null; IS NOT NULL应该属于系统内建函数，于是我找到相关代码： public static final BuiltInFunctionDefinition IS_NOT_NULL = BuiltInFunctionDefinition.newBuilder() .name("isNotNull") .kind(SCALAR)

Re: Flink-1.15版本

看起来是类似的，不过这个报错应该是作业失败之后的报错，看还有没有其他的异常日志。 Best, Feng On Sat, Nov 4, 2023 at 3:26 PM Ray wrote: > 各位专家：当前遇到如下问题1、场景：在使用Yarn场景下提交flink任务2、版本：Flink1.15.03、日志：查看yarn上的日志发下，版本上的问题2023-11-04 > 15:04:42,313 ERROR org.apache.flink.util.FatalExitExceptionHandler > [] - FATAL: Thread