You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by ji...@apache.org on 2013/05/09 09:50:55 UTC
git commit: TAJO-48: BufferUnderflowException occurs during the
initialization of RowFile. (jihoon)
Updated Branches:
refs/heads/master 2923f4e3b -> adb6b3e17
TAJO-48: BufferUnderflowException occurs during the initialization of RowFile. (jihoon)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tajo/commit/adb6b3e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tajo/tree/adb6b3e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tajo/diff/adb6b3e1
Branch: refs/heads/master
Commit: adb6b3e1751b939607dafd1a4f7422e21bd731e7
Parents: 2923f4e
Author: Jihoon Son <ji...@apache.org>
Authored: Thu May 9 16:49:27 2013 +0900
Committer: Jihoon Son <ji...@apache.org>
Committed: Thu May 9 16:49:27 2013 +0900
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../src/main/java/tajo/storage/RowFile.java | 3 +++
2 files changed, 5 insertions(+), 0 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/adb6b3e1/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 7dd10de..2599759 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -39,6 +39,8 @@ Release 0.2.0 - unreleased
BUG FIXES
+ TAJO-48: BufferUnderflowException occurs during the initialization of RowFile. (jihoon)
+
TAJO-58: Remove obsolete methods in GlobalPlanner. (hyunsik)
TAJO-54: SubQuery::allocateContainers() may ask 0 containers. (hyunsik)
http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/adb6b3e1/tajo-core/tajo-core-storage/src/main/java/tajo/storage/RowFile.java
----------------------------------------------------------------------
diff --git a/tajo-core/tajo-core-storage/src/main/java/tajo/storage/RowFile.java b/tajo-core/tajo-core-storage/src/main/java/tajo/storage/RowFile.java
index 91f6715..4882d1b 100644
--- a/tajo-core/tajo-core-storage/src/main/java/tajo/storage/RowFile.java
+++ b/tajo-core/tajo-core-storage/src/main/java/tajo/storage/RowFile.java
@@ -102,6 +102,9 @@ public class RowFile {
// TODO: improve
boolean syncFound = false;
while (!syncFound) {
+ if (buffer.remaining() < SYNC_SIZE) {
+ fillBuffer();
+ }
buffer.mark();
syncFound = checkSync();
if (!syncFound) {