Repository: kafka Updated Branches: refs/heads/trunk 9355427ef -> ebed7ce36
MINOR: Delete unused code in FileStreamSourceTask Author: leisore <[email protected]> Reviewers: Ismael Juma <[email protected]>, Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Thu May 26 23:21:20 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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); } }
