wsjz commented on code in PR #26356:
URL: https://github.com/apache/doris/pull/26356#discussion_r1427678969
##########
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/InsertTask.java:
##########
@@ -74,30 +72,70 @@ public class InsertTask extends AbstractTask {
}
private String labelName;
-
private InsertIntoTableCommand command;
-
private StmtExecutor stmtExecutor;
-
private ConnectContext ctx;
-
private String sql;
-
private String currentDb;
-
private UserIdentity userIdentity;
-
+ private LoadStatistic loadStatistic;
private AtomicBoolean isCanceled = new AtomicBoolean(false);
-
private AtomicBoolean isFinished = new AtomicBoolean(false);
-
private static final String LABEL_SPLITTER = "_";
+ private FailMsg failMsg;
+ @Getter
+ private String trackingUrl;
@Getter
@Setter
- private LoadJob loadJob;
+ private InsertJob jobInfo;
+ private TaskType taskType = TaskType.PENDING;
+ private MergeType mergeType = MergeType.APPEND;
+
+ /**
+ * task merge type
+ */
+ enum MergeType {
+ MERGE,
+ APPEND,
+ DELETE
+ }
+
+ /**
+ * task type
+ */
+ enum TaskType {
+ UNKNOWN, // this is only for ISSUE #2354
+ PENDING,
+ LOADING,
+ FINISHED,
+ FAILED,
+ CANCELLED
+ }
+
+ public InsertTask(InsertIntoTableCommand insertInto,
+ ConnectContext ctx, StmtExecutor executor, LoadStatistic
statistic) {
+ this(null, insertInto, ctx, executor, statistic);
+ }
+
+ public InsertTask(String labelName, String currentDb, String sql,
UserIdentity userIdentity) {
+ this.labelName = labelName;
+ this.sql = sql;
+ this.currentDb = currentDb;
+ this.userIdentity = userIdentity;
+ setTaskId(Env.getCurrentEnv().getNextId());
+ }
+ public InsertTask(String labelName, InsertIntoTableCommand insertInto,
+ ConnectContext ctx, StmtExecutor executor,
LoadStatistic statistic) {
+ this.labelName = labelName;
Review Comment:
the first constructor don't need loadStatistic
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
