vvcephei commented on a change in pull request #9010:
URL: https://github.com/apache/kafka/pull/9010#discussion_r453133360
##########
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##########
@@ -507,4 +510,51 @@ public void
shouldLockGlobalStateDirectoryWhenDirectoryCreationDisabled() throws
initializeStateDirectory(false);
assertTrue(directory.lockGlobalState());
}
+
+ @Test
+ public void shouldNotFailWhenCreatingTaskDirectoryInParallel() throws
Exception {
Review comment:
In retrospect, this makes sense. The fs operations probably take an
order of magnitude more time than the difference in time between starting the
two threads. Thanks for adding it!
----------------------------------------------------------------
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
