Skip to content

Commit 3ebb3e2

Browse files
Enable sink reuse for sinks with different target columns
1 parent 3351259 commit 3ebb3e2

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/SinkReuser.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -177,16 +177,6 @@ private String getDigest(Sink sink) {
177177
List<String> digest = new ArrayList<>();
178178
digest.add(sink.contextResolvedTable().getIdentifier().asSummaryString());
179179

180-
int[][] targetColumns = sink.targetColumns();
181-
if (targetColumns != null && targetColumns.length > 0) {
182-
digest.add(
183-
"targetColumns=["
184-
+ Arrays.stream(targetColumns)
185-
.map(Arrays::toString)
186-
.collect(Collectors.joining(","))
187-
+ "]");
188-
}
189-
190180
String fieldTypes =
191181
sink.getRowType().getFieldList().stream()
192182
.map(f -> f.getType().toString())

0 commit comments

Comments
 (0)