Skip to content

Commit 0670ac2

Browse files
authored
Update task status on ZK if acquire was successful to reset previous state (#990)
1 parent ac72c83 commit 0670ac2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

datastream-server/src/main/java/com/linkedin/datastream/server/DatastreamTaskImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -337,6 +337,7 @@ public void acquire(Duration timeout) {
337337
});
338338

339339
_zkAdapter.acquireTask(this, timeout);
340+
setStatus(DatastreamTaskStatus.ok("Task lock acquired"));
340341
} catch (Exception e) {
341342
LOG.error(String.format("Failed to acquire task: %s with dependencies: %s", this.getDatastreamTaskName(),
342343
String.join(",", this.getDependencies())), e);

0 commit comments

Comments
 (0)