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);
     }

Reply via email to