微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

在 Azkaban 流中禁用子作业

如何解决在 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 举报,一经查实,本站将立刻删除。