| commit | 3480d5fd685d283b222582eff2e8fcd99963d25a | [log] [tgz] |
|---|---|---|
| author | Madhusudan.C.S <madhusudancs@gmail.com> | Sun Apr 28 03:23:40 2013 -0700 |
| committer | Madhusudan.C.S <madhusudancs@gmail.com> | Sun Apr 28 03:23:40 2013 -0700 |
| tree | 096fd584866cc69472e6a891dc89c0ab1e04ed5f | |
| parent | f13540d23aa369d024aa1956535480b2e04a0bd2 [diff] |
Clear buffer after each new write.
diff --git a/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java b/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java index 07f6ba2..c403501 100644 --- a/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java +++ b/hyracks/hyracks-dataflow-common/src/main/java/edu/uci/ics/hyracks/dataflow/common/comm/io/FrameOutputStream.java
@@ -32,6 +32,9 @@ } public void reset(ByteBuffer buffer, boolean clear) { + if (clear) { + buffer.clear(); + } frameTupleAppender.reset(buffer, clear); }