Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 7cbb2b9ea -> eb93526ce
Some phoenix-spark IT tests are broken after PHOENIX-2862 Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/eb93526c Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/eb93526c Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/eb93526c Branch: refs/heads/4.x-HBase-0.98 Commit: eb93526ce009c677c0e75e7a88cde4ee00bb2cd0 Parents: 7cbb2b9 Author: Ankit Singhal <ankitsingha...@gmail.com> Authored: Sat May 21 09:44:16 2016 +0530 Committer: Ankit Singhal <ankitsingha...@gmail.com> Committed: Sat May 21 09:44:16 2016 +0530 ---------------------------------------------------------------------- .../main/java/org/apache/phoenix/mapreduce/index/IndexTool.java | 2 +- .../src/main/java/org/apache/phoenix/util/SchemaUtil.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/eb93526c/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index 34694c6..6743688 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -358,7 +358,7 @@ public class IndexTool extends Configured implements Tool { final String indexTable) throws SQLException { final DatabaseMetaData dbMetaData = connection.getMetaData(); final String schemaName = SchemaUtil.getSchemaNameFromFullName(masterTable); - final String tableName = SchemaUtil.getTableNameFromFullName(masterTable); + final String tableName = SchemaUtil.normalizeIdentifier(SchemaUtil.getTableNameFromFullName(masterTable)); ResultSet rs = null; try { http://git-wip-us.apache.org/repos/asf/phoenix/blob/eb93526c/phoenix-core/src/main/java/org/apache/phoenix/util/SchemaUtil.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/util/SchemaUtil.java b/phoenix-core/src/main/java/org/apache/phoenix/util/SchemaUtil.java index cb1ef47..41e5704 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/util/SchemaUtil.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/util/SchemaUtil.java @@ -641,7 +641,7 @@ public class SchemaUtil { if (tableName == null) { return null; } - if (isExistingTableMappedToPhoenixName(Bytes.toString(tableName))) { return normalizeIdentifier(Bytes.toString(tableName)); } + if (isExistingTableMappedToPhoenixName(Bytes.toString(tableName))) { return Bytes.toString(tableName); } int index = indexOf(tableName, QueryConstants.NAME_SEPARATOR_BYTE); if (index < 0) { index = indexOf(tableName, QueryConstants.NAMESPACE_SEPARATOR_BYTE); @@ -651,7 +651,7 @@ public class SchemaUtil { } public static String getTableNameFromFullName(String tableName) { - if (isExistingTableMappedToPhoenixName(tableName)) { return normalizeIdentifier(tableName); } + if (isExistingTableMappedToPhoenixName(tableName)) { return tableName; } if (tableName.contains(QueryConstants.NAMESPACE_SEPARATOR)) { return getTableNameFromFullName(tableName, QueryConstants.NAMESPACE_SEPARATOR); } return getTableNameFromFullName(tableName, QueryConstants.NAME_SEPARATOR);
