[WIP] Implement an Accurate Simulator based on Functional model #322
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
JIRA: NEMO-478: Implement an Accurate Simulator based on Functional model
Major changes:
Added
run_beam_simulator.sh
and CreatedSimulatorLauncher
to run simulator.-node_json
argumentCreated
NetworkSimulator
andContainerManageSimulator
to manage node and network specification.NetworkSimulator
manages network bandwidth and latency between nodes.ContainerManageSimulator
manages nodes cpu resources.Created
PlanSimulator
andStreamingPlanSimulator
to Emulate on the job level.ExecutorSimulator
*
StreamingPlanSimulator
has an internal timestamp and iterate cycles until the size of transferred data between tasks reaches equilibrium.Created
ExecutorSimulator
andTaskHarness
to Simulate execution of task.TaskHarness
hasDataFetchSimulator
andWriterSimulator
.DataFetchSimulator
manages the number of tuples that are read from upstream tasks.WriterSimulator
manages the number of tuples to transfer to downstream tasks.Minor changes to note:
Tests for the changes:
Other comments:
Closes #GITHUB_PR_NUMBER