phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 bc2856b75 - 862ba4eef PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/862ba4ee Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/862ba4ee Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/862ba4ee Branch: refs/heads/4.4-HBase-0.98 Commit: 862ba4eef7416dea1be30b1965a0053587f57659 Parents: bc2856b Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:10:50 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:10:50 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/862ba4ee/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
Apache-Phoenix | 4.4-HBase-0.98 | Build Successful
4.4-HBase-0.98 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.4-HBase-0.98 Compiled Artifacts https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastCompletedBuild/testReport/ Changes [gabrielr] PHOENIX-2022 Make BaseRegionScanner.next abstract Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/master b7f138246 - 583b5b1e1 PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/583b5b1e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/583b5b1e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/583b5b1e Branch: refs/heads/master Commit: 583b5b1e115a81799cc3e6d0a20a0fe665f666e3 Parents: b7f1382 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 08:57:22 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/583b5b1e/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index 828f776..3f73048 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -33,9 +33,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, ScannerContext scannerContext) throws IOException {
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 b2c0cb900 - c1882ee27 PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c1882ee2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c1882ee2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c1882ee2 Branch: refs/heads/4.x-HBase-1.1 Commit: c1882ee279293b560fda9beb10ac50b8d3ead589 Parents: b2c0cb9 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:22:49 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c1882ee2/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index 828f776..3f73048 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -33,9 +33,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, ScannerContext scannerContext) throws IOException {
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 1badce965 - fcd41402d PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/fcd41402 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/fcd41402 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/fcd41402 Branch: refs/heads/4.x-HBase-0.98 Commit: fcd41402d309e33d1d4b3b04485f3869243596b8 Parents: 1badce9 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:22:00 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/fcd41402/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index 981e8cb..646e7e8 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -32,9 +32,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, int limit) throws IOException {
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.0 0c7b21028 - 928d4d715 PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/928d4d71 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/928d4d71 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/928d4d71 Branch: refs/heads/4.x-HBase-1.0 Commit: 928d4d71519ce31785144fea898eabf3c232f507 Parents: 0c7b210 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:22:22 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/928d4d71/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index ff9ac76..2bda23d 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -33,9 +33,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, int limit) throws IOException {
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 fcd41402d - 327749bf2 PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/327749bf Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/327749bf Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/327749bf Branch: refs/heads/4.x-HBase-0.98 Commit: 327749bf27cda27f1389a7d402060aad0f4d184d Parents: fcd4140 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:06:45 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:06:45 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/327749bf/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 673343508 - 68e297022 PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/68e29702 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/68e29702 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/68e29702 Branch: refs/heads/4.4-HBase-1.0 Commit: 68e29702264b478f0b8c44531051f7604b27d8cc Parents: 6733435 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:36:07 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:36:07 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/68e29702/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index b0574c3..fa78656 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.1 b76fc2030 - cbf00bc2d PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/cbf00bc2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/cbf00bc2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/cbf00bc2 Branch: refs/heads/4.4-HBase-1.1 Commit: cbf00bc2d767be1ae9ac70a643b55e9cedd13f82 Parents: b76fc20 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:35:41 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:35:41 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/cbf00bc2/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index b0574c3..fa78656 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 327749bf2 - 09841bada PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/09841bad Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/09841bad Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/09841bad Branch: refs/heads/4.x-HBase-0.98 Commit: 09841bada6e759958eaab18c8f7910279b3cba09 Parents: 327749b Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:35:08 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:35:08 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/09841bad/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index 03b7381..3511800 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 1041efde0 - c30938336 PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c3093833 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c3093833 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c3093833 Branch: refs/heads/4.4-HBase-1.0 Commit: c309383360d7f7fc194a5b1c86bc52757e3026ee Parents: 1041efd Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:18:25 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c3093833/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index ff9ac76..2bda23d 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -33,9 +33,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, int limit) throws IOException {
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 862ba4eef - 96cb2c728 PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/96cb2c72 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/96cb2c72 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/96cb2c72 Branch: refs/heads/4.4-HBase-0.98 Commit: 96cb2c728c8c289bdaca5ce784c85e4da16e8522 Parents: 862ba4e Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:36:32 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:36:32 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/96cb2c72/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index 03b7381..3511800 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.1 b4e1c5dab - b76fc2030 PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b76fc203 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b76fc203 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b76fc203 Branch: refs/heads/4.4-HBase-1.1 Commit: b76fc20301bf520792081645df63c93c4d41228d Parents: b4e1c5d Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:07:51 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:07:51 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b76fc203/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.0 5be585d00 - 5ff5fd4ed PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/5ff5fd4e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/5ff5fd4e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/5ff5fd4e Branch: refs/heads/4.x-HBase-1.0 Commit: 5ff5fd4eda8deafa01e0f15d28b79d613c73bffe Parents: 5be585d Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:34:40 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:34:40 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/5ff5fd4e/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index b0574c3..fa78656 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/master 82df3b97a - dc3083fec PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/dc3083fe Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/dc3083fe Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/dc3083fe Branch: refs/heads/master Commit: dc3083fec11720a3b92f3edf98a679406004550f Parents: 82df3b9 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:33:47 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:33:47 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/dc3083fe/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index b0574c3..fa78656 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 eb9452d55 - dc46b144a PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/dc46b144 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/dc46b144 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/dc46b144 Branch: refs/heads/4.x-HBase-1.1 Commit: dc46b144aa9eaf315c3969669dab7f0a50d94281 Parents: eb9452d Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:34:16 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:34:16 2015 +0530 -- phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/dc46b144/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java -- diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java index b0574c3..fa78656 100644 --- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java +++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java @@ -1627,6 +1627,7 @@ public abstract class BaseTest { * Disable and drop all the tables except SYSTEM.CATALOG and SYSTEM.SEQUENCE */ private static void disableAndDropNonSystemTables() throws Exception { +if (driver == null) return; HBaseAdmin admin = driver.getConnectionQueryServices(null, null).getAdmin(); try { HTableDescriptor[] tables = admin.listTables();
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.1 f5cdf4391 - b4e1c5dab PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b4e1c5da Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b4e1c5da Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b4e1c5da Branch: refs/heads/4.4-HBase-1.1 Commit: b4e1c5dabcede13d7523dffa1e82aa295aa0ee01 Parents: f5cdf43 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:19:59 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b4e1c5da/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index 828f776..3f73048 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -33,9 +33,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, ScannerContext scannerContext) throws IOException {
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 c1882ee27 - eb9452d55 PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/eb9452d5 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/eb9452d5 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/eb9452d5 Branch: refs/heads/4.x-HBase-1.1 Commit: eb9452d55068ff4574b48938aebba765c28caaaf Parents: c1882ee Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:05:24 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:05:24 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/eb9452d5/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/master 583b5b1e1 - 82df3b97a PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/82df3b97 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/82df3b97 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/82df3b97 Branch: refs/heads/master Commit: 82df3b97a9ca88605f78b59e547819ff3bf9cd7a Parents: 583b5b1 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:04:43 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:04:43 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/82df3b97/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) + +
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 c30938336 - 673343508 PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/67334350 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/67334350 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/67334350 Branch: refs/heads/4.4-HBase-1.0 Commit: 673343508fb0c4ac83dd4306798291dfc451bd31 Parents: c309383 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:09:53 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:09:53 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/67334350/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
phoenix git commit: PHOENIX-2022 Make BaseRegionScanner.next abstract
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 9498eb55d - bc2856b75 PHOENIX-2022 Make BaseRegionScanner.next abstract Avoid infinite recursion by removing a recursive call within BaseRegionScanner.next, which was already being used as an abstract method. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/bc2856b7 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/bc2856b7 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/bc2856b7 Branch: refs/heads/4.4-HBase-0.98 Commit: bc2856b75d4b040a06ed4d2b12fb2fbede623d97 Parents: 9498eb5 Author: Gabriel Reid gabri...@ngdata.com Authored: Mon Jun 1 08:57:22 2015 +0200 Committer: Gabriel Reid gabri...@ngdata.com Committed: Mon Jun 1 17:17:19 2015 +0200 -- .../java/org/apache/phoenix/coprocessor/BaseRegionScanner.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/bc2856b7/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java index 981e8cb..646e7e8 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java @@ -32,9 +32,7 @@ public abstract class BaseRegionScanner implements RegionScanner { } @Override -public boolean next(ListCell results) throws IOException { -return next(results); -} +public abstract boolean next(ListCell results) throws IOException; @Override public boolean next(ListCell result, int limit) throws IOException {
phoenix git commit: PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.0 928d4d715 - 5be585d00 PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/5be585d0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/5be585d0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/5be585d0 Branch: refs/heads/4.x-HBase-1.0 Commit: 5be585d00b362fafb25fc09eb3000b1dd9e4fc8c Parents: 928d4d7 Author: Rajeshbabu Chintaguntla rajeshb...@apache.org Authored: Mon Jun 1 21:06:04 2015 +0530 Committer: Rajeshbabu Chintaguntla rajeshb...@apache.org Committed: Mon Jun 1 21:06:04 2015 +0530 -- .../org/apache/phoenix/end2end/HashJoinIT.java | 54 .../apache/phoenix/execute/HashJoinPlan.java| 7 +-- 2 files changed, 58 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/5be585d0/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index a03204a..88e03ca 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -3813,6 +3813,60 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { } } +@Test +public void testSubqueryWithoutData() throws Exception { +Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES); +Connection conn = DriverManager.getConnection(getUrl(), props); +conn.setAutoCommit(false); + +try { +String GRAMMAR_TABLE = CREATE TABLE IF NOT EXISTS GRAMMAR_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String LARGE_TABLE = CREATE TABLE IF NOT EXISTS LARGE_TABLE (ID INTEGER PRIMARY KEY, + +unsig_id UNSIGNED_INT, big_id BIGINT, unsig_long_id UNSIGNED_LONG, tiny_id TINYINT, + +unsig_tiny_id UNSIGNED_TINYINT, small_id SMALLINT, unsig_small_id UNSIGNED_SMALLINT, + +float_id FLOAT, unsig_float_id UNSIGNED_FLOAT, double_id DOUBLE, unsig_double_id UNSIGNED_DOUBLE, + +decimal_id DECIMAL, boolean_id BOOLEAN, time_id TIME, date_id DATE, timestamp_id TIMESTAMP, + +unsig_time_id TIME, unsig_date_id DATE, unsig_timestamp_id TIMESTAMP, varchar_id VARCHAR (30), + +char_id CHAR (30), binary_id BINARY (100), varbinary_id VARBINARY (100)); + +String SECONDARY_LARGE_TABLE = CREATE TABLE IF NOT EXISTS SECONDARY_LARGE_TABLE (SEC_ID INTEGER PRIMARY KEY, + +sec_unsig_id UNSIGNED_INT, sec_big_id BIGINT, sec_usnig_long_id UNSIGNED_LONG, sec_tiny_id TINYINT, + +sec_unsig_tiny_id UNSIGNED_TINYINT, sec_small_id SMALLINT, sec_unsig_small_id UNSIGNED_SMALLINT, + +sec_float_id FLOAT, sec_unsig_float_id UNSIGNED_FLOAT, sec_double_id DOUBLE, sec_unsig_double_id UNSIGNED_DOUBLE, + +sec_decimal_id DECIMAL, sec_boolean_id BOOLEAN, sec_time_id TIME, sec_date_id DATE, + +sec_timestamp_id TIMESTAMP, sec_unsig_time_id TIME, sec_unsig_date_id DATE, sec_unsig_timestamp_id TIMESTAMP, + +sec_varchar_id VARCHAR (30), sec_char_id CHAR (30), sec_binary_id BINARY (100), sec_varbinary_id VARBINARY (100)); +createTestTable(getUrl(), GRAMMAR_TABLE); +createTestTable(getUrl(), LARGE_TABLE); +createTestTable(getUrl(), SECONDARY_LARGE_TABLE); + +String ddl = SELECT * FROM (SELECT ID, BIG_ID, DATE_ID FROM LARGE_TABLE AS A WHERE (A.ID % 5) = 0) AS A + +INNER JOIN (SELECT SEC_ID, SEC_TINY_ID, SEC_UNSIG_FLOAT_ID FROM SECONDARY_LARGE_TABLE AS B WHERE (B.SEC_ID % 5) = 0) AS B + +ON A.ID=B.SEC_ID WHERE A.DATE_ID ALL (SELECT SEC_DATE_ID FROM SECONDARY_LARGE_TABLE LIMIT 100) +
Apache-Phoenix | Master | Build Successful
Master branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/master Last Successful Compiled Artifacts https://builds.apache.org/job/Phoenix-master/lastSuccessfulBuild/artifact/ Last Complete Test Report https://builds.apache.org/job/Phoenix-master/lastCompletedBuild/testReport/ Changes [rajeshbabu] PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) [rajeshbabu] PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
Apache-Phoenix | 4.4-HBase-0.98 | Build Successful
4.4-HBase-0.98 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.4-HBase-0.98 Compiled Artifacts https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastCompletedBuild/testReport/ Changes [rajeshbabu] PHOENIX-2007 java.sql.SQLException: Encountered exception in sub plan [0] execution(Alicia Ying Shu) [rajeshbabu] PHOENIX-2016 Some Phoenix tests failed with NPE(Alicia Ying Shu) Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
phoenix git commit: PHOENIX-1990 bin/queryserver makeWinServiceDesc doesn't actually work in Windows
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 68e297022 - 5ccfa54c7 PHOENIX-1990 bin/queryserver makeWinServiceDesc doesn't actually work in Windows Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/5ccfa54c Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/5ccfa54c Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/5ccfa54c Branch: refs/heads/4.4-HBase-1.0 Commit: 5ccfa54c71f77d660d46175a0f212c8d3988df1c Parents: 68e2970 Author: Nick Dimiduk ndimi...@apache.org Authored: Mon May 18 16:00:31 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 11:52:07 2015 -0700 -- bin/queryserver.py | 17 ++--- 1 file changed, 14 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/5ccfa54c/bin/queryserver.py -- diff --git a/bin/queryserver.py b/bin/queryserver.py index 6a18741..7666246 100755 --- a/bin/queryserver.py +++ b/bin/queryserver.py @@ -78,11 +78,22 @@ phoenix_out_file = '%s.out' % phoenix_file_basename phoenix_pid_file = '%s.pid' % phoenix_file_basename opts = os.getenv('PHOENIX_QUERYSERVER_OPTS', '') -# load hbase-env.sh to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR -hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.sh') +# load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR +hbase_env_path = None +hbase_env_cmd = None +if os.name == 'posix': +hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.sh') +hbase_env_cmd = ['bash', '-c', 'source %s env' % hbase_env_path] +elif os.name == 'nt': +hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.cmd') +hbase_env_cmd = ['cmd.exe', '/c', 'call %s set' % hbase_env_path] +if not hbase_env_path or not hbase_env_cmd: +print sys.stderr, hbase-env file unknown on platform %s % os.name +sys.exit(-1) + hbase_env = {} if os.path.isfile(hbase_env_path): -p = subprocess.Popen(['bash', '-c', 'source %s env' % hbase_env_path], stdout = subprocess.PIPE) +p = subprocess.Popen(hbase_env_cmd, stdout = subprocess.PIPE) for x in p.stdout: (k, _, v) = x.partition('=') hbase_env[k.strip()] = v.strip()
phoenix git commit: PHOENIX-1976 Exit gracefully if addShutdownHook fails.
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 44c512116 - b4f1b1a2a PHOENIX-1976 Exit gracefully if addShutdownHook fails. If the JVM is already in the process of shutting down, we don't need to add the shutdown hook for the PhoenixDriver instance. Additionally, we shouldn't advertise this instance either since we're going down. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b4f1b1a2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b4f1b1a2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b4f1b1a2 Branch: refs/heads/4.4-HBase-0.98 Commit: b4f1b1a2ace51477540f12abbb76b70828895bf2 Parents: 44c5121 Author: Josh Elser josh.el...@gmail.com Authored: Thu May 14 17:40:46 2015 -0400 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 12:03:45 2015 -0700 -- .../org/apache/phoenix/jdbc/PhoenixDriver.java | 46 ++-- 1 file changed, 32 insertions(+), 14 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b4f1b1a2/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java index 6360d06..cfabe82 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java @@ -60,25 +60,43 @@ public final class PhoenixDriver extends PhoenixEmbeddedDriver { private static volatile String driverShutdownMsg; static { try { -DriverManager.registerDriver( INSTANCE = new PhoenixDriver() ); -// Add shutdown hook to release any resources that were never closed -// In theory not necessary, but it won't hurt anything -Runtime.getRuntime().addShutdownHook(new Thread() { -@Override -public void run() { -try { -INSTANCE.close(); -} catch (SQLException e) { -logger.warn(Unable to close PhoenixDriver on shutdown, e); -} finally { -driverShutdownMsg = Phoenix driver closed because server is shutting down; +INSTANCE = new PhoenixDriver(); +try { +// Add shutdown hook to release any resources that were never closed +// In theory not necessary, but it won't hurt anything +Runtime.getRuntime().addShutdownHook(new Thread() { +@Override +public void run() { +closeInstance(INSTANCE); } -} -}); +}); + +// Only register the driver when we successfully register the shutdown hook +// Don't want to register it if we're already in the process of going down. +DriverManager.registerDriver( INSTANCE ); +} catch (IllegalStateException e) { +logger.warn(Failed to register PhoenixDriver shutdown hook as the JVM is already shutting down); + +// Close the instance now because we don't have the shutdown hook +closeInstance(INSTANCE); + +throw e; +} } catch (SQLException e) { throw new IllegalStateException(Unable to register + PhoenixDriver.class.getName() + : + e.getMessage()); } } + +private static void closeInstance(PhoenixDriver instance) { +try { +instance.close(); +} catch (SQLException e) { +logger.warn(Unable to close PhoenixDriver on shutdown, e); +} finally { +driverShutdownMsg = Phoenix driver closed because server is shutting down; +} +} + // One entry per cluster here private final ConcurrentMapConnectionInfo,ConnectionQueryServices connectionQueryServicesMap = new ConcurrentHashMapConnectionInfo,ConnectionQueryServices(3);
phoenix git commit: PHOENIX-1990 bin/queryserver makeWinServiceDesc doesn't actually work in Windows
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 96cb2c728 - 44c512116 PHOENIX-1990 bin/queryserver makeWinServiceDesc doesn't actually work in Windows Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/44c51211 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/44c51211 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/44c51211 Branch: refs/heads/4.4-HBase-0.98 Commit: 44c51211677bc793fa5df64c1638c2606723a82c Parents: 96cb2c7 Author: Nick Dimiduk ndimi...@apache.org Authored: Mon May 18 16:00:31 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 11:52:17 2015 -0700 -- bin/queryserver.py | 17 ++--- 1 file changed, 14 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/44c51211/bin/queryserver.py -- diff --git a/bin/queryserver.py b/bin/queryserver.py index 6a18741..7666246 100755 --- a/bin/queryserver.py +++ b/bin/queryserver.py @@ -78,11 +78,22 @@ phoenix_out_file = '%s.out' % phoenix_file_basename phoenix_pid_file = '%s.pid' % phoenix_file_basename opts = os.getenv('PHOENIX_QUERYSERVER_OPTS', '') -# load hbase-env.sh to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR -hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.sh') +# load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR +hbase_env_path = None +hbase_env_cmd = None +if os.name == 'posix': +hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.sh') +hbase_env_cmd = ['bash', '-c', 'source %s env' % hbase_env_path] +elif os.name == 'nt': +hbase_env_path = os.path.join(hbase_config_path, 'hbase-env.cmd') +hbase_env_cmd = ['cmd.exe', '/c', 'call %s set' % hbase_env_path] +if not hbase_env_path or not hbase_env_cmd: +print sys.stderr, hbase-env file unknown on platform %s % os.name +sys.exit(-1) + hbase_env = {} if os.path.isfile(hbase_env_path): -p = subprocess.Popen(['bash', '-c', 'source %s env' % hbase_env_path], stdout = subprocess.PIPE) +p = subprocess.Popen(hbase_env_cmd, stdout = subprocess.PIPE) for x in p.stdout: (k, _, v) = x.partition('=') hbase_env[k.strip()] = v.strip()
phoenix git commit: PHOENIX-1976 Exit gracefully if addShutdownHook fails.
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 dc46b144a - f2be91383 PHOENIX-1976 Exit gracefully if addShutdownHook fails. If the JVM is already in the process of shutting down, we don't need to add the shutdown hook for the PhoenixDriver instance. Additionally, we shouldn't advertise this instance either since we're going down. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f2be9138 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f2be9138 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f2be9138 Branch: refs/heads/4.x-HBase-1.1 Commit: f2be9138359b078fd3e285f3fd441de711789962 Parents: dc46b14 Author: Josh Elser josh.el...@gmail.com Authored: Thu May 14 17:40:46 2015 -0400 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 12:02:28 2015 -0700 -- .../org/apache/phoenix/jdbc/PhoenixDriver.java | 46 ++-- 1 file changed, 32 insertions(+), 14 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/f2be9138/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java index 6360d06..cfabe82 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java @@ -60,25 +60,43 @@ public final class PhoenixDriver extends PhoenixEmbeddedDriver { private static volatile String driverShutdownMsg; static { try { -DriverManager.registerDriver( INSTANCE = new PhoenixDriver() ); -// Add shutdown hook to release any resources that were never closed -// In theory not necessary, but it won't hurt anything -Runtime.getRuntime().addShutdownHook(new Thread() { -@Override -public void run() { -try { -INSTANCE.close(); -} catch (SQLException e) { -logger.warn(Unable to close PhoenixDriver on shutdown, e); -} finally { -driverShutdownMsg = Phoenix driver closed because server is shutting down; +INSTANCE = new PhoenixDriver(); +try { +// Add shutdown hook to release any resources that were never closed +// In theory not necessary, but it won't hurt anything +Runtime.getRuntime().addShutdownHook(new Thread() { +@Override +public void run() { +closeInstance(INSTANCE); } -} -}); +}); + +// Only register the driver when we successfully register the shutdown hook +// Don't want to register it if we're already in the process of going down. +DriverManager.registerDriver( INSTANCE ); +} catch (IllegalStateException e) { +logger.warn(Failed to register PhoenixDriver shutdown hook as the JVM is already shutting down); + +// Close the instance now because we don't have the shutdown hook +closeInstance(INSTANCE); + +throw e; +} } catch (SQLException e) { throw new IllegalStateException(Unable to register + PhoenixDriver.class.getName() + : + e.getMessage()); } } + +private static void closeInstance(PhoenixDriver instance) { +try { +instance.close(); +} catch (SQLException e) { +logger.warn(Unable to close PhoenixDriver on shutdown, e); +} finally { +driverShutdownMsg = Phoenix driver closed because server is shutting down; +} +} + // One entry per cluster here private final ConcurrentMapConnectionInfo,ConnectionQueryServices connectionQueryServicesMap = new ConcurrentHashMapConnectionInfo,ConnectionQueryServices(3);
phoenix git commit: PHOENIX-1976 Exit gracefully if addShutdownHook fails.
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.1 404419721 - 278937023 PHOENIX-1976 Exit gracefully if addShutdownHook fails. If the JVM is already in the process of shutting down, we don't need to add the shutdown hook for the PhoenixDriver instance. Additionally, we shouldn't advertise this instance either since we're going down. Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/27893702 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/27893702 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/27893702 Branch: refs/heads/4.4-HBase-1.1 Commit: 2789370230305b41c925e7ea164c04ed397d4fe3 Parents: 4044197 Author: Josh Elser josh.el...@gmail.com Authored: Thu May 14 17:40:46 2015 -0400 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 12:03:30 2015 -0700 -- .../org/apache/phoenix/jdbc/PhoenixDriver.java | 46 ++-- 1 file changed, 32 insertions(+), 14 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/27893702/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java index 6360d06..cfabe82 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixDriver.java @@ -60,25 +60,43 @@ public final class PhoenixDriver extends PhoenixEmbeddedDriver { private static volatile String driverShutdownMsg; static { try { -DriverManager.registerDriver( INSTANCE = new PhoenixDriver() ); -// Add shutdown hook to release any resources that were never closed -// In theory not necessary, but it won't hurt anything -Runtime.getRuntime().addShutdownHook(new Thread() { -@Override -public void run() { -try { -INSTANCE.close(); -} catch (SQLException e) { -logger.warn(Unable to close PhoenixDriver on shutdown, e); -} finally { -driverShutdownMsg = Phoenix driver closed because server is shutting down; +INSTANCE = new PhoenixDriver(); +try { +// Add shutdown hook to release any resources that were never closed +// In theory not necessary, but it won't hurt anything +Runtime.getRuntime().addShutdownHook(new Thread() { +@Override +public void run() { +closeInstance(INSTANCE); } -} -}); +}); + +// Only register the driver when we successfully register the shutdown hook +// Don't want to register it if we're already in the process of going down. +DriverManager.registerDriver( INSTANCE ); +} catch (IllegalStateException e) { +logger.warn(Failed to register PhoenixDriver shutdown hook as the JVM is already shutting down); + +// Close the instance now because we don't have the shutdown hook +closeInstance(INSTANCE); + +throw e; +} } catch (SQLException e) { throw new IllegalStateException(Unable to register + PhoenixDriver.class.getName() + : + e.getMessage()); } } + +private static void closeInstance(PhoenixDriver instance) { +try { +instance.close(); +} catch (SQLException e) { +logger.warn(Unable to close PhoenixDriver on shutdown, e); +} finally { +driverShutdownMsg = Phoenix driver closed because server is shutting down; +} +} + // One entry per cluster here private final ConcurrentMapConnectionInfo,ConnectionQueryServices connectionQueryServicesMap = new ConcurrentHashMapConnectionInfo,ConnectionQueryServices(3);
Apache-Phoenix | 4.4-HBase-1.0 | Build Successful
4.4-HBase-1.0 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.4-HBase-1.0 Compiled Artifacts https://builds.apache.org/job/Phoenix-4.4-HBase-1.0/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.4-HBase-1.0/lastCompletedBuild/testReport/ Changes [jamestaylor] PHOENIX-1984 Make INSTR 1-based instead of 0-based Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
phoenix git commit: PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 29ea50354 - 9c5fa PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/9c5f Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/9c5f Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/9c5f Branch: refs/heads/4.x-HBase-1.1 Commit: 9c5fae456f3a0934e43e02af0ef5188b9337 Parents: 29ea503 Author: Nick Dimiduk ndimi...@apache.org Authored: Wed May 27 15:58:32 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 15:57:15 2015 -0700 -- .../java/org/apache/phoenix/filter/RowKeyComparisonFilter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/9c5f/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java index 2e2037b..b7de7ac 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java @@ -73,8 +73,9 @@ public class RowKeyComparisonFilter extends BooleanExpressionFilter { if (evaluate) { inputTuple.setKey(v.getRowArray(), v.getRowOffset(), v.getRowLength()); this.keepRow = Boolean.TRUE.equals(evaluate(inputTuple)); -if (logger.isDebugEnabled()) { -logger.debug(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) + row + inputTuple); +if (logger.isTraceEnabled()) { +logger.trace(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) ++ row + inputTuple); } evaluate = false; }
phoenix git commit: PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 98cc07918 - 861900975 PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/86190097 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/86190097 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/86190097 Branch: refs/heads/4.4-HBase-1.0 Commit: 8619009755531dc5b481c9671c2b5b790dfc2b93 Parents: 98cc079 Author: Nick Dimiduk ndimi...@apache.org Authored: Wed May 27 15:58:32 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 16:09:35 2015 -0700 -- .../java/org/apache/phoenix/filter/RowKeyComparisonFilter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/86190097/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java index 2e2037b..b7de7ac 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java @@ -73,8 +73,9 @@ public class RowKeyComparisonFilter extends BooleanExpressionFilter { if (evaluate) { inputTuple.setKey(v.getRowArray(), v.getRowOffset(), v.getRowLength()); this.keepRow = Boolean.TRUE.equals(evaluate(inputTuple)); -if (logger.isDebugEnabled()) { -logger.debug(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) + row + inputTuple); +if (logger.isTraceEnabled()) { +logger.trace(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) ++ row + inputTuple); } evaluate = false; }
phoenix git commit: PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level
Repository: phoenix Updated Branches: refs/heads/master dc3083fec - 9e686b758 PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/9e686b75 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/9e686b75 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/9e686b75 Branch: refs/heads/master Commit: 9e686b758ff735fd9129430cd31fe36993b9711b Parents: dc3083f Author: Nick Dimiduk ndimi...@apache.org Authored: Wed May 27 15:58:32 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 15:54:37 2015 -0700 -- .../java/org/apache/phoenix/filter/RowKeyComparisonFilter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/9e686b75/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java index 2e2037b..b7de7ac 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java @@ -73,8 +73,9 @@ public class RowKeyComparisonFilter extends BooleanExpressionFilter { if (evaluate) { inputTuple.setKey(v.getRowArray(), v.getRowOffset(), v.getRowLength()); this.keepRow = Boolean.TRUE.equals(evaluate(inputTuple)); -if (logger.isDebugEnabled()) { -logger.debug(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) + row + inputTuple); +if (logger.isTraceEnabled()) { +logger.trace(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) ++ row + inputTuple); } evaluate = false; }
phoenix git commit: PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 09841bada - c7f4a6743 PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c7f4a674 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c7f4a674 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c7f4a674 Branch: refs/heads/4.x-HBase-0.98 Commit: c7f4a6743daeb8fab8653db912eac5366a35a3ac Parents: 09841ba Author: Nick Dimiduk ndimi...@apache.org Authored: Wed May 27 15:58:32 2015 -0700 Committer: Nick Dimiduk ndimi...@apache.org Committed: Mon Jun 1 16:01:14 2015 -0700 -- .../java/org/apache/phoenix/filter/RowKeyComparisonFilter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c7f4a674/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java index 2e2037b..b7de7ac 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/filter/RowKeyComparisonFilter.java @@ -73,8 +73,9 @@ public class RowKeyComparisonFilter extends BooleanExpressionFilter { if (evaluate) { inputTuple.setKey(v.getRowArray(), v.getRowOffset(), v.getRowLength()); this.keepRow = Boolean.TRUE.equals(evaluate(inputTuple)); -if (logger.isDebugEnabled()) { -logger.debug(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) + row + inputTuple); +if (logger.isTraceEnabled()) { +logger.trace(RowKeyComparisonFilter: + (this.keepRow ? KEEP : FILTER) ++ row + inputTuple); } evaluate = false; }
Apache-Phoenix | 4.4-HBase-0.98 | Build Successful
4.4-HBase-0.98 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.4-HBase-0.98 Compiled Artifacts https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.4-HBase-0.98/lastCompletedBuild/testReport/ Changes [ndimiduk] PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
Apache-Phoenix | 4.x-HBase-1.0 | Build Successful
4.x-HBase-1.0 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.x-HBase-1.0 Compiled Artifacts https://builds.apache.org/job/Phoenix-4.x-HBase-1.0/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.x-HBase-1.0/lastCompletedBuild/testReport/ Changes [ndimiduk] PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
Apache-Phoenix | Master | Build Successful
Master branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/master Last Successful Compiled Artifacts https://builds.apache.org/job/Phoenix-master/lastSuccessfulBuild/artifact/ Last Complete Test Report https://builds.apache.org/job/Phoenix-master/lastCompletedBuild/testReport/ Changes [ndimiduk] PHOENIX-2012 RowKeyComparisonFilter logs unencoded data at DEBUG level Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
phoenix git commit: PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 9c5fa - 6f890ade0 PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6f890ade Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6f890ade Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6f890ade Branch: refs/heads/4.x-HBase-1.1 Commit: 6f890ade0691d03469ff8fce81c2fa9edd6941af Parents: 9c5f111 Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:18:51 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:18:51 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/6f890ade/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new
phoenix git commit: PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.1 fb1cb7e96 - 72abeb150 PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/72abeb15 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/72abeb15 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/72abeb15 Branch: refs/heads/4.4-HBase-1.1 Commit: 72abeb1507503d819d34b66c6e3c3dcd3a8cb789 Parents: fb1cb7e Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:22:56 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:22:56 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/72abeb15/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new
phoenix git commit: PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-1.0 861900975 - c222b8206 PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c222b820 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c222b820 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c222b820 Branch: refs/heads/4.4-HBase-1.0 Commit: c222b82062a359f0ea4b6361ca3244a83b48da3b Parents: 8619009 Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:24:24 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:24:24 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c222b820/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new
phoenix git commit: PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/4.4-HBase-0.98 c88606da6 - b351c6b69 PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b351c6b6 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b351c6b6 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b351c6b6 Branch: refs/heads/4.4-HBase-0.98 Commit: b351c6b692db08eb56102303c9991b69af745b26 Parents: c88606d Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:25:38 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:25:38 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b351c6b6/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new
phoenix git commit: PHOENIX-777 Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/master 9e686b758 - 7f6bf10b2 PHOENIX-777 Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/7f6bf10b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/7f6bf10b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/7f6bf10b Branch: refs/heads/master Commit: 7f6bf10b2cc54279b9210772323dc8f4d2939a19 Parents: 9e686b7 Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:13:44 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:13:44 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/7f6bf10b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new
Build failed in Jenkins: Phoenix | Master #776
See https://builds.apache.org/job/Phoenix-master/776/changes Changes: [ramkrishna] PHOENIX-777 Support null value for fixed length ARRAY (Dumindu Buddhika) -- [...truncated 116411 lines...] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.234 sec - in org.apache.phoenix.compile.JoinQueryCompilerTest Running org.apache.phoenix.compile.QueryOptimizerTest Tests run: 21, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.523 sec - in org.apache.phoenix.expression.RoundFloorCeilExpressionsTest Running org.apache.phoenix.expression.util.regex.PatternPerformanceTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in org.apache.phoenix.expression.util.regex.PatternPerformanceTest Running org.apache.phoenix.util.LikeExpressionTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in org.apache.phoenix.util.LikeExpressionTest Running org.apache.phoenix.util.MetaDataUtilTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.007 sec - in org.apache.phoenix.util.MetaDataUtilTest Running org.apache.phoenix.util.ScanUtilTest Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.016 sec - in org.apache.phoenix.util.ScanUtilTest Running org.apache.phoenix.util.PhoenixEncodeDecodeTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.158 sec - in org.apache.phoenix.util.PhoenixEncodeDecodeTest Running org.apache.phoenix.util.ByteUtilTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.396 sec - in org.apache.phoenix.compile.StatementHintsCompilationTest Running org.apache.phoenix.compile.SelectStatementRewriterTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.086 sec - in org.apache.phoenix.util.ByteUtilTest Running org.apache.hadoop.hbase.ipc.PhoenixIndexRpcSchedulerTest Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.103 sec - in org.apache.phoenix.compile.SelectStatementRewriterTest Running org.apache.phoenix.parse.QueryParserTest Tests run: 58, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.049 sec - in org.apache.phoenix.parse.QueryParserTest Running org.apache.phoenix.parse.BuiltInFunctionInfoTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in org.apache.phoenix.parse.BuiltInFunctionInfoTest Running org.apache.phoenix.filter.SkipScanFilterIntersectTest Tests run: 19, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.016 sec - in org.apache.phoenix.filter.SkipScanFilterIntersectTest Running org.apache.phoenix.filter.SkipScanBigFilterTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.266 sec - in org.apache.hadoop.hbase.ipc.PhoenixIndexRpcSchedulerTest Tests run: 37, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.825 sec - in org.apache.phoenix.compile.QueryOptimizerTest Running org.apache.phoenix.compile.ScanRangesTest Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.023 sec - in org.apache.phoenix.compile.ScanRangesTest Running org.apache.phoenix.compile.ViewCompilerTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.125 sec - in org.apache.phoenix.compile.ViewCompilerTest Running org.apache.phoenix.compile.WhereCompilerTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.542 sec - in org.apache.phoenix.filter.SkipScanBigFilterTest Running org.apache.phoenix.execute.MutationStateTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in org.apache.phoenix.execute.MutationStateTest Running org.apache.phoenix.mapreduce.CsvBulkLoadToolTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.011 sec - in org.apache.phoenix.mapreduce.CsvBulkLoadToolTest Running org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest Tests run: 43, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.235 sec - in org.apache.phoenix.compile.WhereCompilerTest Running org.apache.phoenix.compile.QueryCompilerTest Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.161 sec - in org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest Running org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtilTest Tests run: 100, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.376 sec - in org.apache.phoenix.compile.QueryCompilerTest Running org.apache.phoenix.index.IndexMaintainerTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.552 sec - in org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtilTest Running org.apache.phoenix.schema.SchemaUtilTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in org.apache.phoenix.schema.SchemaUtilTest Running org.apache.phoenix.schema.types.PrimitiveFloatPhoenixArrayToStringTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec - in org.apache.phoenix.schema.types.PrimitiveFloatPhoenixArrayToStringTest Running
phoenix git commit: PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika)
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.0 4849a5675 - 3413a8e05 PHOENIX-777 - Support null value for fixed length ARRAY (Dumindu Buddhika) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/3413a8e0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/3413a8e0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/3413a8e0 Branch: refs/heads/4.x-HBase-1.0 Commit: 3413a8e05d4649fe798ef50d7b87490c846965bb Parents: 4849a56 Author: ramkrishna ramkrishna.s.vasude...@gmail.com Authored: Tue Jun 2 11:20:33 2015 +0530 Committer: ramkrishna ramkrishna.s.vasude...@gmail.com Committed: Tue Jun 2 11:20:33 2015 +0530 -- .../phoenix/end2end/ArraysWithNullsIT.java | 300 +++ .../phoenix/compile/ExpressionCompiler.java | 9 +- .../apache/phoenix/schema/types/PBinary.java| 2 +- .../org/apache/phoenix/schema/types/PChar.java | 5 +- .../org/apache/phoenix/schema/types/PDate.java | 6 +- .../apache/phoenix/schema/types/PDecimal.java | 3 + .../apache/phoenix/schema/types/PTimestamp.java | 17 +- .../phoenix/schema/types/PhoenixArray.java | 51 ++-- 8 files changed, 358 insertions(+), 35 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/3413a8e0/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java new file mode 100644 index 000..b034193 --- /dev/null +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ArraysWithNullsIT.java @@ -0,0 +1,300 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * License); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an AS IS BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.phoenix.end2end; + +import static org.junit.Assert.assertEquals; + +import java.sql.*; + +import org.apache.phoenix.schema.types.PTimestamp; +import org.apache.phoenix.schema.types.PhoenixArray; +import org.junit.Test; + +public class ArraysWithNullsIT extends BaseClientManagedTimeIT { + +@Test +public void testArrayUpsertIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t1 ( k VARCHAR PRIMARY KEY, a INTEGER[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t1 VALUES('a',ARRAY[null,3,null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t1 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(INTEGER,new Object[]{null,3,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + + + +@Test +public void testArrayUpsertVarcharWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t2 ( k VARCHAR PRIMARY KEY, a VARCHAR[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t2 VALUES('a',ARRAY['10',null])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t2 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(VARCHAR,new Object[]{10,null}); + +assertEquals(rs.getArray(1),array); +conn.close(); + +} + +@Test +public void testArrayUpsertBigIntWithNulls() throws Exception { +Connection conn = DriverManager.getConnection(getUrl()); +conn.createStatement().execute(CREATE TABLE t3 ( k VARCHAR PRIMARY KEY, a BIGINT[])); + +PreparedStatement stmt = conn.prepareStatement(UPSERT INTO t3 VALUES('a',ARRAY[2,null,32335,4])); +stmt.execute(); +conn.commit(); + +ResultSet rs = conn.createStatement().executeQuery(Select a from t3 where k = 'a'); +rs.next(); +Array array = conn.createArrayOf(BIGINT,new