fix(dlm): target database id is null in task framework mode (#2676)

oceanbase · Jun 6, 2024 · 22889bf · 22889bf
1 parent 656b30c
commit 22889bf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/service/schedule/job/DataDeleteJob.java b/server/odc-service/src/main/java/com/oceanbase/odc/service/schedule/job/DataDeleteJob.java
@@ -141,7 +141,9 @@ private void executeInTaskFramework(JobExecutionContext context) {
                         databaseService.findDataSourceForConnectById(dataDeleteParameters.getDatabaseId())));
         parameters
                 .setTargetDs(DataSourceInfoMapper.toDataSourceInfo(
-                        databaseService.findDataSourceForConnectById(dataDeleteParameters.getTargetDatabaseId())));
+                        databaseService.findDataSourceForConnectById(dataDeleteParameters.getTargetDatabaseId() == null
+                                ? dataDeleteParameters.getDatabaseId()
+                                : dataDeleteParameters.getTargetDatabaseId())));
         parameters.getSourceDs().setQueryTimeout(dataDeleteParameters.getQueryTimeout());
         parameters.getTargetDs().setQueryTimeout(dataDeleteParameters.getQueryTimeout());
         parameters.getSourceDs().setDatabaseName(dataDeleteParameters.getDatabaseName());