[INLONG-4050][sort] Fix parameter definition error of hive load

yunqingmoswu · May 17, 2022 · 054d4ae · 054d4ae
1 parent a95f62e
commit 054d4ae
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...ort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/HiveLoadNode.java b/...ort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/HiveLoadNode.java
@@ -27,7 +27,6 @@
 import org.apache.inlong.sort.formats.common.LocalZonedTimestampFormatInfo;
 import org.apache.inlong.sort.formats.common.TimestampFormatInfo;
 import org.apache.inlong.sort.protocol.FieldInfo;
-import org.apache.inlong.sort.protocol.enums.FilterStrategy;
 import org.apache.inlong.sort.protocol.node.LoadNode;
 import org.apache.inlong.sort.protocol.transformation.FieldRelationShip;
 import org.apache.inlong.sort.protocol.transformation.FilterFunction;
@@ -37,9 +36,6 @@
 import java.util.List;
 import java.util.Map;
 
-/**
- * hive load node with flink connectors
- */
 @EqualsAndHashCode(callSuper = true)
 @JsonTypeName("hiveLoad")
 @Data
@@ -83,7 +79,6 @@ public HiveLoadNode(@JsonProperty("id") String id,
             @JsonProperty("fields") List<FieldInfo> fields,
             @JsonProperty("fieldRelationShips") List<FieldRelationShip> fieldRelationShips,
             @JsonProperty("filters") List<FilterFunction> filters,
-            @JsonProperty("filterStrategy") FilterStrategy filterStrategy,
             @JsonProperty("sinkParallelism") Integer sinkParallelism,
             @JsonProperty("properties") Map<String, String> properties,
             @JsonProperty("catalogName") String catalogName,
@@ -93,7 +88,7 @@ public HiveLoadNode(@JsonProperty("id") String id,
             @JsonProperty("hiveVersion") String hiveVersion,
             @JsonProperty("hadoopConfDir") String hadoopConfDir,
             @JsonProperty("parFields") List<FieldInfo> partitionFields) {
-        super(id, name, fields, fieldRelationShips, filters, filterStrategy, sinkParallelism, properties);
+        super(id, name, fields, fieldRelationShips, filters, sinkParallelism, properties);
         this.database = Preconditions.checkNotNull(database, "database of hive is null");
         this.tableName = Preconditions.checkNotNull(tableName, "table of hive is null");
         this.hiveVersion = Preconditions.checkNotNull(hiveVersion, "version of hive is null");