You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by la...@apache.org on 2019/12/21 15:46:25 UTC
[phoenix] branch 4.x-HBase-1.3 updated: Revert "PHOENIX-5616 Speed
up ParameterizedIndexUpgradeToolIT."
This is an automated email from the ASF dual-hosted git repository.
larsh pushed a commit to branch 4.x-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push:
new 0c5f0d6 Revert "PHOENIX-5616 Speed up ParameterizedIndexUpgradeToolIT."
0c5f0d6 is described below
commit 0c5f0d6d308b3c9be9537e9a0915f0ee19f2271c
Author: Lars Hofhansl <la...@apache.org>
AuthorDate: Sat Dec 21 07:47:03 2019 -0800
Revert "PHOENIX-5616 Speed up ParameterizedIndexUpgradeToolIT."
This reverts commit 53c0089a29a33124b0a0be4c5315995ace2c70fd.
---
.../end2end/ParameterizedIndexUpgradeToolIT.java | 38 ++++++++++++----------
1 file changed, 21 insertions(+), 17 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java
index 5a2cef9..16f99e3 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParameterizedIndexUpgradeToolIT.java
@@ -310,40 +310,44 @@ public class ParameterizedIndexUpgradeToolIT extends BaseTest {
}
@Test
- public void testDryRunAndFailures() throws Exception {
+ public void testToolWithIncorrectTables() throws Exception {
validate(true);
-
- // test with incorrect table
iut.setInputTables("TEST3.TABLE_NOT_PRESENT");
iut.prepareToolSetup();
int status = iut.executeTool();
Assert.assertEquals(-1, status);
validate(true);
+ }
- // test with input file parameter
+ @Test
+ public void testToolWithNoIndex() throws Exception {
+ if (!upgrade || isNamespaceEnabled) {
+ return;
+ }
+ conn.createStatement().execute("CREATE TABLE TEST.NEW_TABLE (id bigint NOT NULL "
+ + "PRIMARY KEY, a.name varchar, sal bigint, address varchar)" + tableDDLOptions);
+ iut.setInputTables("TEST.NEW_TABLE");
+ iut.prepareToolSetup();
+ int status = iut.executeTool();
+ Assert.assertEquals(0, status);
+ conn.createStatement().execute("DROP TABLE TEST.NEW_TABLE");
+ }
+
+ @Test
+ public void testToolWithInputFileParameter() throws Exception {
BufferedWriter writer = new BufferedWriter(new FileWriter(new File(INPUT_FILE)));
writer.write(INPUT_LIST);
writer.close();
+ validate(true);
+
iut.setInputTables(null);
iut.setInputFile(INPUT_FILE);
iut.prepareToolSetup();
- status = iut.executeTool();
- Assert.assertEquals(0, status);
+ iut.executeTool();
validate(true);
-
- // test table without index
- if (upgrade && !isNamespaceEnabled) {
- conn.createStatement().execute("CREATE TABLE TEST.NEW_TABLE (id bigint NOT NULL "
- + "PRIMARY KEY, a.name varchar, sal bigint, address varchar)" + tableDDLOptions);
- iut.setInputTables("TEST.NEW_TABLE");
- iut.prepareToolSetup();
- status = iut.executeTool();
- Assert.assertEquals(0, status);
- conn.createStatement().execute("DROP TABLE TEST.NEW_TABLE");
- }
}
@After