add java memory on dataX java launch params

datavane · Apr 13, 2024 · 96f2d37 · 96f2d37
1 parent d57f781
commit 96f2d37
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/tis-assemble/src/main/java/com/qlangtech/tis/exec/impl/DefaultChainContext.java b/tis-assemble/src/main/java/com/qlangtech/tis/exec/impl/DefaultChainContext.java
@@ -65,6 +65,10 @@ public class DefaultChainContext implements IExecChainContext {
  // 执行阶段跨度
  private ExecutePhaseRange executePhaseRange;
 
+ @Override
+ public String getJavaMemSpec() {
+ return null;
+ }
 // @Override
 // public TableDumpFactory getTableDumpFactory() {
 // throw new UnsupportedOperationException();

diff --git a/tis-sql-parser/src/main/java/com/qlangtech/tis/sql/parser/SqlTaskNodeMeta.java b/tis-sql-parser/src/main/java/com/qlangtech/tis/sql/parser/SqlTaskNodeMeta.java
@@ -225,6 +225,11 @@ public String getIndexName() {
  return null;
  }
 
+ @Override
+ public String getJavaMemSpec() {
+ return null;
+ }
+
  @Override
  public boolean isDryRun() {
  return false;
@@ -1023,6 +1028,11 @@ public DftJoinTaskContext(ExecutePhaseRange executePhaseRange) {
  this.executePhaseRange = executePhaseRange;
  }
 
+ @Override
+ public String getJavaMemSpec() {
+ return null;
+ }
+
  @Override
  public String getIndexName() {
  return null;