Skip to content

Commit 1a458e8

Browse files
authored
[Fix][Zeta] Fix typo in isPhysicalDAGInfo (#9840)
1 parent fa1202c commit 1a458e8

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/DAGUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,14 +98,14 @@ public static JobDAGInfo getJobDAGInfo(
9898
LogicalDag logicalDag,
9999
JobImmutableInformation jobImmutableInformation,
100100
EngineConfig engineConfig,
101-
boolean isPhysicalDAGIInfo,
101+
boolean isPhysicalDAGInfo,
102102
ExecutionAddress master,
103103
Set<ExecutionAddress> historyExecutionAddress) {
104104
List<Pipeline> pipelines =
105105
new ExecutionPlanGenerator(logicalDag, jobImmutableInformation, engineConfig)
106106
.generate()
107107
.getPipelines();
108-
if (isPhysicalDAGIInfo) {
108+
if (isPhysicalDAGInfo) {
109109
// Generate ExecutePlan DAG
110110
Map<Integer, List<Edge>> pipelineWithEdges = new HashMap<>();
111111
Map<Long, VertexInfo> vertexInfoMap = new HashMap<>();

seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ public class JobMaster {
151151
private final IMap<Object, Object> runningJobStateTimestampsIMap;
152152

153153
// TODO add config to change value
154-
private boolean isPhysicalDAGIInfo = true;
154+
private boolean isPhysicalDAGInfo = true;
155155

156156
private final EngineConfig engineConfig;
157157

@@ -643,7 +643,7 @@ public JobDAGInfo getJobDAGInfo() {
643643
logicalDag,
644644
jobImmutableInformation,
645645
engineConfig,
646-
isPhysicalDAGIInfo,
646+
isPhysicalDAGInfo,
647647
new ExecutionAddress(
648648
this.nodeEngine.getThisAddress().getHost(),
649649
this.nodeEngine.getThisAddress().getPort()),

0 commit comments

Comments
 (0)