eye-gu commented on issue #18335: URL: https://github.com/apache/dolphinscheduler/issues/18335#issuecomment-4670634970
This proposal does not modify parameters of a running task.The override happens before the downstream task starts. The flow is: 1. Upstream task finishes → outputs dsInternal.* params via VarPool 2. Master use VarPool overrides task instance 3. Downstream task launches with the overridden config So in your example, we don't modify slot while Flink is running. We set the slot before submitting the Flink job. It's essentially "start the next task with different configs than its definition" -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
