diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java index 75e7d869ac9..b18aed05424 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java +++ b/seatunnel-transforms-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());