commit ebb35163f36434a632d64d95706166fc9a6eaee7
author edi_bice <edi_bice@yahoo.com> Wed Feb 17 16:53:02 2016 -0500
committer Gianmarco De Francisci Morales <gdfm@apache.org> Tue Apr 19 11:33:42 2016 +0300
tree 1e345e263625ba0620aa5a925bcec8e36d16f333
parent 381e6a91e3b5ca4c1de96264537ea670ccb7af6f

SAMOA-58: until we change samza to produce files with .avro extension

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 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;
   }