commit c3d6933cb687961db1a59d64da8f736966669d9c
author vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Oct 06 21:04:05 2010 +0000
committer vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Oct 06 21:04:05 2010 +0000
tree 788d2395b98049e1cedea80486f8ddbeb10c8f62
parent 3f0fe94e05a0999e0b991ed96275403e5d497ed0

Fixed final flush problem

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

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

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