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 73a2c6338da5d7..65a161157c8967 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 void logModifyTableAddOrDropColumns(TableAddOrDropColumnsInfo info) { 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 39a90046d2419e..effe33ce624dd1 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 boolean equals(Object obj) { 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)