This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/dev-1.1.2 by this push:
new e77fcb9917 [minor](log) add some log to observe the change of table's
state. (#11448)
e77fcb9917 is described below
commit e77fcb9917ad297b756626261522127d2154f2eb
Author: Mingyu Chen <[email protected]>
AuthorDate: Wed Aug 3 08:43:14 2022 +0800
[minor](log) add some log to observe the change of table's state. (#11448)
When upgrading to 1.x, some table's state may change to ROLLUP,
Resulting in not able to create/drop/modify partition.
I haven't find the root cause yet, so I add some log to observe
the change of table's state.
---
.../java/org/apache/doris/alter/MaterializedViewHandler.java | 12 ++++++++++++
.../main/java/org/apache/doris/alter/SchemaChangeJobV2.java | 1 +
2 files changed, 13 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/alter/MaterializedViewHandler.java
b/fe/fe-core/src/main/java/org/apache/doris/alter/MaterializedViewHandler.java
index f2c1b5b8d3..86710a81a3 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/alter/MaterializedViewHandler.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/alter/MaterializedViewHandler.java
@@ -901,8 +901,15 @@ public class MaterializedViewHandler extends AlterHandler {
if (!alterJob.isDone()) {
addAlterJobV2ToTableNotFinalStateJobMap(alterJob);
changeTableStatus(alterJob.getDbId(), alterJob.getTableId(),
OlapTableState.ROLLUP);
+ LOG.info("set table's state to ROLLUP, table id: {}, job id: {}",
alterJob.getTableId(),
+ alterJob.getJobId());
} else if (removeAlterJobV2FromTableNotFinalStateJobMap(alterJob)) {
changeTableStatus(alterJob.getDbId(), alterJob.getTableId(),
OlapTableState.NORMAL);
+ LOG.info("set table's state to NORMAL, table id: {}, job id: {}",
alterJob.getTableId(),
+ alterJob.getJobId());
+ } else {
+ LOG.info("not set table's state, table id: {}, is job done: {},
job id: {}", alterJob.getTableId(),
+ alterJob.isDone(), alterJob.getJobId());
}
}
@@ -975,6 +982,11 @@ public class MaterializedViewHandler extends AlterHandler {
removeJobFromRunningQueue(alterJob);
if (removeAlterJobV2FromTableNotFinalStateJobMap(alterJob)) {
changeTableStatus(alterJob.getDbId(), alterJob.getTableId(),
OlapTableState.NORMAL);
+ LOG.info("set table's state to NORMAL, table id: {}, job id: {}",
alterJob.getTableId(),
+ alterJob.getJobId());
+ } else {
+ LOG.info("not set table's state, table id: {}, is job done: {},
job id: {}", alterJob.getTableId(),
+ alterJob.isDone(), alterJob.getJobId());
}
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java
b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java
index 897ac2cd4b..ecc9501a54 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java
@@ -632,6 +632,7 @@ public class SchemaChangeJobV2 extends AlterJobV2 {
tbl.deleteIndexInfo(shadowIndexName);
}
tbl.setState(OlapTableState.NORMAL);
+ LOG.info("set table's state to NORMAL when cancel job:
{}", tbl.getId(), jobId);
} finally {
tbl.writeUnlock();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
