diff --git a/fe/src/main/java/org/apache/doris/load/Load.java b/fe/src/main/java/org/apache/doris/load/Load.java index 4655d9a5890e51..27cf9bc76bd460 100644 --- a/fe/src/main/java/org/apache/doris/load/Load.java +++ b/fe/src/main/java/org/apache/doris/load/Load.java @@ -283,6 +283,9 @@ public boolean addLoadJob(TMiniLoadRequest request) throws DdlException { String columnSeparatorStr = params.get(LoadStmt.KEY_IN_PARAM_COLUMN_SEPARATOR); if (columnSeparatorStr != null) { + if (columnSeparatorStr.isEmpty()) { + columnSeparatorStr = "\t"; + } columnSeparator = new ColumnSeparator(columnSeparatorStr); try { columnSeparator.analyze(); diff --git a/fe/src/main/java/org/apache/doris/load/LoadChecker.java b/fe/src/main/java/org/apache/doris/load/LoadChecker.java index 91a8ba348a57c6..9ac727effdd50f 100644 --- a/fe/src/main/java/org/apache/doris/load/LoadChecker.java +++ b/fe/src/main/java/org/apache/doris/load/LoadChecker.java @@ -267,8 +267,9 @@ private void runOneLoadingJob(LoadJob job) { LOG.debug("job {} is already committed, just wait it to be visiable, transaction state {}", job, state); return; } else if (state.getTransactionStatus() == TransactionStatus.VISIBLE) { - // if job is committed and then fe restart, the progress is not persisted, so that set it here - load.updateLoadJobState(job, JobState.FINISHED); + if (load.updateLoadJobState(job, JobState.FINISHED)) { + load.clearJob(job, JobState.QUORUM_FINISHED); + } return; }