avro-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scottca...@apache.org
Subject svn commit: r1508713 - in /avro/trunk: CHANGES.txt lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java
Date Wed, 31 Jul 2013 02:30:50 GMT
Author: scottcarey
Date: Wed Jul 31 02:30:50 2013
New Revision: 1508713

URL: http://svn.apache.org/r1508713
Log:
AVRO-1144 Deadlock with FSInput and Hadoop NativeS3FileSystem

Modified:
    avro/trunk/CHANGES.txt
    avro/trunk/lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java

Modified: avro/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/avro/trunk/CHANGES.txt?rev=1508713&r1=1508712&r2=1508713&view=diff
==============================================================================
--- avro/trunk/CHANGES.txt (original)
+++ avro/trunk/CHANGES.txt Wed Jul 31 02:30:50 2013
@@ -134,6 +134,9 @@ Trunk (not yet released)
     AVRO-1292. Java: Fix potential client blocking in NettyTransceiver.
     (James Baldassari via cutting)
 
+    AVRO-1144. Java: Deadlock with FSInput and Hadoop NativeS3FileSystem.
+    (scottcarey)
+
 Avro 1.7.4 (22 February 2012)
 
   NEW FEATURES

Modified: avro/trunk/lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java
URL: http://svn.apache.org/viewvc/avro/trunk/lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java?rev=1508713&r1=1508712&r2=1508713&view=diff
==============================================================================
--- avro/trunk/lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java (original)
+++ avro/trunk/lang/java/mapred/src/main/java/org/apache/avro/mapred/FsInput.java Wed Jul
31 02:30:50 2013
@@ -34,8 +34,8 @@ public class FsInput implements Closeabl
 
   /** Construct given a path and a configuration. */
   public FsInput(Path path, Configuration conf) throws IOException {
-    this.stream = path.getFileSystem(conf).open(path);
     this.len = path.getFileSystem(conf).getFileStatus(path).getLen();
+    this.stream = path.getFileSystem(conf).open(path);
   }
 
   public long length() {



Mime
View raw message