From c241df08250178fca3610c3cdc7840dc9a9d7769 Mon Sep 17 00:00:00 2001
From: tinker <guowenlong.gwl@oceanbase.com>
Date: Wed, 5 Jun 2024 21:18:10 +0800
Subject: [PATCH] fix target database id is null

---
 .../com/oceanbase/odc/service/schedule/job/DataDeleteJob.java | 4 +++-
 1 file changed, 3 insertions(+), 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
index 913a651e19..9e28363a09 100644
--- 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());