fix(taskframework): fix refresh entity replaced by native sql (#2145)

* add findByIdNative * remove unnecessay code
oceanbase · Apr 2, 2024 · a0b4518 · a0b4518
1 parent 884e60b
commit a0b4518
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/metadb/task/JobRepository.java b/server/odc-service/src/main/java/com/oceanbase/odc/metadb/task/JobRepository.java
@@ -15,6 +15,8 @@
  */
 package com.oceanbase.odc.metadb.task;
 
+import java.util.Optional;
+
 import javax.transaction.Transactional;
 
 import org.springframework.data.jpa.repository.JpaRepository;
@@ -60,4 +62,6 @@ public interface JobRepository extends JpaRepository<JobEntity, Long>,
     @Modifying
     int updateJobStatusAndExecutionTimesById(@Param("param") JobEntity entity);
 
+    @Query(value = "SELECT * FROM job_job WHERE id = ?1", nativeQuery = true)
+    Optional<JobEntity> findByIdNative(Long id);
 }
diff --git a/...service/src/main/java/com/oceanbase/odc/service/task/service/StdTaskFrameworkService.java b/...service/src/main/java/com/oceanbase/odc/service/task/service/StdTaskFrameworkService.java
@@ -110,10 +110,8 @@ public class StdTaskFrameworkService implements TaskFrameworkService {
 
     @Override
     public JobEntity find(Long id) {
-        JobEntity jobEntity = jobRepository.findById(id)
+        return jobRepository.findByIdNative(id)
                 .orElseThrow(() -> new NotFoundException(ResourceType.ODC_TASK, "id", id));
-        entityManager.refresh(jobEntity);
-        return jobEntity;
     }
 
     @Override