Apache-Phoenix | master | HBase 2.2 | Build #134 FAILURE
master branch HBase 2.2 build #134 status FAILURE Build #134 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/134/
Apache-Phoenix | 4.x | HBase 1.4 | Build #128 FAILURE
4.x branch HBase 1.4 build #128 status FAILURE Build #128 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/128/
Apache-Phoenix | 4.x | HBase 1.6 | Build #128 FAILURE
4.x branch HBase 1.6 build #128 status FAILURE Build #128 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/128/
Apache-Phoenix | 4.x | HBase 1.3 | Build #128 FAILURE
4.x branch HBase 1.3 build #128 status FAILURE Build #128 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/128/
Apache-Phoenix | master | HBase 2.1 | Build #134 SUCCESS
master branch HBase 2.1 build #134 status SUCCESS Build #134 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/134/
Apache-Phoenix | master | HBase 2.3 | Build #134 FAILURE
master branch HBase 2.3 build #134 status FAILURE Build #134 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/134/
[phoenix-connectors] branch master updated: PHOENIX-6240 Standardize connectors logging on SLF4j
This is an automated email from the ASF dual-hosted git repository.
stoty pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix-connectors.git
The following commit(s) were added to refs/heads/master by this push:
new 234ed7c PHOENIX-6240 Standardize connectors logging on SLF4j
234ed7c is described below
commit 234ed7c88447e178d7f12d87c000b2bba98ef250
Author: Istvan Toth
AuthorDate: Wed Dec 2 08:19:38 2020 +0100
PHOENIX-6240 Standardize connectors logging on SLF4j
---
.../main/java/org/apache/phoenix/compat/HiveCompatUtil.java | 4 ++--
.../objectinspector/AbstractPhoenixObjectInspector.java | 11 ++-
.../main/java/org/apache/phoenix/compat/HiveCompatUtil.java | 6 +++---
.../objectinspector/AbstractPhoenixObjectInspector.java | 13 +++--
phoenix-hive-base/pom.xml | 7 ---
.../org/apache/phoenix/hive/BaseHivePhoenixStoreIT.java | 6 +++---
.../main/java/org/apache/phoenix/hive/PhoenixMetaHook.java | 9 -
.../java/org/apache/phoenix/hive/PhoenixRecordUpdater.java | 6 +++---
.../src/main/java/org/apache/phoenix/hive/PhoenixSerDe.java | 7 ---
.../java/org/apache/phoenix/hive/PhoenixSerializer.java | 6 +++---
.../java/org/apache/phoenix/hive/PhoenixStorageHandler.java | 7 +++
.../apache/phoenix/hive/mapreduce/PhoenixInputFormat.java | 6 +++---
.../apache/phoenix/hive/mapreduce/PhoenixOutputFormat.java | 6 +++---
.../apache/phoenix/hive/mapreduce/PhoenixRecordReader.java | 6 +++---
.../apache/phoenix/hive/mapreduce/PhoenixRecordWriter.java | 6 +++---
.../phoenix/hive/mapreduce/PhoenixResultWritable.java | 6 +++---
.../hive/objectinspector/PhoenixObjectInspectorFactory.java | 6 +++---
.../apache/phoenix/hive/ppd/PhoenixPredicateDecomposer.java | 6 +++---
.../phoenix/hive/ql/index/IndexPredicateAnalyzer.java | 6 +++---
.../org/apache/phoenix/hive/query/PhoenixQueryBuilder.java | 6 +++---
.../org/apache/phoenix/hive/util/ColumnMappingUtils.java| 6 +++---
.../org/apache/phoenix/hive/util/PhoenixConnectionUtil.java | 8
.../apache/phoenix/hive/util/PhoenixStorageHandlerUtil.java | 12 +++-
.../main/java/org/apache/phoenix/hive/util/PhoenixUtil.java | 6 +++---
phoenix-pig-base/pom.xml| 6 --
.../java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java | 6 +++---
.../java/org/apache/phoenix/pig/PhoenixHBaseLoader.java | 7 +++
.../org/apache/phoenix/pig/util/PhoenixPigSchemaUtil.java | 6 +++---
.../apache/phoenix/pig/util/QuerySchemaParserFunction.java | 7 ---
.../phoenix/pig/util/SqlQueryToColumnInfoFunction.java | 8 +---
.../src/main/java/org/apache/phoenix/pig/util/TypeUtil.java | 6 +++---
phoenix-spark-base/pom.xml | 5 ++---
.../phoenix/spark/datasource/v2/PhoenixDataSource.java | 5 +++--
.../spark/datasource/v2/writer/PhoenixDataWriter.java | 6 --
34 files changed, 112 insertions(+), 118 deletions(-)
diff --git
a/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java
b/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java
index 71c4f8e..c5b5052 100644
---
a/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java
+++
b/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/compat/HiveCompatUtil.java
@@ -17,7 +17,6 @@
*/
package org.apache.phoenix.compat;
-import org.apache.commons.logging.Log;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.QueryState;
import org.apache.hadoop.hive.ql.io.AcidOutputFormat;
@@ -27,6 +26,7 @@ import org.apache.hadoop.hive.ql.parse.ParseDriver;
import org.apache.hadoop.hive.ql.parse.SemanticAnalyzer;
import org.apache.hadoop.hive.ql.plan.ExprNodeGenericFuncDesc;
import org.apache.hadoop.hive.ql.session.SessionState;
+import org.slf4j.Logger;
import java.io.File;
import java.lang.reflect.Method;
@@ -44,7 +44,7 @@ public class HiveCompatUtil {
return comparisonExpr;
}
-public static String getOptionsValue(AcidOutputFormat.Options options,
AtomicReference GET_BUCKET_METHOD_REF, AtomicReference
GET_BUCKET_ID_METHOD_REF, Log LOG) {
+public static String getOptionsValue(AcidOutputFormat.Options options,
AtomicReference GET_BUCKET_METHOD_REF, AtomicReference
GET_BUCKET_ID_METHOD_REF, Logger LOG) {
StringBuilder content = new StringBuilder();
int bucket = options.getBucket();
diff --git
a/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java
b/phoenix-hive-base/phoenix4-hive/src/main/java/org/apache/phoenix/hive/objectinspector/AbstractPhoenixObjectInspector.java
index 7e406cd..1a0e2e9 100644
---
[phoenix] branch master updated: PHOENIX-6232 Correlated subquery should not push to RegionServer as the probe side of the Hash join
This is an automated email from the ASF dual-hosted git repository.
chenglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new 0c6df0b PHOENIX-6232 Correlated subquery should not push to
RegionServer as the probe side of the Hash join
0c6df0b is described below
commit 0c6df0b8ca270104d12d2ea678f4f70d67d41a26
Author: chenglei
AuthorDate: Thu Dec 3 11:49:42 2020 +0800
PHOENIX-6232 Correlated subquery should not push to RegionServer as the
probe side of the Hash join
---
.../phoenix/end2end/join/HashJoinMoreIT.java | 104 +
.../org/apache/phoenix/compile/JoinCompiler.java | 252 +++--
.../org/apache/phoenix/compile/QueryCompiler.java | 33 +--
.../apache/phoenix/compile/SubselectRewriter.java | 7 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 38 ++--
.../apache/phoenix/optimize/QueryOptimizer.java| 20 +-
.../org/apache/phoenix/util/ParseNodeUtil.java | 45
.../phoenix/compile/JoinQueryCompilerTest.java | 48 ++--
.../apache/phoenix/compile/QueryCompilerTest.java | 193 +++-
9 files changed, 591 insertions(+), 149 deletions(-)
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
index 3a1b015..f0f411f 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
@@ -21,18 +21,23 @@ import static
org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
import java.sql.Array;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
+import java.sql.SQLFeatureNotSupportedException;
import java.sql.Statement;
import java.util.Properties;
+import org.apache.phoenix.compile.QueryPlan;
import org.apache.phoenix.end2end.ParallelStatsDisabledIT;
+import org.apache.phoenix.execute.HashJoinPlan;
import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.QueryUtil;
+import org.apache.phoenix.util.TestUtil;
import org.junit.Test;
public class HashJoinMoreIT extends ParallelStatsDisabledIT {
@@ -912,4 +917,103 @@ public class HashJoinMoreIT extends
ParallelStatsDisabledIT {
conn.close();
}
}
+
+@Test
+public void testHashJoinBug6232() throws Exception {
+Connection conn = null;
+try {
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+conn = DriverManager.getConnection(getUrl(), props);
+
+String tableName1 = generateUniqueName();
+String tableName2 = generateUniqueName();
+
+String sql="CREATE TABLE IF NOT EXISTS "+tableName1+" ( "+
+"AID INTEGER PRIMARY KEY,"+
+"AGE INTEGER"+
+")";
+conn.createStatement().execute(sql);
+
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (1,11)");
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (2,22)");
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (3,33)");
+conn.commit();
+
+sql="CREATE TABLE IF NOT EXISTS "+tableName2+" ( "+
+"BID INTEGER PRIMARY KEY,"+
+"CODE INTEGER"+
+")";
+conn.createStatement().execute(sql);
+
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (1,66)");
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (2,11)");
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (3,22)");
+conn.commit();
+
+sql="select a.aid from " + tableName1 + " a inner join "+
+"(select bid,code from " + tableName2 + " where code > 10
limit 3) b on a.aid = b.bid "+
+"where a.age > (select code from " + tableName2 + " c
where c.bid = 2) order by a.aid";
+ResultSet rs=conn.prepareStatement(sql).executeQuery();
+assertTrue(rs.next());
+assertTrue(rs.getInt(1) == 2);
+assertTrue(rs.next());
+assertTrue(rs.getInt(1) == 3);
+assertTrue(!rs.next());
+
+sql = "select a.aid from (select aid,age from " + tableName1 + "
where age >=11 and age<=33) a inner join "+
+"(select bid,code from " + tableName2 + " where code > 10
limit 3) b on a.aid = b.bid "+
+"where a.age > (select code
[phoenix] branch 4.x updated: PHOENIX-6232 Correlated subquery should not push to RegionServer as the probe side of the Hash join
This is an automated email from the ASF dual-hosted git repository.
chenglei pushed a commit to branch 4.x
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x by this push:
new 5e70f76 PHOENIX-6232 Correlated subquery should not push to
RegionServer as the probe side of the Hash join
5e70f76 is described below
commit 5e70f76bb59ff08eff699f3cbfc532c4f8d86667
Author: chenglei
AuthorDate: Thu Dec 3 11:41:12 2020 +0800
PHOENIX-6232 Correlated subquery should not push to RegionServer as the
probe side of the Hash join
---
.../phoenix/end2end/join/HashJoinMoreIT.java | 104 +
.../org/apache/phoenix/compile/JoinCompiler.java | 249 +++--
.../org/apache/phoenix/compile/QueryCompiler.java | 32 +--
.../apache/phoenix/compile/SubselectRewriter.java | 7 +-
.../org/apache/phoenix/jdbc/PhoenixStatement.java | 38 ++--
.../apache/phoenix/optimize/QueryOptimizer.java| 19 +-
.../org/apache/phoenix/util/ParseNodeUtil.java | 45
.../phoenix/compile/JoinQueryCompilerTest.java | 48 ++--
.../apache/phoenix/compile/QueryCompilerTest.java | 193 +++-
9 files changed, 588 insertions(+), 147 deletions(-)
diff --git
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
index 3a1b015..f0f411f 100644
---
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
+++
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/join/HashJoinMoreIT.java
@@ -21,18 +21,23 @@ import static
org.apache.phoenix.util.TestUtil.TEST_PROPERTIES;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
import java.sql.Array;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
+import java.sql.SQLFeatureNotSupportedException;
import java.sql.Statement;
import java.util.Properties;
+import org.apache.phoenix.compile.QueryPlan;
import org.apache.phoenix.end2end.ParallelStatsDisabledIT;
+import org.apache.phoenix.execute.HashJoinPlan;
import org.apache.phoenix.util.PropertiesUtil;
import org.apache.phoenix.util.QueryUtil;
+import org.apache.phoenix.util.TestUtil;
import org.junit.Test;
public class HashJoinMoreIT extends ParallelStatsDisabledIT {
@@ -912,4 +917,103 @@ public class HashJoinMoreIT extends
ParallelStatsDisabledIT {
conn.close();
}
}
+
+@Test
+public void testHashJoinBug6232() throws Exception {
+Connection conn = null;
+try {
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+conn = DriverManager.getConnection(getUrl(), props);
+
+String tableName1 = generateUniqueName();
+String tableName2 = generateUniqueName();
+
+String sql="CREATE TABLE IF NOT EXISTS "+tableName1+" ( "+
+"AID INTEGER PRIMARY KEY,"+
+"AGE INTEGER"+
+")";
+conn.createStatement().execute(sql);
+
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (1,11)");
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (2,22)");
+conn.createStatement().execute("UPSERT INTO
"+tableName1+"(AID,AGE) VALUES (3,33)");
+conn.commit();
+
+sql="CREATE TABLE IF NOT EXISTS "+tableName2+" ( "+
+"BID INTEGER PRIMARY KEY,"+
+"CODE INTEGER"+
+")";
+conn.createStatement().execute(sql);
+
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (1,66)");
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (2,11)");
+conn.createStatement().execute("UPSERT INTO
"+tableName2+"(BID,CODE) VALUES (3,22)");
+conn.commit();
+
+sql="select a.aid from " + tableName1 + " a inner join "+
+"(select bid,code from " + tableName2 + " where code > 10
limit 3) b on a.aid = b.bid "+
+"where a.age > (select code from " + tableName2 + " c
where c.bid = 2) order by a.aid";
+ResultSet rs=conn.prepareStatement(sql).executeQuery();
+assertTrue(rs.next());
+assertTrue(rs.getInt(1) == 2);
+assertTrue(rs.next());
+assertTrue(rs.getInt(1) == 3);
+assertTrue(!rs.next());
+
+sql = "select a.aid from (select aid,age from " + tableName1 + "
where age >=11 and age<=33) a inner join "+
+"(select bid,code from " + tableName2 + " where code > 10
limit 3) b on a.aid = b.bid "+
+"where a.age > (select code from "
Apache-Phoenix | master | HBase 2.2 | Build #133 FAILURE
master branch HBase 2.2 build #133 status FAILURE Build #133 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/133/
Apache-Phoenix | master | HBase 2.2 | Build #132 ABORTED
master branch HBase 2.2 build #132 status ABORTED Build #132 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/132/
Apache-Phoenix | 4.x | HBase 1.6 | Build #127 FAILURE
4.x branch HBase 1.6 build #127 status FAILURE Build #127 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/127/
Apache-Phoenix | 4.x | HBase 1.4 | Build #127 SUCCESS
4.x branch HBase 1.4 build #127 status SUCCESS Build #127 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/127/
Apache-Phoenix | 4.x | HBase 1.3 | Build #127 FAILURE
4.x branch HBase 1.3 build #127 status FAILURE Build #127 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/127/
Apache-Phoenix | master | HBase 2.3 | Build #132 FAILURE
master branch HBase 2.3 build #132 status FAILURE Build #132 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/132/
Apache-Phoenix | master | HBase 2.1 | Build #132 FAILURE
master branch HBase 2.1 build #132 status FAILURE Build #132 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/132/
[phoenix] branch master updated (99a5f4c -> 29c45c6)
This is an automated email from the ASF dual-hosted git repository. chinmayskulkarni pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/phoenix.git. from 99a5f4c PHOENIX-6239: NullPointerException when index table does not use COLUMN_ENCODED_BYTES (#994) add 29c45c6 PHOENIX-6086 : Avoid restoring snapshots of System tables No new revisions were added by this update. Summary of changes: .../phoenix/query/ConnectionQueryServicesImpl.java | 97 +++--- 1 file changed, 13 insertions(+), 84 deletions(-)
[phoenix] branch 4.x updated (0b69306 -> b8cb658)
This is an automated email from the ASF dual-hosted git repository. chinmayskulkarni pushed a change to branch 4.x in repository https://gitbox.apache.org/repos/asf/phoenix.git. from 0b69306 PHOENIX-6239: NullPointerException when index table does not use COLUMN_ENCODED_BYTES (#994) add b8cb658 PHOENIX-6086 : Avoid restoring snapshots of System tables No new revisions were added by this update. Summary of changes: .../phoenix/query/ConnectionQueryServicesImpl.java | 97 +++--- 1 file changed, 13 insertions(+), 84 deletions(-)
[phoenix] branch master updated (8c260aa -> 99a5f4c)
This is an automated email from the ASF dual-hosted git repository. skadam pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/phoenix.git. from 8c260aa PHOENIX-6237 Relocate javax. classes in phoenix-client add 99a5f4c PHOENIX-6239: NullPointerException when index table does not use COLUMN_ENCODED_BYTES (#994) No new revisions were added by this update. Summary of changes: .../it/java/org/apache/phoenix/end2end/AlterAddCascadeIndexIT.java | 6 +++--- .../src/main/java/org/apache/phoenix/schema/MetaDataClient.java | 4 +++- 2 files changed, 6 insertions(+), 4 deletions(-)
Apache-Phoenix | master | HBase 2.2 | Build #131 SUCCESS
master branch HBase 2.2 build #131 status SUCCESS Build #131 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/master/131/
Apache-Phoenix | 4.x | HBase 1.3 | Build #126 FAILURE
4.x branch HBase 1.3 build #126 status FAILURE Build #126 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/126/
Apache-Phoenix | 4.x | HBase 1.6 | Build #126 FAILURE
4.x branch HBase 1.6 build #126 status FAILURE Build #126 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/126/
Apache-Phoenix | 4.x | HBase 1.4 | Build #125 SUCCESS
4.x branch HBase 1.4 build #125 status SUCCESS Build #125 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/125/
Apache-Phoenix | 4.x | HBase 1.6 | Build #125 FAILURE
4.x branch HBase 1.6 build #125 status FAILURE Build #125 https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-mulitbranch/job/4.x/125/
