Skip to content

Commit 1ac05ad

Browse files
lsy3993dataroaring
authored andcommitted
[opt](binlog) Log table rename when reply (#38034)
## Proposed changes Issue Number: close #xxx <!--Describe your changes.--> Related PR is : #37031 , when replay rename table, addTableRename is needed
1 parent 2458804 commit 1ac05ad

File tree

1 file changed

+3
-0
lines changed
  • fe/fe-core/src/main/java/org/apache/doris/persist

1 file changed

+3
-0
lines changed

fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java

+3
Original file line numberDiff line numberDiff line change
@@ -306,6 +306,7 @@ public static void loadJournal(Env env, Long logId, JournalEntity journal) {
306306
case OperationType.OP_RENAME_TABLE: {
307307
TableInfo info = (TableInfo) journal.getData();
308308
env.replayRenameTable(info);
309+
Env.getCurrentEnv().getBinlogManager().addTableRename(info, logId);
309310
break;
310311
}
311312
case OperationType.OP_MODIFY_VIEW_DEF: {
@@ -316,6 +317,7 @@ public static void loadJournal(Env env, Long logId, JournalEntity journal) {
316317
case OperationType.OP_RENAME_PARTITION: {
317318
TableInfo info = (TableInfo) journal.getData();
318319
env.replayRenamePartition(info);
320+
Env.getCurrentEnv().getBinlogManager().addTableRename(info, logId);
319321
break;
320322
}
321323
case OperationType.OP_RENAME_COLUMN: {
@@ -362,6 +364,7 @@ public static void loadJournal(Env env, Long logId, JournalEntity journal) {
362364
case OperationType.OP_RENAME_ROLLUP: {
363365
TableInfo info = (TableInfo) journal.getData();
364366
env.replayRenameRollup(info);
367+
Env.getCurrentEnv().getBinlogManager().addTableRename(info, logId);
365368
break;
366369
}
367370
case OperationType.OP_LOAD_START:

0 commit comments

Comments
 (0)