You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by gj...@apache.org on 2019/05/30 18:49:16 UTC
[phoenix] 02/03: PHOENIX-4703 Make indextool changes to drop before
rebuild
This is an automated email from the ASF dual-hosted git repository.
gjacoby pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
commit d218e6135b3f02487b906d031ebefc160ae78ea7
Author: Gokcen Iskender <gi...@salesforce.com>
AuthorDate: Fri Apr 26 15:50:06 2019 -0700
PHOENIX-4703 Make indextool changes to drop before rebuild
---
.../org/apache/phoenix/end2end/IndexToolForDeleteBeforeRebuildIT.java | 2 --
.../src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java | 1 -
.../src/main/java/org/apache/phoenix/schema/MetaDataClient.java | 1 +
3 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForDeleteBeforeRebuildIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForDeleteBeforeRebuildIT.java
index 4a08a27..abc0baf 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForDeleteBeforeRebuildIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolForDeleteBeforeRebuildIT.java
@@ -20,7 +20,6 @@ package org.apache.phoenix.end2end;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import org.apache.hadoop.conf.Configuration;
-
import org.apache.hadoop.hbase.client.Table;
import org.apache.phoenix.jdbc.PhoenixConnection;
import org.apache.phoenix.mapreduce.index.IndexTool;
@@ -71,7 +70,6 @@ public class IndexToolForDeleteBeforeRebuildIT extends ParallelStatsDisabledIT {
INDEX_LOCAL_DDL = "CREATE LOCAL INDEX %s ON %s (ZIP) INCLUDE (NAME)";
private static final String UPSERT_SQL = "UPSERT INTO %s VALUES(?,?,?,?)";
-
@BeforeClass
public static void setup() throws Exception {
Map<String, String> serverProps = Maps.newHashMapWithExpectedSize(3);
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 2a15a4d..4d347c2 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
@@ -90,7 +90,6 @@ import org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil;
import org.apache.phoenix.mapreduce.util.PhoenixMapReduceUtil;
import org.apache.phoenix.parse.HintNode.Hint;
import org.apache.phoenix.query.ConnectionQueryServices;
-import org.apache.phoenix.schema.PColumnFamily;
import org.apache.phoenix.schema.PIndexState;
import org.apache.phoenix.schema.PTable;
import org.apache.phoenix.schema.PTable.IndexType;
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
index 3fad1a1..0b4e75f 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
@@ -4302,6 +4302,7 @@ public class MetaDataClient {
boolean changingPhoenixTableProperty= evaluateStmtProperties(metaProperties,metaPropertiesEvaluated,table,schemaName,tableName);
PIndexState newIndexState = statement.getIndexState();
+ // TODO: Change this for PHOENIX-4703
if (isAsync && newIndexState != PIndexState.REBUILD) { throw new SQLExceptionInfo.Builder(
SQLExceptionCode.ASYNC_NOT_ALLOWED)
.setMessage(" ASYNC building of index is allowed only with REBUILD index state")