Skip to content

Commit 46d8250

Browse files
gustavodemoraisdawidwys
authored andcommitted
[FLINK-38211][table] Remove joinFilter and remame rowType
1 parent 70f0c5f commit 46d8250

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMultiJoin.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -173,16 +173,12 @@ public RelWriter explainTerms(final RelWriter pw) {
173173
.collect(Collectors.joining(", ")))
174174
.item("inputUniqueKeys", formatInputUniqueKeysWithFieldNames())
175175
.item("joinConditions", formatJoinConditionsWithFieldNames(pw))
176-
.itemIf(
177-
"joinFilter",
178-
formatExpressionWithFieldNames(joinFilter, pw),
179-
joinFilter != null)
180176
.itemIf(
181177
"postJoinFilter",
182178
formatExpressionWithFieldNames(postJoinFilter, pw),
183179
postJoinFilter != null)
184180
.item("select", String.join(",", getRowType().getFieldNames()))
185-
.item("outputRowType", getRowType())
181+
.item("rowType", getRowType())
186182
.itemIf("stateTtlHints", RelExplainUtil.hintsToString(hints), !hints.isEmpty());
187183
}
188184

0 commit comments

Comments
 (0)