

我有一个SCDF Steam,它由HTTP Source - Custom Processor和Task Launcher Dataflow Sink组成。我正在尝试将属性从处理器传递到任务启动器数据流和子任务。我已经尝试在处理器中构建要发送到任务启动器数据流的消息,如下所示...
{
"args":["--spring.profiles.active=prod","--dataflow-server-uri=http://spring-cloud-dataflow-server:8080"],
"name":"composedtask-filecopy2",
"deploymentProps":{"runID":"e6ac18d2-f53f-11eb-9a03-0242ac130003"}
}这些属性可以到达合成任务,但不能到达子任务。
将它们传递给子任务的部署属性的格式是什么?
发布于 2021-08-05 17:54:38
将应用程序/部署器属性传递到组合任务图中的子任务的一般过程记录在here中。
也就是说,tasklauncher-sink负责在您的用例中的每个上游HTTP事件上启动此图。要在此方法中将部署器属性传递给子任务,您将使用类似的复合前缀作为键,以及所需的值来包装部署器属性。
例如,如果您想要将部署程序属性传递给图形中的prescript任务,您可能需要尝试:
{ "args":"--spring.profiles.active=prod","--dataflow-server-uri=http://spring-cloud-dataflow-server:8080","name":"composedtask-filecopy2","deploymentProps":{"deployer.composedtask-filecopy2.prescript.memory":"2048m"} }
https://stackoverflow.com/questions/68670331
复制相似问题