如何解决动态叉子加入问题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": "bob@aol.com","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 举报,一经查实,本站将立刻删除。