bugfix

oceanbase · Jun 27, 2024 · 568677d · 568677d
1 parent 9d16f49
commit 568677d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...r/odc-service/src/main/java/com/oceanbase/odc/metadb/schedule/ScheduleTaskRepository.java b/...r/odc-service/src/main/java/com/oceanbase/odc/metadb/schedule/ScheduleTaskRepository.java
@@ -39,7 +39,7 @@
 public interface ScheduleTaskRepository extends JpaRepository<ScheduleTaskEntity, Long>,
         JpaSpecificationExecutor<ScheduleTaskEntity> {
 
-    Optional<ScheduleTaskEntity> findByIdAndJobName(Long id, Long scheduleId);
+    Optional<ScheduleTaskEntity> findByIdAndJobName(Long id, String scheduleId);
 
     List<ScheduleTaskEntity> findByJobNameAndStatusIn(String jobName, List<TaskStatus> statuses);
 

diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/service/schedule/ScheduleTaskService.java b/server/odc-service/src/main/java/com/oceanbase/odc/service/schedule/ScheduleTaskService.java
@@ -256,7 +256,8 @@ public ScheduleTaskEntity nullSafeGetById(Long id) {
     }
 
     public ScheduleTask nullSafeGetByIdAndScheduleId(Long id, Long scheduleId) {
-        Optional<ScheduleTaskEntity> scheduleEntityOptional = scheduleTaskRepository.findByIdAndJobName(id, scheduleId);
+        Optional<ScheduleTaskEntity> scheduleEntityOptional =
+                scheduleTaskRepository.findByIdAndJobName(id, scheduleId.toString());
         return scheduleTaskMapper.entityToModel(scheduleEntityOptional
                 .orElseThrow(() -> new NotFoundException(ResourceType.ODC_SCHEDULE_TASK, "id", id)));
     }