[kafka] branch 2.2 updated: MINOR: log reason for fatal error in locking state dir (#7534)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 2.2
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.2 by this push:
     new 3a29f33  MINOR: log reason for fatal error in locking state dir (#7534)
3a29f33 is described below

commit 3a29f334e8720d27de7227d3522e0dbc80e293ce
Author: John Roesler <vv...@users.noreply.github.com>
AuthorDate: Thu Oct 17 02:26:36 2019 -0500

    MINOR: log reason for fatal error in locking state dir (#7534)
    
    Reviewers: Bill Bejeck <bi...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
 .../org/apache/kafka/streams/processor/internals/AbstractTask.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 @@ public abstract class AbstractTask implements Task {
             }
         } 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");