SAMOA-58: until we change samza to produce files with .avro extension
Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/ebb35163 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/ebb35163 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/ebb35163 Branch: refs/heads/master Commit: ebb35163f36434a632d64d95706166fc9a6eaee7 Parents: 381e6a9 Author: edi_bice <[email protected]> Authored: Wed Feb 17 16:53:02 2016 -0500 Committer: Gianmarco De Francisci Morales <[email protected]> Committed: Tue Apr 19 11:33:42 2016 +0300 ---------------------------------------------------------------------- .../src/main/java/org/apache/samoa/streams/AvroFileStream.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/ebb35163/samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java ---------------------------------------------------------------------- diff --git a/samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java b/samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java index 15229a4..5b4e755 100644 --- a/samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java +++ b/samoa-api/src/main/java/org/apache/samoa/streams/AvroFileStream.java @@ -139,7 +139,8 @@ public class AvroFileStream extends FileStream { public void prepareForUseImpl(TaskMonitor monitor, ObjectRepository repository) { super.prepareForUseImpl(monitor, repository); String filePath = this.avroFileOption.getFile().getAbsolutePath(); - this.fileSource.init(filePath, AvroFileStream.AVRO_FILE_EXTENSION); + //this.fileSource.init(filePath, AvroFileStream.AVRO_FILE_EXTENSION); + this.fileSource.init(filePath, null); this.lastInstanceRead = null; }
