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 <[email protected]> Authored: Thu May 9 16:49:27 2013 +0900 Committer: Jihoon Son <[email protected]> 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) {
