sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264469001
##########
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##########
@@ -59,13 +67,23 @@
public class LocalApplicationRunner implements ApplicationRunner {
private static final Logger LOG =
LoggerFactory.getLogger(LocalApplicationRunner.class);
+ private static final String RUNID_PATH = "runId";
+ private static final String APPLICATION_RUNNER_PATH_SUFFIX =
"/ApplicationRunnerData";
+ private static final String RUNID_LOCK_ID = "runId";
+ private static final int LOCK_TIMEOUT = 10;
+ private static final TimeUnit LOCK_TIMEOUT_UNIT = TimeUnit.MINUTES;
private final ApplicationDescriptorImpl<? extends ApplicationDescriptor>
appDesc;
private final LocalJobPlanner planner;
private final Set<StreamProcessor> processors =
ConcurrentHashMap.newKeySet();
private final CountDownLatch shutdownLatch = new CountDownLatch(1);
private final AtomicInteger numProcessorsToStart = new AtomicInteger();
private final AtomicReference<Throwable> failure = new AtomicReference<>();
+ private final String uid = UUID.randomUUID().toString();
+ private CoordinationUtils coordinationUtils = null;
+ private DistributedReadWriteLock runIdLock = null;
+ private DistributedDataAccess runIdAccess = null;
+ private String runId = null;
Review comment:
make final. Assign null if needed in the constructor.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
