commit 7c84bfb64e09f86a5cdef851ee6d4c5ec328d2d9
author vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Oct 06 21:26:19 2010 +0000
committer vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Oct 06 21:26:19 2010 +0000
tree 7096ef133a744c24fb51789fffb071d036f115e6
parent 08f5d763aa804d0db786356b1438b306e625dce2

Fixed problem with closing writer

git-svn-id: https://hyracks.googlecode.com/svn/trunk/hyracks@143 123451ca-8445-de46-9d55-352943316053

hyracks-dataflow-hadoop/src/main/java/edu/uci/ics/hyracks/dataflow/hadoop/HadoopReadOperatorDescriptor.java

diff --git a/hyracks-dataflow-hadoop/src/main/java/edu/uci/ics/hyracks/dataflow/hadoop/HadoopReadOperatorDescriptor.java b/hyracks-dataflow-hadoop/src/main/java/edu/uci/ics/hyracks/dataflow/hadoop/HadoopReadOperatorDescriptor.java
index 0c75d30..53d1a7f 100644
--- a/hyracks-dataflow-hadoop/src/main/java/edu/uci/ics/hyracks/dataflow/hadoop/HadoopReadOperatorDescriptor.java
+++ b/hyracks-dataflow-hadoop/src/main/java/edu/uci/ics/hyracks/dataflow/hadoop/HadoopReadOperatorDescriptor.java
@@ -159,6 +159,7 @@
                     if (appender.getTupleCount() > 0) {
                         FrameUtils.flushFrame(outBuffer, writer);
                     }
+                    writer.close();
                     hadoopRecordReader.close();
                 } catch (InstantiationException e) {
                     throw new HyracksDataException(e);