Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
- 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)

...