Repository: tajo Updated Branches: refs/heads/master c50a5dadf -> 4841c656f
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); }
