flink Unsupported operand types: IF(boolean, NULL, String)

作者：很楠不爱3 | 2024-04-29 12:31:26

踩

问题：业务方存储了NULL 字符串，需要处理为 null

select if('a'='null'，null，'a');

结果遇到了 Unsupported operand types: IF(boolean, NULL, String)，根据报错反馈，很明显应该是没有对 null 自动转换（Spark 是会自动转的）

源码：

if 的源码我以前看过，就是calcyte自动生成的，在org.apache.flink.table.planner.codegen.calls 的 IfCallGen 类

确实没办法了，只能

select if(a=‘null’,cast(null as string),’a’)

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/507766