diff --git a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala index cbf13f3020a52..5511e22fb81d2 100644 --- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala +++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala @@ -1287,17 +1287,17 @@ object ScalarOperatorGens { |boolean $nullTerm; |if (${condition.resultTerm}) { | ${trueAction.code} - | if (!${trueAction.nullTerm}) { + | $nullTerm = ${trueAction.nullTerm}; + | if (!$nullTerm) { | $resultTerm = ${trueAction.resultTerm}; | } - | $nullTerm = ${trueAction.nullTerm}; |} |else { | ${falseAction.code} - | if (!${falseAction.nullTerm}) { + | $nullTerm = ${falseAction.nullTerm}; + | if (!$nullTerm) { | $resultTerm = ${falseAction.resultTerm}; | } - | $nullTerm = ${falseAction.nullTerm}; |} |""".stripMargin.trim }