All, I ran into a situation where I need to pass params/values to tasks as they are launched from the scheduler. The only mechanism that I see is Command.Environment variables.
However, when I attempt to launch tasks with same environment variable names, the master rejects subsequent tasks with the taskinfo as invalid due task already exists (paraphrase) and the task is marked as TASK_LOST. Is there another way to reliably pass params/values to a task? In my situation, I want to launch a task (upon resource offer) and pass a new value to the task upon each Executor.launch callback. Thanks. -- Vladimir Vivien