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(stored as value in jobmodels jobModelVersion zookeeper node) - barriers/ - {jobModelVersion} barrier_state(stored as value in barriers jobModelVersion zookeeper node) - 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) |
...