-
Type:
Improvement
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 1.4
-
Component/s: None
-
Labels:None
JobModelManager uses CoordinatorStreamStore.put() to save job model information which does flush for each message.
The flush operation in CoordinatorStreamStore is very heavy, so it may take over a very long time for AM to save the information in a run.
We should use CoordinatorStreamStore's batch put instead of single put.
- links to