remove duplicate exception

TongchengOpenSource · Apr 12, 2024 · 344f17c · 344f17c
1 parent dec336b
commit 344f17c
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/...ansforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java b/...ansforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java
@@ -91,9 +91,6 @@ protected TableSchema transformTableSchema() {
         for (int i = 0; i < fields.size(); i++) {
             String field = fields.get(i);
             int inputFieldIndex = seaTunnelRowType.indexOf(field);
-            if (inputFieldIndex == -1) {
-                throw TransformCommonError.cannotFindInputFieldError(getPluginName(), field);
-            }
             inputValueIndex[i] = inputFieldIndex;
             outputColumns.add(inputColumns.get(inputFieldIndex).copy());
             outputFieldNames.add(inputColumns.get(inputFieldIndex).getName());