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:19 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk bf578f987 -> 62253539d


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


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

Branch: refs/heads/trunk
Commit: 62253539d87e1ccb353673ed96adc98fb2d854ae
Parents: bf578f9
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:21:57 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/62253539/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