...
Code Block | ||
---|---|---|
| ||
- zkBaseRootPath/$appName-$appId-$JobName-$JobId-$stageId/ - processors/ - processor.000001/ - processor.000002/ ... - processor.00000N/ - jobModels/ - {jobModelVersion} JobModelObject - localityData - task01/ - physicalHostInfolocationId - task02/ - physicalHostInfolocationId ... - task0N/ - physicalHostInfo locationId |
Local store sandboxing:
In standalone landscape, the file system location to persist the local state should be provided by the users through stream processor configuration(by defining local.store.dir configuration). The configuration `local.store.dir` is expected to be preserved across processor restarts to reuse preexisting local state. It’s expected that the stream processor java process will be configured by user to run with sufficient read/write permissions to access the local state directories created by any processor in the group. The local store file hierarchy/organization followed in samza-yarn deployment model for both high and low level API will be followed in standalone.
...