database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improve](show alter) add more infos to 'show alter' result for schema change job (#16843)

Browse Source
This commit is contained in:
YueW
2023-02-20 11:59:06 +08:00
committed by GitHub
parent ef2fdb79bb
commit a17a32ebd4
2 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJobV2.java
View File

@ -992,6 +992,7 @@ public class SchemaChangeJobV2 extends AlterJobV2 {
info.add(errMsg);
info.add(progress);
info.add(timeoutMs / 1000);
info.add(getOtherInfo());
infos.add(info);
}
}
@ -1012,6 +1013,21 @@ public class SchemaChangeJobV2 extends AlterJobV2 {
return taskInfos;
}
public String getOtherInfo() {
String info = null;
// can add info as needed
List<String> infoList = Lists.newArrayList();
if (invertedIndexChange) {
String invertedIndexChangeInfo = "";
for (Index invertedIndex : alterInvertedIndexes) {
invertedIndexChangeInfo += "[" + (isDropOp ? "DROP " : "ADD ") + invertedIndex.toString() + "], ";
}
infoList.add(invertedIndexChangeInfo);
}
info = Joiner.on(", ").join(infoList.subList(0, infoList.size()));
return info;
}
@Override
public void write(DataOutput out) throws IOException {
String json = GsonUtils.GSON.toJson(this, AlterJobV2.class);

1
fe/fe-core/src/main/java/org/apache/doris/common/proc/SchemaChangeProcDir.java
View File

@ -48,6 +48,7 @@ public class SchemaChangeProcDir implements ProcDirInterface {
.add("JobId").add("TableName").add("CreateTime").add("FinishTime")
.add("IndexName").add("IndexId").add("OriginIndexId").add("SchemaVersion")
.add("TransactionId").add("State").add("Msg").add("Progress").add("Timeout")
.add("OtherInfos")
.build();
private static final Logger LOG = LogManager.getLogger(SchemaChangeProcDir.class);