Skip to content

Commit a6e8211

Browse files
committed
[Improve][Zeta] Simplify multiple table parser restore constructors
1 parent 82934e0 commit a6e8211

1 file changed

Lines changed: 10 additions & 54 deletions

File tree

seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java

Lines changed: 10 additions & 54 deletions
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,15 @@ public class MultipleTableJobConfigParser {
141141
@VisibleForTesting
142142
public MultipleTableJobConfigParser(
143143
String jobDefineFilePath, IdGenerator idGenerator, JobConfig jobConfig) {
144-
this(jobDefineFilePath, idGenerator, jobConfig, Collections.emptyList(), RestoreMode.NONE);
144+
this(
145+
jobDefineFilePath,
146+
null,
147+
idGenerator,
148+
jobConfig,
149+
Collections.emptyList(),
150+
RestoreMode.NONE,
151+
Collections.emptyList(),
152+
new MetadataConfig());
145153
}
146154

147155
@VisibleForTesting
@@ -164,51 +172,17 @@ public MultipleTableJobConfigParser(
164172
JobConfig jobConfig,
165173
List<URL> commonPluginJars,
166174
boolean isStartWithSavePoint) {
167-
this(
168-
jobDefineFilePath,
169-
idGenerator,
170-
jobConfig,
171-
commonPluginJars,
172-
isStartWithSavePoint ? RestoreMode.SAVEPOINT : RestoreMode.NONE);
173-
}
174-
175-
public MultipleTableJobConfigParser(
176-
String jobDefineFilePath,
177-
IdGenerator idGenerator,
178-
JobConfig jobConfig,
179-
List<URL> commonPluginJars,
180-
RestoreMode restoreMode) {
181175
this(
182176
jobDefineFilePath,
183177
null,
184178
idGenerator,
185179
jobConfig,
186180
commonPluginJars,
187-
restoreMode,
181+
isStartWithSavePoint ? RestoreMode.SAVEPOINT : RestoreMode.NONE,
188182
Collections.emptyList(),
189183
new MetadataConfig());
190184
}
191185

192-
public MultipleTableJobConfigParser(
193-
String jobDefineFilePath,
194-
List<String> variables,
195-
IdGenerator idGenerator,
196-
JobConfig jobConfig,
197-
List<URL> commonPluginJars,
198-
boolean isStartWithSavePoint,
199-
List<JobPipelineCheckpointData> pipelineCheckpoints,
200-
MetadataConfig metaDataConfig) {
201-
this(
202-
jobDefineFilePath,
203-
variables,
204-
idGenerator,
205-
jobConfig,
206-
commonPluginJars,
207-
isStartWithSavePoint ? RestoreMode.SAVEPOINT : RestoreMode.NONE,
208-
pipelineCheckpoints,
209-
metaDataConfig);
210-
}
211-
212186
public MultipleTableJobConfigParser(
213187
String jobDefineFilePath,
214188
List<String> variables,
@@ -228,24 +202,6 @@ public MultipleTableJobConfigParser(
228202
metaDataConfig);
229203
}
230204

231-
public MultipleTableJobConfigParser(
232-
Config seaTunnelJobConfig,
233-
IdGenerator idGenerator,
234-
JobConfig jobConfig,
235-
List<URL> commonPluginJars,
236-
boolean isStartWithSavePoint,
237-
List<JobPipelineCheckpointData> pipelineCheckpoints,
238-
MetadataConfig metaDataConfig) {
239-
this(
240-
seaTunnelJobConfig,
241-
idGenerator,
242-
jobConfig,
243-
commonPluginJars,
244-
isStartWithSavePoint ? RestoreMode.SAVEPOINT : RestoreMode.NONE,
245-
pipelineCheckpoints,
246-
metaDataConfig);
247-
}
248-
249205
public MultipleTableJobConfigParser(
250206
Config seaTunnelJobConfig,
251207
IdGenerator idGenerator,

0 commit comments

Comments
 (0)