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: Delete unused code in FileStreamSourceTask
Date Fri, 27 May 2016 06:21:36 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9355427ef -> ebed7ce36


MINOR: Delete unused code in FileStreamSourceTask

Author: leisore <leisore@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>, Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1433 from leisore/master


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

Branch: refs/heads/trunk
Commit: ebed7ce3604d32d1b502888bc188904b43e5674f
Parents: 9355427
Author: leisore <leisore@gmail.com>
Authored: Thu May 26 23:21:20 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Thu May 26 23:21:20 2016 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/ebed7ce3/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 14d944f..bab3f77 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
@@ -146,7 +146,6 @@ public class FileStreamSourceTask extends SourceTask {
                                 records = new ArrayList<>();
                             records.add(new SourceRecord(offsetKey(filename), offsetValue(streamOffset),
topic, VALUE_SCHEMA, line));
                         }
-                        new ArrayList<SourceRecord>();
                     } while (line != null);
                 }
             }


Mime
View raw message