THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
- zkBaseRootPath/$appName-$appId-$JobName-$JobId-$stageId/ - processors/ - processor.000001/ - locatoinId1(stored as value in processor zookeeper node) - processor.000002/ - locationId2(stored as value in processor zookeeper node) ... - processor.00000N/ - locationIdN(stored as value in processor zookeeper node) - jobModels/ - {jobModelVersion} JobModelObject - barriers/ - {jobModelVersion} barrier_state - localityData - task01/ - locationId1(stored as value in task zookeeper node) - task02/ - locationId2(stored as value in task zookeeper node) ... - task0N/ - locationIdN(stored as value in task zookeeper node) |
...