diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java index 45ed54dced7e00a..015d4d16047d87e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java @@ -128,25 +128,21 @@ public class IngestionLoadJob extends LoadJob { public static final Logger LOG = LogManager.getLogger(IngestionLoadJob.class); - private long etlStartTimestamp = -1; - - private long quorumFinishTimestamp = -1; - - private List loadTableIds = new ArrayList<>(); - @Setter @SerializedName("ests") private EtlStatus etlStatus; - private final Map> tableToLoadPartitions = Maps.newHashMap(); - - private final Map> tabletToSentReplicaPushTask = Maps.newHashMap(); - // members below updated when job state changed to loading // { tableId.partitionId.indexId.bucket.schemaHash -> (etlFilePath, etlFileSize) } @SerializedName(value = "tm2fi") private final Map> tabletMetaToFileInfo = Maps.newHashMap(); + @SerializedName(value = "hp") + private final Map hadoopProperties = new HashMap<>(); + + @SerializedName(value = "i2sv") + private final Map indexToSchemaVersion = new HashMap<>(); + private final Map indexToSchemaHash = Maps.newHashMap(); private final Map filePathToSize = new HashMap<>(); @@ -157,11 +153,15 @@ public class IngestionLoadJob extends LoadJob { private final List commitInfos = Lists.newArrayList(); - @SerializedName(value = "hp") - private final Map hadoopProperties = new HashMap<>(); + private final Map> tableToLoadPartitions = Maps.newHashMap(); - @SerializedName(value = "i2sv") - private final Map indexToSchemaVersion = new HashMap<>(); + private final Map> tabletToSentReplicaPushTask = Maps.newHashMap(); + + private long etlStartTimestamp = -1; + + private long quorumFinishTimestamp = -1; + + private List loadTableIds = new ArrayList<>(); public IngestionLoadJob() { super(EtlJobType.INGESTION);