kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: add logfilename to error message when file missing
Date Tue, 03 May 2016 17:22:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 2f39fb0d1 -> e6d814a3e


MINOR: add logfilename to error message when file missing

ewencp

Author: dan norwood <norwood@confluent.io>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1307 from norwood/log-filename-when-missing-file

(cherry picked from commit 62253539d87e1ccb353673ed96adc98fb2d854ae)
Signed-off-by: Ewen Cheslack-Postava <me@ewencp.org>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e6d814a3
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e6d814a3
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e6d814a3

Branch: refs/heads/0.10.0
Commit: e6d814a3eb2998a3172404385f1a9010f42d5425
Parents: 2f39fb0
Author: dan norwood <norwood@confluent.io>
Authored: Tue May 3 10:21:57 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Tue May 3 10:22:24 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/file/FileStreamSourceTask.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/e6d814a3/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
----------------------------------------------------------------------
diff --git a/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
b/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
index af50d4d..14d944f 100644
--- a/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
+++ b/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
@@ -103,7 +103,7 @@ public class FileStreamSourceTask extends SourceTask {
                 reader = new BufferedReader(new InputStreamReader(stream));
                 log.debug("Opened {} for reading", logFilename());
             } catch (FileNotFoundException e) {
-                log.warn("Couldn't find file for FileStreamSourceTask, sleeping to wait for
it to be created");
+                log.warn("Couldn't find file {} for FileStreamSourceTask, sleeping to wait
for it to be created", logFilename());
                 synchronized (this) {
                     this.wait(1000);
                 }


Mime
View raw message