Skip to content

Commit

Permalink
[INLONG-4050][sort] Fix parameter definition error of hive load
Browse files Browse the repository at this point in the history
  • Loading branch information
GanfengTan authored and moyunqing committed May 17, 2022
1 parent c1be5a2 commit db187f9
Showing 1 changed file with 1 addition and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -37,9 +36,6 @@
import java.util.List;
import java.util.Map;

/**
* hive load node with flink connectors
*/
@EqualsAndHashCode(callSuper = true)
@JsonTypeName("hiveLoad")
@Data
Expand Down Expand Up @@ -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,
Expand All @@ -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");
Expand Down

0 comments on commit db187f9

Please sign in to comment.