Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
- Description
On supporting LambdaExecutor, this issue relates to allowing user to specify which type of executor they need, and refactor the dependency classes to runtime/common to avoid cyclic dependencies.
- # # Major changes:
- Provide user argument to use the new representer
- Refactor task state manager and metric manager from runtime executor to runtime common
- Other comments:
Try it out by
```
./bin/run_beam.sh \
-job_id wordCount_testexecutor \
-executor_json `pwd`/examples/resources/executors/beam_test_executor_resources.json \
-optimization_policy org.apache.nemo.compiler.optimizer.policy.DefaultPolicy \
-user_main org.apache.nemo.examples.beam.WordCount \
-executor_type lambda \
-user_args "`pwd`/examples/resources/inputs/test_input_wordcount `pwd`/outputs/wordcount --numEventGenerators=1"
```
Attachments
Issue Links
- is a child of
-
NEMO-398 ExecutorRepresenter interface and LambdaExecutorRepresenter
- Resolved
- links to