We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e12db66 commit 512e0c9Copy full SHA for 512e0c9
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
@@ -482,7 +482,6 @@ synchronized boolean lock(final TaskId taskId) {
482
throw new IllegalStateException("The state directory has been deleted");
483
} else {
484
lockedTasksToOwner.put(taskId, Thread.currentThread());
485
- // make sure the task directory actually exists, and create it if not
486
return true;
487
}
488
0 commit comments