This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 46d825080d6620da403eee7a67ec6cc3fde2c32f Author: Gustavo de Morais <[email protected]> AuthorDate: Mon Sep 29 15:45:05 2025 +0200 [FLINK-38211][table] Remove joinFilter and remame rowType --- .../planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java index acd0dfa9253..1107f9e6b36 100644 --- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java +++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java @@ -173,16 +173,12 @@ public class StreamPhysicalMultiJoin extends AbstractRelNode implements StreamPh .collect(Collectors.joining(", "))) .item("inputUniqueKeys", formatInputUniqueKeysWithFieldNames()) .item("joinConditions", formatJoinConditionsWithFieldNames(pw)) - .itemIf( - "joinFilter", - formatExpressionWithFieldNames(joinFilter, pw), - joinFilter != null) .itemIf( "postJoinFilter", formatExpressionWithFieldNames(postJoinFilter, pw), postJoinFilter != null) .item("select", String.join(",", getRowType().getFieldNames())) - .item("outputRowType", getRowType()) + .item("rowType", getRowType()) .itemIf("stateTtlHints", RelExplainUtil.hintsToString(hints), !hints.isEmpty()); }
