fixup

xuyangzhong · xuyangzhong · commit d899471b7c92 · 2025-10-27T20:54:25.000+08:00
diff --git a/flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/SinkTestStep.java b/flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/SinkTestStep.java
@@ -142,12 +142,11 @@ public List<String> getExpectedAsStrings() {
     }
 
     public List<String> getExpectedMaterializedResultsAsStrings() {
-
         if (expectedMaterializedStrings != null) {
             return expectedMaterializedStrings;
         }
         if (expectedMaterializedRows != null) {
-            if (deduplicatedFieldIndices == null) {
+            if (deduplicatedFieldIndices != null) {
                 throw new UnsupportedOperationException(
                         "Unsupported to deduplicate data for materialized rows");
             }

Original file line number	Diff line number	Diff line change
`@@ -142,12 +142,11 @@ public List<String> getExpectedAsStrings() {`
`142`	`142`	`}`
`143`	`143`
`144`	`144`	`public List<String> getExpectedMaterializedResultsAsStrings() {`
`145`		`-`
`146`	`145`	`if (expectedMaterializedStrings != null) {`
`147`	`146`	`return expectedMaterializedStrings;`
`148`	`147`	`}`
`149`	`148`	`if (expectedMaterializedRows != null) {`
`150`		`- if (deduplicatedFieldIndices == null) {`
	`149`	`+ if (deduplicatedFieldIndices != null) {`
`151`	`150`	`throw new UnsupportedOperationException(`
`152`	`151`	`"Unsupported to deduplicate data for materialized rows");`
`153`	`152`	`}`