branch-3.0: [fix](persist) Fix TableAddOrDropInvertedIndicesInfo.equals

#45335 (#45363) Cherry-picked from #45335 Co-authored-by: walter <[email protected]>
apache · Dec 12, 2024 · ad2dcb4 · ad2dcb4
1 parent a1d9142
commit ad2dcb4
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 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
@@ -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
@@ -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)