fix rollback failed

oceanbase · May 30, 2024 · a4182c3 · a4182c3
1 parent aaba459
commit a4182c3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...-service/src/main/java/com/oceanbase/odc/service/schedule/job/DataArchiveRollbackJob.java b/...-service/src/main/java/com/oceanbase/odc/service/schedule/job/DataArchiveRollbackJob.java
@@ -90,6 +90,9 @@ public void executeJob(JobExecutionContext context) {
  i));
  dlmTableUnit.setSourceDatasourceInfo(dlmTableUnit.getTargetDatasourceInfo());
  dlmTableUnit.setTargetDatasourceInfo(temp);
+ String tmp = dlmTableUnit.getTableName();
+ dlmTableUnit.setTableName(dlmTableUnit.getTargetTableName());
+ dlmTableUnit.setTargetTableName(tmp);
  dlmTableUnit.setType(JobType.ROLLBACK);
  dlmTableUnit.setStatus(
  dlmTableUnit.getStatus() == TaskStatus.PREPARING ? TaskStatus.DONE : TaskStatus.PREPARING);