opt

MactavishCui · Jan 2, 2025 · dceb03a · dceb03a
1 parent b6595b6
commit dceb03a
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/JobInstanceServiceImpl.java
@@ -297,13 +297,7 @@ public void refreshJobByTaskIds(Integer... taskIds) {
     @Override
     public LineageResult getLineage(Integer id) {
         History history = getJobInfoDetail(id).getHistory();
-        ExecutorConfig config = ExecutorConfig.builder()
-                .checkpoint(0)
-                .parallelism(1)
-                .useSqlFragment(true)
-                .variables(fragmentVariableService.listEnabledVariables())
-                .build();
-        return LineageBuilder.getColumnLineageByLogicalPlan(history.getStatement(), config);
+        return LineageBuilder.getColumnLineageByLogicalPlan(history.getStatement(), history.getConfigJson());
     }
 
     @Override