Commit dc687f4c authored by mcb's avatar mcb

commit

parent 72413f6c
...@@ -619,7 +619,7 @@ public class OfflineSynchServiceImpl implements OfflineSynchService { ...@@ -619,7 +619,7 @@ public class OfflineSynchServiceImpl implements OfflineSynchService {
DmpDevelopTask task = new DmpDevelopTask(); DmpDevelopTask task = new DmpDevelopTask();
task.setProjectId(projectId); task.setProjectId(projectId);
task.setParentId(parentId); //task.setParentId(parentId);
task.setTaskType("2"); //任务类型 task.setTaskType("2"); //任务类型
task.setDatasourceId(dataSourceId); //数据源ID task.setDatasourceId(dataSourceId); //数据源ID
task.setType("3"); task.setType("3");
......
...@@ -83,14 +83,14 @@ ...@@ -83,14 +83,14 @@
"params": { "params": {
"version": "1.0", "version": "1.0",
"treeId": 669, "treeId": 669,
"parentId": "509", //"parentId": "509",
"mode": "0", "mode": "0",
"projectId": "31", "projectId": "31",
"taskId":"", //任务id "taskId":"", //任务id
"taskName": "dmp_demo_dmp_azkaban_exector_server_config", //任务名称 "taskName": "dmp_demo_dmp_azkaban_exector_server_config", //任务名称
"scripts": { "scripts": {
"setting": { "setting": {
"extract": "incremental", "extract": "incremental", //增量/全量
"extractExpression": "where 1=1", //增量表达式 "extractExpression": "where 1=1", //增量表达式
"targetInsertMergeOverwrite": "insert", //插入合并重写 "targetInsertMergeOverwrite": "insert", //插入合并重写
"ftColumn": "分桶字段", "ftColumn": "分桶字段",
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment