diff --git a/client/migrationx/migrationx-transformer/src/main/java/com/aliyun/dataworks/migrationx/transformer/dataworks/converter/adf/AdfConverter.java b/client/migrationx/migrationx-transformer/src/main/java/com/aliyun/dataworks/migrationx/transformer/dataworks/converter/adf/AdfConverter.java index f3a0e56..92f3159 100644 --- a/client/migrationx/migrationx-transformer/src/main/java/com/aliyun/dataworks/migrationx/transformer/dataworks/converter/adf/AdfConverter.java +++ b/client/migrationx/migrationx-transformer/src/main/java/com/aliyun/dataworks/migrationx/transformer/dataworks/converter/adf/AdfConverter.java @@ -53,7 +53,11 @@ public List convert() throws Exception { flows.add(toWorkflow(pipeline, trigger)); } for(SpecWorkflow flow : flows) { - flow.setCitable(citableFlowIds.contains(flow.getId())); + boolean citable = citableFlowIds.contains(flow.getId()); + flow.setCitable(citable); + if (citable) { + flow.getTrigger().setType(TriggerType.NONE); + } } return flows; }