在 Azkaban 流中禁用子作业

问题描述

我正在尝试禁用属于 Azkaban 流程一部分的作业，该流程本身是另一个流程的子流程，即。 Parentflow > Childflow >> Job_To_disable 指的是可以根据 execute a flow 的 Azkaban 文档传递的禁用参数，我可以完全禁用子流，但不能完全禁用子作业。我使用的示例代码如下：

  az_obj.initializeSession();
  HashMap<String,String> map = new HashMap<>();
  map.put("Sname","Student_name");
  map.put("Srno","12345");
  HashMap<String,String> disabledflows = new HashMap<>();
  disabledflows.put("children","[\"Job_To_disable\"]");
  disabledflows.put("id","Childflow");
  JSONObject disabledJSON = new JSONObject(disabledflows);
  String disabledString = disabledJSON.toString();
  HashMap<String,String> flow_options = new HashMap<>();
  flow_options.put("disabled","["+ disabledString + "]");
  JSONObject ex_data = az_obj.executeWithOptions("ProjectName","ParentFlow",flow_options,map);

也尝试过

  flow_options.put("disabled","[{\"id\":\"Childflow\",\"children\":[\"Job_To_disable\"]}]");

我正在尝试使用 Java 代码实现以下选项，但无法实现。

disabled=[{"id":"ImportFlow","children":["Job_To_disable"]}]

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

azkaban azkaban java java