http://git-wip-us.apache.org/repos/asf/tajo/blob/4841c656/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
----------------------------------------------------------------------
diff --git
a/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
b/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
index ebf557e..db9f3c8 100644
---
a/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
+++
b/tajo-storage/tajo-storage-hbase/src/main/java/org/apache/tajo/storage/hbase/SortedInsertRewriter.java
@@ -22,8 +22,9 @@ import org.apache.tajo.OverridableConf;
import org.apache.tajo.catalog.Column;
import org.apache.tajo.catalog.Schema;
import org.apache.tajo.catalog.SortSpec;
+import org.apache.tajo.exception.TajoException;
+import org.apache.tajo.exception.TajoInternalError;
import org.apache.tajo.plan.LogicalPlan;
-import org.apache.tajo.plan.PlanningException;
import org.apache.tajo.plan.logical.*;
import org.apache.tajo.plan.logical.SortNode.SortPurpose;
import org.apache.tajo.plan.rewrite.LogicalPlanRewriteRule;
@@ -68,7 +69,7 @@ public class SortedInsertRewriter implements
LogicalPlanRewriteRule {
}
@Override
- public LogicalPlan rewrite(OverridableConf queryContext, LogicalPlan plan)
throws PlanningException {
+ public LogicalPlan rewrite(OverridableConf queryContext, LogicalPlan plan)
throws TajoException {
LogicalRootNode rootNode = plan.getRootBlock().getRoot();
StoreTableNode storeTable = rootNode.getChild();
@@ -78,7 +79,7 @@ public class SortedInsertRewriter implements
LogicalPlanRewriteRule {
try {
sortColumns = getIndexColumns(tableSchema, storeTable.getOptions());
} catch (IOException e) {
- throw new PlanningException(e);
+ throw new TajoInternalError(e);
}
int[] sortColumnIndexes = new int[sortColumns.length];
@@ -101,7 +102,7 @@ public class SortedInsertRewriter implements
LogicalPlanRewriteRule {
for (int i = 0; i < sortColumnIndexes.length; i++) {
Column sortColumn = sortSchema.getColumn(sortColumnIndexes[i]);
if (sortColumn == null) {
- throw new PlanningException("Can't fine proper sort column:" +
sortColumns[i]);
+ throw new TajoInternalError("Can't fine proper sort column:" +
sortColumns[i]);
}
sortSpecs[index++] = new SortSpec(sortColumn, true, true);
}