动态叉子加入问题Netflix Conductor

问题描述

尝试在Conductor中使用FORK_JOIN_DYNAMIC任务，我相信我的数据映射或其结构可能有问题吗？

我继续查看示例和此处的另一篇文章（由saidatta解决），但存在相同的问题，但是我必须在映射中缺少一些内容。

工作流程定义：

    {
  "createTime": 1602706631958,"name": "Video2Frames","description": "VideoOutputTest","version": 4,"tasks": [
    {
      "name": "OutputVideoFrames","taskReferenceName": "video2frames","inputParameters": {
        "videoFileLocation": "${workflow.input.videFileLocation}","imageOutputDirPath": "${workflow.input.imageOutputDirPath}"
      },"type": "SIMPLE","decisionCases": {},"defaultCase": [],"forkTasks": [],"startDelay": 0,"joinOn": [],"optional": false,"defaultExclusiveJoinTask": [],"asyncComplete": false,"loopOver": []
    },{
      "name": "DynamicVideo2Frames","taskReferenceName": "DynamicVideo2Frames","inputParameters": {
        "dynamicTasksJSON": "${video2frames.output.dynamicTasksJSON}","dynamicTaskInputJSON": "${video2frames.output.dynamicTaskInputJSON}"
      },"type": "FORK_JOIN_DYNAMIC","dynamicForkTasksParam": "dynamicTasksJSON","dynamicForkTasksInputParamName": "dynamicTaskInputJSON",{
      "name": "dynamic_join","taskReferenceName": "join1","inputParameters": {},"type": "JOIN","loopOver": []
    }
  ],"inputParameters": [],"outputParameters": {
    "statues": "","workflowIds": ""
  },"schemaVersion": 2,"restartable": true,"workflowStatusListenerEnabled": false,"ownerEmail": "[email protected]","timeoutPolicy": "ALERT_ONLY","timeoutSeconds": 0,"variables": {}
}

OutputVideoFrames输出：

{
  "dynamicTasksInputJSON": {
    "video2frames1": {
      "width": 100,"height": 100,"params": {
        "recipe": "jpg"
      }
    },"video2frames2": {
      "width": 200,"height": 200,"params": {
        "recipe": "jpg"
      }
    }
  },"dynamicTasksJSON": [
    {
      "name": "DynamicVideo2Frames","taskReferenceName": "video2frames1","type": "SIMPLE"
    },"taskReferenceName": "video2frames2","type": "SIMPLE"
    }
  ]
}

错误：

Input to the dynamically forked tasks is not a map -> expecting a map of K,V but found null

解决方法

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

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

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