commit 3a29f334e8720d27de7227d3522e0dbc80e293ce
author John Roesler <vvcephei@users.noreply.github.com> Thu Oct 17 02:26:36 2019 -0500
committer Matthias J. Sax <matthias@confluent.io> Thu Oct 17 00:49:58 2019 -0700
tree befca9a3e5aefa9b86830eeffe0c0d41315cbb9e
parent da39763a31cab9a2c177a33a7e3ae6457a223154

MINOR: log reason for fatal error in locking state dir (#7534)

Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>

streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
index 3387801..aa1391c 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java
@@ -220,8 +220,9 @@
             }
         } catch (final IOException e) {
             throw new StreamsException(
-                String.format("%sFatal error while trying to lock the state directory for task %s",
-                logPrefix, id));
+                String.format("%sFatal error while trying to lock the state directory for task %s", logPrefix, id),
+                e
+            );
         }
         log.trace("Initializing state stores");