This is an automated email from the ASF dual-hosted git repository.
gavinchou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 09619fc03da [fix](persist) Fix
TableAddOrDropInvertedIndicesInfo.equals and remove useless logs (#45335)
09619fc03da is described below
commit 09619fc03da5d87053325dc2f4710a8eba3a5a59
Author: walter <[email protected]>
AuthorDate: Thu Dec 12 19:34:29 2024 +0800
[fix](persist) Fix TableAddOrDropInvertedIndicesInfo.equals and remove
useless logs (#45335)
---
fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java | 4 ----
.../org/apache/doris/persist/TableAddOrDropInvertedIndicesInfo.java | 2 +-
2 files changed, 1 insertion(+), 5 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
index 73a2c6338da..65a161157c8 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
@@ -2086,15 +2086,11 @@ public class EditLog {
public void
logModifyTableAddOrDropInvertedIndices(TableAddOrDropInvertedIndicesInfo info) {
long logId =
logEdit(OperationType.OP_MODIFY_TABLE_ADD_OR_DROP_INVERTED_INDICES, info);
- LOG.info("walter log modify table add or drop inverted indices, infos:
{}, json: {}",
- info, info.toJson(), new RuntimeException("test"));
Env.getCurrentEnv().getBinlogManager().addModifyTableAddOrDropInvertedIndices(info,
logId);
}
public void logIndexChangeJob(IndexChangeJob indexChangeJob) {
long logId = logEdit(OperationType.OP_INVERTED_INDEX_JOB,
indexChangeJob);
- LOG.info("walter log inverted index job, infos: {}, json: {}",
- indexChangeJob, indexChangeJob.toJson(), new
RuntimeException("test"));
Env.getCurrentEnv().getBinlogManager().addIndexChangeJob(indexChangeJob, logId);
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/persist/TableAddOrDropInvertedIndicesInfo.java
b/fe/fe-core/src/main/java/org/apache/doris/persist/TableAddOrDropInvertedIndicesInfo.java
index 39a90046d24..effe33ce624 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/persist/TableAddOrDropInvertedIndicesInfo.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/persist/TableAddOrDropInvertedIndicesInfo.java
@@ -120,7 +120,7 @@ public class TableAddOrDropInvertedIndicesInfo implements
Writable {
TableAddOrDropInvertedIndicesInfo info =
(TableAddOrDropInvertedIndicesInfo) obj;
- return (dbId == info.dbId && tableId == tableId
+ return (dbId == info.dbId && tableId == info.tableId
&& indexSchemaMap.equals(info.indexSchemaMap)
&& indexes.equals(info.indexes)
&& alterInvertedIndexes.equals(info.alterInvertedIndexes)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
