Skip to content

Commit 6741573

Browse files
authored
[hotfix] Use simplifiedCondition to check for isAlwaysTrue in PushCalcPastChangelogNormalizeRule
1 parent aa97d86 commit 6741573

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ private void transformWithRemainingPredicates(
328328
final RexNode condition = relBuilder.and(conditions);
329329
final RexNode simplifiedCondition =
330330
FlinkRexUtil.simplify(relBuilder.getRexBuilder(), condition, rexExecutor);
331-
if (!condition.isAlwaysTrue()) {
331+
if (!simplifiedCondition.isAlwaysTrue()) {
332332
programBuilder.addCondition(adjustInputRef(simplifiedCondition, inputRefMapping));
333333
}
334334
}

0 commit comments

Comments
 (0)