ableegoldman commented on a change in pull request #10342:
URL: https://github.com/apache/kafka/pull/10342#discussion_r596446057
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##########
@@ -86,15 +86,8 @@ static void registerStateStores(final Logger log,
}
final TaskId id = stateMgr.taskId();
- try {
- if (!stateDirectory.lock(id)) {
- throw new LockException(String.format("%sFailed to lock the
state directory for task %s", logPrefix, id));
- }
- } catch (final IOException e) {
- throw new StreamsException(
- String.format("%sFatal error while trying to lock the state
directory for task %s", logPrefix, id),
- e
- );
+ if (!stateDirectory.lock(id)) {
+ throw new LockException(String.format("%sFailed to lock the state
directory for task %s", logPrefix, id));
Review comment:
No logical changes here (or below in TaskManager), just cleaning up the
try-catch block now that we no longer throw IOException
----------------------------------------------------------------
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:
[email protected]
