date:20160815

Jenkins build is back to normal : Phoenix-4.x-HBase-1.0 #605

2016-08-15 Thread Apache Jenkins Server

See

Build failed in Jenkins: Phoenix | Master #1362

2016-08-15 Thread Apache Jenkins Server

See 

Changes:

[ankitsinghal59] PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

--
[...truncated 725 lines...]
Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 171.76 sec - in 
org.apache.phoenix.iterate.RoundRobinResultIteratorIT
Running org.apache.phoenix.tx.TransactionIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 95.529 sec - in 
org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Running org.apache.phoenix.tx.TxCheckpointIT
Tests run: 128, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 713.334 sec - 
in org.apache.phoenix.end2end.index.IndexIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 749.828 sec - 
in org.apache.phoenix.end2end.index.LocalIndexIT
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 204.025 sec - 
in org.apache.phoenix.tx.TxCheckpointIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 304.815 sec - 
in org.apache.phoenix.tx.TransactionIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1,020.995 sec 
- in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

Tests run: 1202, Failures: 0, Errors: 0, Skipped: 5

[INFO] 
[INFO] --- maven-failsafe-plugin:2.19.1:integration-test 
(HBaseManagedTimeTableReuseTest) @ phoenix-core ---

---
 T E S T S
---
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.892 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.AlterSessionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.117 sec - in 
org.apache.phoenix.end2end.AlterSessionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.523 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.553 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.533 sec - 
in org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 47.042 sec - 
in org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 32.205 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.449 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.964 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.217 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.132 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 68.804 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.321 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.098 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.184 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.459 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.416 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.218 sec - in 
org.apache.phoenix.end2end.

Jenkins build is back to normal : Phoenix | 4.x-HBase-0.98 #1267

2016-08-15 Thread Apache Jenkins Server

See

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-0.98 520673f4a -> 6efbf404e


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6efbf404
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6efbf404
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6efbf404

Branch: refs/heads/4.8-HBase-0.98
Commit: 6efbf404ed577a6dbd8635e32aa16e5a2a4b4ea1
Parents: 520673f
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:33:01 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/6efbf404/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6efbf404/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6efbf404/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.0 fa7b7e2fc -> 6f2d2220c


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6f2d2220
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6f2d2220
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6f2d2220

Branch: refs/heads/4.8-HBase-1.0
Commit: 6f2d2220ca0d106ea1a96bd0bfa1c1fc57f311a6
Parents: fa7b7e2
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:32:07 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/6f2d2220/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6f2d2220/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6f2d2220/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 0a116960e -> 6d4e5e0ef


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6d4e5e0e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6d4e5e0e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6d4e5e0e

Branch: refs/heads/4.x-HBase-0.98
Commit: 6d4e5e0ef6414412233793718cc5b043d0b9313e
Parents: 0a11696
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:32:35 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/6d4e5e0e/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6d4e5e0e/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/6d4e5e0e/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 c7c34385d -> c6074b8e8


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c6074b8e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c6074b8e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c6074b8e

Branch: refs/heads/4.x-HBase-1.1
Commit: c6074b8e8e0291184103fefed629b32e00d73e0e
Parents: c7c3438
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:30:51 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c6074b8e/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c6074b8e/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c6074b8e/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.1 510331702 -> c5e1cc077


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c5e1cc07
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c5e1cc07
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c5e1cc07

Branch: refs/heads/4.8-HBase-1.1
Commit: c5e1cc0773c554dcd45385eaa7dc871596113eac
Parents: 5103317
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:31:15 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c5e1cc07/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c5e1cc07/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c5e1cc07/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 d3c7c9b48 -> 24e670d71


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/24e670d7
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/24e670d7
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/24e670d7

Branch: refs/heads/4.x-HBase-1.0
Commit: 24e670d7163e2a04f15fc48fdc2bac6887c32e0e
Parents: d3c7c9b
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:31:46 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/24e670d7/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/24e670d7/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/24e670d7/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.2 2e8e5ab12 -> 116231d10


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/116231d1
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/116231d1
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/116231d1

Branch: refs/heads/4.8-HBase-1.2
Commit: 116231d10106a2336f1b6e3275990e1b0811baed
Parents: 2e8e5ab
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:30:19 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/116231d1/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/116231d1/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/116231d1/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

2016-08-15 Thread ankit

Repository: phoenix
Updated Branches:
  refs/heads/master 44cf0827f -> 657917bfb


PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/657917bf
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/657917bf
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/657917bf

Branch: refs/heads/master
Commit: 657917bfb15ecd5bef4616458f2c8cd3ede0cf6b
Parents: 44cf082
Author: Ankit Singhal 
Authored: Tue Aug 16 10:29:18 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Aug 16 10:29:18 2016 +0530

--
 .../org/apache/phoenix/end2end/DateTimeIT.java  | 44 
 .../org/apache/phoenix/schema/types/PDate.java  |  2 +-
 .../apache/phoenix/schema/types/PTimestamp.java |  2 +-
 3 files changed, 46 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/657917bf/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
index 461816a..7ffc54f 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DateTimeIT.java
@@ -732,4 +732,48 @@ public class DateTimeIT extends BaseHBaseManagedTimeIT {
 assertTrue(rs.next());
 assertEquals(new 
java.util.Date().getYear(),rs.getTimestamp(2).getYear());
 }
+
+@Test
+public void testLiteralDateComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > TIMESTAMP 
'2016-05-11 00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select DATE '2016-05-10 00:00:00' > TIMESTAMP '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
+
+@Test
+public void testLiteralDateTimestampComparison2() throws Exception {
+ResultSet rs =
+conn.createStatement().executeQuery(
+"select TIMESTAMP '2016-05-10 00:00:00' > DATE '2016-05-11 
00:00:00'");
+
+assertTrue(rs.next());
+assertEquals(false, rs.getBoolean(1));
+assertFalse(rs.next());
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/657917bf/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
index b10b1ac..c27d0fc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDate.java
@@ -129,7 +129,7 @@ public class PDate extends PDataType {
 if (rhsType == PTimestamp.INSTANCE || rhsType == 
PUnsignedTimestamp.INSTANCE) {
   return -rhsType.compareTo(rhs, lhs, PTime.INSTANCE);
 }
-return ((java.util.Date) rhs).compareTo((java.util.Date) lhs);
+return ((java.util.Date) lhs).compareTo((java.util.Date) rhs);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/657917bf/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
index 1f654fe..cdfb533 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PTimestamp.java
@@ -174,7 +174,7 @@ public class PTimestamp extends PDataType {
 if (equalsAny(rhsType, PTimestamp.INSTANCE, 
PUnsignedTimestamp.INSTANCE)) {
 return ((java.sql.Timestamp) lhs).compareTo((java.sql.Timestamp) 
rhs);
 }
-int c =

Build failed in Jenkins: Phoenix-4.x-HBase-1.1 #158

2016-08-15 Thread Apache Jenkins Server

See 

Changes:

[elserj] PHOENIX-3164 Cache UGI instances for remote users in PQS

--
[...truncated 2105 lines...]
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.AsyncImmutableIndexIT
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT  Time elapsed: 0.004 sec 
 <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)

Running org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT  Time elapsed: 0.003 
sec  <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)

Running org.apache.phoenix.end2end.index.MutableIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.007 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexFailureIT
org.apache.phoenix.end2end.index.MutableIndexFailureIT  Time elapsed: 0.006 sec 
 <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)

Running org.apache.phoenix.hbase.index.FailForUnsupportedHBaseVersionsIT
Running org.apache.phoenix.end2end.index.MutableIndexReplicationIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.008 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexReplicationIT
org.apache.phoenix.end2end.index.MutableIndexReplicationIT  Time elapsed: 0.005 
sec  <<< ERROR!
java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setupConfigsAndStartCluster(MutableIndexReplicationIT.java:170)
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setUpBeforeClass(MutableIndexReplicationIT.java:108)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setupConfigsAndStartCluster(MutableIndexReplicationIT.java:170)
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setUpBeforeClass(MutableIndexReplicationIT.java:108)

Running org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.006 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT  Time elapsed: 0.005 
sec  <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)

Running org.apache.phoenix.end2end.index.txn.TxWriteFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.txn.TxWriteFailureIT
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT  Time elapsed: 0.003 sec  
<<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT.doSetup(TxWriteFailureIT.java:86)
Caused by: java.io.IOExcep

Apache-Phoenix | Master | Build Successful

2016-08-15 Thread Apache Jenkins Server

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
[elserj] PHOENIX-3164 Cache UGI instances for remote users in PQS



Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout

Build failed in Jenkins: Phoenix | 4.x-HBase-0.98 #1266

2016-08-15 Thread Apache Jenkins Server

See 

Changes:

[elserj] PHOENIX-3164 Cache UGI instances for remote users in PQS

--
[...truncated 693 lines...]
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 75.467 sec - in 
org.apache.phoenix.iterate.RoundRobinResultIteratorIT
Running org.apache.phoenix.trace.PhoenixTraceReaderIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.077 sec - in 
org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.198 sec - in 
org.apache.phoenix.trace.PhoenixTraceReaderIT
Running org.apache.phoenix.tx.TransactionIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 90.637 sec - in 
org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Running org.apache.phoenix.tx.TxCheckpointIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 395.955 sec - 
in org.apache.phoenix.end2end.index.LocalIndexIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 169.702 sec - 
in org.apache.phoenix.tx.TransactionIT
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 104.932 sec - 
in org.apache.phoenix.tx.TxCheckpointIT
Tests run: 128, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 530.023 sec - 
in org.apache.phoenix.end2end.index.IndexIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 627.185 sec - 
in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

Tests run: 1198, Failures: 0, Errors: 0, Skipped: 5

[INFO] 
[INFO] --- maven-failsafe-plugin:2.19.1:integration-test 
(HBaseManagedTimeTableReuseTest) @ phoenix-core ---

---
 T E S T S
---
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.999 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.466 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.891 sec - in 
org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.963 sec - 
in org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.98 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 21.448 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.692 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.106 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.018 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.301 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.249 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.675 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.591 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 19.518 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.158 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.

Build failed in Jenkins: Phoenix-4.x-HBase-1.0 #604

2016-08-15 Thread Apache Jenkins Server

See 

Changes:

[elserj] PHOENIX-3164 Cache UGI instances for remote users in PQS

--
[...truncated 846 lines...]
at 
org.apache.hadoop.hbase.regionserver.HRegion.checkFamily(HRegion.java:6224)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2197)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2177)
at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.scan(RSRpcServices.java:2079)
at 
org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:31533)
at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:2049)
at org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:111)
at 
org.apache.hadoop.hbase.ipc.RpcExecutor.consumerLoop(RpcExecutor.java:133)
at org.apache.hadoop.hbase.ipc.RpcExecutor$1.run(RpcExecutor.java:108)
at java.lang.Thread.run(Thread.java:745)

at 
org.apache.phoenix.end2end.AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties(AlterTableIT.java:1201)
Caused by: java.util.concurrent.ExecutionException: 
org.apache.phoenix.exception.PhoenixIOException: 
org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException: Column family 
CF1 does not exist in region 
T3,\x01\x00\x00,1471303573139.bab50ed304fb87a496cbcc95c39fd164. in table 'T3', 
{TABLE_ATTRIBUTES => {coprocessor$1 => 
'|org.apache.phoenix.coprocessor.ScanRegionObserver|805306366|', coprocessor$2 
=> 
'|org.apache.phoenix.coprocessor.UngroupedAggregateRegionObserver|805306366|', 
coprocessor$3 => 
'|org.apache.phoenix.coprocessor.GroupedAggregateRegionObserver|805306366|', 
coprocessor$4 => 
'|org.apache.phoenix.coprocessor.ServerCachingEndpointImpl|805306366|', 
coprocessor$5 => 
'|org.apache.phoenix.hbase.index.Indexer|805306366|index.builder=org.apache.phoenix.index.PhoenixIndexBuilder,org.apache.hadoop.hbase.index.codec.class=org.apache.phoenix.index.PhoenixIndexCodec',
 METADATA => {'COMPACTION_ENABLED' => 'false'}}, {NAME => '0', 
DATA_BLOCK_ENCODING => 'FAST_DIFF', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => 
'1', COMPRESSION => 'NONE', VERSIONS => '1', TTL => 'FOREVER', MIN_VERSIONS => 
'0', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65536', IN_MEMORY => 'false', 
BLOCKCACHE => 'true'}
at 
org.apache.hadoop.hbase.regionserver.HRegion.checkFamily(HRegion.java:6224)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2197)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2177)
at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.scan(RSRpcServices.java:2079)
at 
org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:31533)
at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:2049)
at org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:111)
at 
org.apache.hadoop.hbase.ipc.RpcExecutor.consumerLoop(RpcExecutor.java:133)
at org.apache.hadoop.hbase.ipc.RpcExecutor$1.run(RpcExecutor.java:108)
at java.lang.Thread.run(Thread.java:745)

at 
org.apache.phoenix.end2end.AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties(AlterTableIT.java:1201)
Caused by: org.apache.phoenix.exception.PhoenixIOException: 
org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException: Column family 
CF1 does not exist in region 
T3,\x01\x00\x00,1471303573139.bab50ed304fb87a496cbcc95c39fd164. in table 'T3', 
{TABLE_ATTRIBUTES => {coprocessor$1 => 
'|org.apache.phoenix.coprocessor.ScanRegionObserver|805306366|', coprocessor$2 
=> 
'|org.apache.phoenix.coprocessor.UngroupedAggregateRegionObserver|805306366|', 
coprocessor$3 => 
'|org.apache.phoenix.coprocessor.GroupedAggregateRegionObserver|805306366|', 
coprocessor$4 => 
'|org.apache.phoenix.coprocessor.ServerCachingEndpointImpl|805306366|', 
coprocessor$5 => 
'|org.apache.phoenix.hbase.index.Indexer|805306366|index.builder=org.apache.phoenix.index.PhoenixIndexBuilder,org.apache.hadoop.hbase.index.codec.class=org.apache.phoenix.index.PhoenixIndexCodec',
 METADATA => {'COMPACTION_ENABLED' => 'false'}}, {NAME => '0', 
DATA_BLOCK_ENCODING => 'FAST_DIFF', BLOOMFILTER => 'ROW', REPLICATION_SCOPE => 
'1', COMPRESSION => 'NONE', VERSIONS => '1', TTL => 'FOREVER', MIN_VERSIONS => 
'0', KEEP_DELETED_CELLS => 'FALSE', BLOCKSIZE => '65536', IN_MEMORY => 'false', 
BLOCKCACHE => 'true'}
at 
org.apache.hadoop.hbase.regionserver.HRegion.checkFamily(HRegion.java:6224)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2197)
at 
org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2177)
at 
org.apache.hadoop.hbase.regionserver.RSRpcServices.scan(RSRpcServices.java:2079)
at 
org.apache.hadoop.hbase.protobuf.generated.ClientProtos$Cli

[3/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/d3c7c9b4
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d3c7c9b4
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d3c7c9b4

Branch: refs/heads/4.x-HBase-1.0
Commit: d3c7c9b48e02eef065c0c3af0c25ef3a279b8a3d
Parents: b64b08f
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:42:06 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3c7c9b4/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index e945021..42f954a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3c7c9b4/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index 9823182..70b85db 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -242,6 +242,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3c7c9b4/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.r

[7/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/520673f4
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/520673f4
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/520673f4

Branch: refs/heads/4.8-HBase-0.98
Commit: 520673f4a8f82befa5f5111c6879e5c06d4d3443
Parents: 1d07324
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:51:06 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/520673f4/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index d574334..e74bb9e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -205,6 +205,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/520673f4/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index 892482d..339ea6e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -238,6 +238,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/520673f4/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.

[1/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-0.98 1d07324cc -> 520673f4a
  refs/heads/4.8-HBase-1.0 dcd7b09d7 -> fa7b7e2fc
  refs/heads/4.8-HBase-1.1 6660a4903 -> 510331702
  refs/heads/4.8-HBase-1.2 af20adacb -> 2e8e5ab12
  refs/heads/4.x-HBase-0.98 d243b628f -> 0a116960e
  refs/heads/4.x-HBase-1.0 b64b08f31 -> d3c7c9b48
  refs/heads/4.x-HBase-1.1 1d234eab1 -> c7c34385d
  refs/heads/master 2afb16dc2 -> 44cf0827f


PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/44cf0827
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/44cf0827
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/44cf0827

Branch: refs/heads/master
Commit: 44cf0827f1e5577510ee95f149df8d552a56da3c
Parents: 2afb16d
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:31:48 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/44cf0827/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index 2ad2d43..22fa45a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/44cf0827/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index b7ea82e..83347c8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -241,6 +241,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/44cf0827/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/ph

[2/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c7c34385
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c7c34385
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c7c34385

Branch: refs/heads/4.x-HBase-1.1
Commit: c7c34385d6e6ffda9681d48d3a111aa7b2e0eb2b
Parents: 1d234ea
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:38:02 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c7c34385/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index 2ad2d43..22fa45a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c7c34385/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index b7ea82e..83347c8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -241,6 +241,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c7c34385/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.r

[4/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/0a116960
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/0a116960
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/0a116960

Branch: refs/heads/4.x-HBase-0.98
Commit: 0a116960e3b07b142dc688a8046e863e62c84fa0
Parents: d243b62
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:45:45 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/0a116960/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index d574334..e74bb9e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -205,6 +205,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/0a116960/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index 892482d..339ea6e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -238,6 +238,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/0a116960/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.

[8/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/fa7b7e2f
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/fa7b7e2f
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/fa7b7e2f

Branch: refs/heads/4.8-HBase-1.0
Commit: fa7b7e2fccbcbb7f29f8e13b4f028df9fe82b84d
Parents: dcd7b09
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:51:19 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/fa7b7e2f/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index e945021..42f954a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/fa7b7e2f/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index 9823182..70b85db 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -242,6 +242,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/fa7b7e2f/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.r

[6/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/51033170
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/51033170
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/51033170

Branch: refs/heads/4.8-HBase-1.1
Commit: 5103317020ce0f467c44cd24c880f46ed1426237
Parents: 6660a49
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:50:19 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/51033170/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index 2ad2d43..22fa45a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/51033170/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index b7ea82e..83347c8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -241,6 +241,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/51033170/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.r

[5/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

2016-08-15 Thread elserj

PHOENIX-3164 Cache UGI instances for remote users in PQS

equals(Object) and hashCode() on UGI are implemented
via reference checks (rather than the values themselves).
This creates a situation where new PhoenixConnections are
opened for the same user via PQS.


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/2e8e5ab1
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/2e8e5ab1
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/2e8e5ab1

Branch: refs/heads/4.8-HBase-1.2
Commit: 2e8e5ab12fbcaea355af8b86ac0c084098e6e89f
Parents: af20ada
Author: Josh Elser 
Authored: Tue Aug 9 14:52:20 2016 -0400
Committer: Josh Elser 
Committed: Mon Aug 15 18:50:03 2016 -0400

--
 .../org/apache/phoenix/query/QueryServices.java |  3 +
 .../phoenix/query/QueryServicesOptions.java |  4 +
 .../apache/phoenix/queryserver/server/Main.java | 61 --
 .../server/PhoenixDoAsCallbackTest.java | 89 
 4 files changed, 149 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/2e8e5ab1/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
index 2ad2d43..22fa45a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServices.java
@@ -206,6 +206,9 @@ public interface QueryServices extends SQLCloseable {
 public static final String QUERY_SERVER_DNS_NAMESERVER_ATTRIB = 
"phoenix.queryserver.dns.nameserver";
 public static final String QUERY_SERVER_DNS_INTERFACE_ATTRIB = 
"phoenix.queryserver.dns.interface";
 public static final String QUERY_SERVER_HBASE_SECURITY_CONF_ATTRIB = 
"hbase.security.authentication";
+public static final String QUERY_SERVER_UGI_CACHE_MAX_SIZE = 
"phoenix.queryserver.ugi.cache.max.size";
+public static final String QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 
"phoenix.queryserver.ugi.cache.initial.size";
+public static final String QUERY_SERVER_UGI_CACHE_CONCURRENCY = 
"phoenix.queryserver.ugi.cache.concurrency";
 
 public static final String RENEW_LEASE_ENABLED = 
"phoenix.scanner.lease.renew.enabled";
 public static final String RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS 
= "phoenix.scanner.lease.renew.interval";

http://git-wip-us.apache.org/repos/asf/phoenix/blob/2e8e5ab1/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
index b7ea82e..83347c8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/QueryServicesOptions.java
@@ -241,6 +241,10 @@ public class QueryServicesOptions {
 // doesn't depend on phoenix-core.
 public static final String DEFAULT_QUERY_SERVER_SERIALIZATION = "PROTOBUF";
 public static final int DEFAULT_QUERY_SERVER_HTTP_PORT = 8765;
+public static final long DEFAULT_QUERY_SERVER_UGI_CACHE_MAX_SIZE = 1000L;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_INITIAL_SIZE = 100;
+public static final int DEFAULT_QUERY_SERVER_UGI_CACHE_CONCURRENCY = 10;
+
 public static final boolean DEFAULT_RENEW_LEASE_ENABLED = true;
 public static final int 
DEFAULT_RUN_RENEW_LEASE_FREQUENCY_INTERVAL_MILLISECONDS =
 DEFAULT_HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD / 2;

http://git-wip-us.apache.org/repos/asf/phoenix/blob/2e8e5ab1/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
--
diff --git 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
index fc2ee34..4b3ca7e 100644
--- 
a/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
+++ 
b/phoenix-queryserver/src/main/java/org/apache/phoenix/queryserver/server/Main.java
@@ -18,14 +18,15 @@
 package org.apache.phoenix.queryserver.server;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+
 import org.apache.calcite.avatica.Meta;
 import org.apache.calcite.avatica.remote.Driver;
 import org.apache.calcite.avatica.r

Apache-Phoenix | Master | Build Successful

2016-08-15 Thread Apache Jenkins Server

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
[jmahonin] PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes



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-0.98 | Build Successful

2016-08-15 Thread Apache Jenkins Server

4.x-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.x-HBase-0.98

Compiled Artifacts https://builds.apache.org/job/Phoenix-4.x-HBase-0.98/lastSuccessfulBuild/artifact/

Test Report https://builds.apache.org/job/Phoenix-4.x-HBase-0.98/lastCompletedBuild/testReport/

Changes
[jmahonin] PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes



Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #22

2016-08-15 Thread Apache Jenkins Server

See 

--
Started by user mujtaba
[EnvInject] - Loading node environment variables.
Building remotely on ubuntu-4 (Ubuntu yahoo-not-h2 ubuntu ubuntu4 docker) in 
workspace 
[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/hudson1062396343794992727.sh
core file size  (blocks, -c) 0
data seg size   (kbytes, -d) unlimited
scheduling priority (-e) 0
file size   (blocks, -f) unlimited
pending signals (-i) 386178
max locked memory   (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files  (-n) 6
pipe size(512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority  (-r) 0
stack size  (kbytes, -s) 8192
cpu time   (seconds, -t) unlimited
max user processes  (-u) 10240
virtual memory  (kbytes, -v) unlimited
file locks  (-x) unlimited
core id : 0
core id : 1
core id : 10
core id : 9
physical id : 0
physical id : 1
MemTotal:   49453208 kB
MemFree:11686000 kB
Filesystem   Size  Used Avail Use% Mounted on
udev  24G   12K   24G   1% /dev
tmpfs4.8G  840K  4.8G   1% /run
/dev/mapper/pomona--vg-root  3.6T  742G  2.7T  22% /
none 4.0K 0  4.0K   0% /sys/fs/cgroup
none 5.0M 0  5.0M   0% /run/lock
none  24G 0   24G   0% /run/shm
none 100M 0  100M   0% /run/user
/dev/sda2237M   84M  141M  38% /boot
apache-maven-2.2.1
apache-maven-3.0.4
apache-maven-3.0.5
apache-maven-3.2.1
apache-maven-3.2.5
apache-maven-3.3.3
apache-maven-3.3.9
latest
latest2
latest3



Verifying compile level compatibility with HBase 0.98 with Phoenix 
Cloning into 'hbase'...
Switched to a new branch '0.98'
Branch 0.98 set up to track remote branch 0.98 from origin.

main:
 [exec] 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common
 [exec] 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common

main:
[mkdir] Created dir: 

 [exec] tar: hadoop-snappy-nativelibs.tar: Cannot open: No such file or 
directory
 [exec] tar: Error is not recoverable: exiting now
 [exec] Result: 2

main:
[mkdir] Created dir: 

 [copy] Copying 20 files to 

[mkdir] Created dir: 

[mkdir] Created dir: 


main:
[mkdir] Created dir: 

 [copy] Copying 17 files to 

[mkdir] Created dir: 


main:
[mkdir] Created dir: 

 [copy] Copying 1 file to 

[mkdir] Created dir: 


HBase pom.xml:

Got HBase version as 0.98.21
Cloning into 'phoenix'...
Switched to a new branch '4.x-HBase-0.98'
Branch 4.x-HBase-0.98 set up to track remote branch 4.x-HBase-0.98 from origin.
ANTLR Parser Generator  Version 3.5.2
Output file 

 does not exist: must build 

PhoenixSQL.g



Verifying compile level compatibility with HBase branch-1.2 with Phoenix 
Cloning into 'hbase'...
Switched to a new branch 'branch-1.2'
Branch branch-1.2 set up to track remote branch branch-1.2 from origin.

main:
 [exec] 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/phoenix/hbase/

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #21

2016-08-15 Thread Apache Jenkins Server

See 

--
Started by user mujtaba
[EnvInject] - Loading node environment variables.
Building remotely on ubuntu-4 (Ubuntu yahoo-not-h2 ubuntu ubuntu4 docker) in 
workspace 
[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/hudson4458926614029793797.sh
core file size  (blocks, -c) 0
data seg size   (kbytes, -d) unlimited
scheduling priority (-e) 0
file size   (blocks, -f) unlimited
pending signals (-i) 386178
max locked memory   (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files  (-n) 6
pipe size(512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority  (-r) 0
stack size  (kbytes, -s) 8192
cpu time   (seconds, -t) unlimited
max user processes  (-u) 10240
virtual memory  (kbytes, -v) unlimited
file locks  (-x) unlimited
core id : 0
core id : 1
core id : 10
core id : 9
physical id : 0
physical id : 1
MemTotal:   49453208 kB
MemFree:10463276 kB
Filesystem   Size  Used Avail Use% Mounted on
udev  24G   12K   24G   1% /dev
tmpfs4.8G  840K  4.8G   1% /run
/dev/mapper/pomona--vg-root  3.6T  742G  2.7T  22% /
none 4.0K 0  4.0K   0% /sys/fs/cgroup
none 5.0M 0  5.0M   0% /run/lock
none  24G 0   24G   0% /run/shm
none 100M 0  100M   0% /run/user
/dev/sda2237M   84M  141M  38% /boot
/tmp/hudson4458926614029793797.sh: line 7: ll: command not found
Build step 'Execute shell' marked build as failure

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #20

2016-08-15 Thread Apache Jenkins Server

See 

--
Started by user mujtaba
[EnvInject] - Loading node environment variables.
Building remotely on ubuntu-2 (Ubuntu yahoo-not-h2 ubuntu docker) in workspace 

[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/hudson1347754586506332038.sh
core file size  (blocks, -c) 0
data seg size   (kbytes, -d) unlimited
scheduling priority (-e) 0
file size   (blocks, -f) unlimited
pending signals (-i) 386178
max locked memory   (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files  (-n) 6
pipe size(512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority  (-r) 0
stack size  (kbytes, -s) 8192
cpu time   (seconds, -t) unlimited
max user processes  (-u) 10240
virtual memory  (kbytes, -v) unlimited
file locks  (-x) unlimited
core id : 0
core id : 1
core id : 10
core id : 9
physical id : 0
physical id : 1
MemTotal:   49453340 kB
MemFree: 9719688 kB
Filesystem  Size  Used Avail Use% Mounted on
udev 24G   12K   24G   1% /dev
tmpfs   4.8G  720K  4.8G   1% /run
/dev/dm-0   3.6T  773G  2.7T  23% /
none4.0K 0  4.0K   0% /sys/fs/cgroup
none5.0M 0  5.0M   0% /run/lock
none 24G 0   24G   0% /run/shm
none100M 0  100M   0% /run/user
/dev/sda2   237M  107M  118M  48% /boot



Verifying compile level compatibility with HBase 0.98 with Phoenix 
Cloning into 'hbase'...
Switched to a new branch '0.98'
Branch 0.98 set up to track remote branch 0.98 from origin.
/tmp/hudson1347754586506332038.sh: line 25: 
/home/jenkins/tools/maven/apache-Maven: No such file or directory
Build step 'Execute shell' marked build as failure

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

2016-08-15 Thread jmahonin

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.2 f5c11a191 -> af20adacb


PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan 
Hadoop)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/af20adac
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/af20adac
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/af20adac

Branch: refs/heads/4.8-HBase-1.2
Commit: af20adacbb44e701da64436d37a0dc2b72f80841
Parents: f5c11a1
Author: Josh Mahonin 
Authored: Mon Aug 15 11:55:56 2016 -0400
Committer: Josh Mahonin 
Committed: Mon Aug 15 14:10:27 2016 -0400

--
 phoenix-spark/src/it/resources/setup.sql|  6 +++
 .../apache/phoenix/spark/PhoenixSparkIT.scala   | 49 
 .../apache/phoenix/spark/PhoenixRelation.scala  | 26 ++-
 3 files changed, 70 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/af20adac/phoenix-spark/src/it/resources/setup.sql
--
diff --git a/phoenix-spark/src/it/resources/setup.sql 
b/phoenix-spark/src/it/resources/setup.sql
index aa2cee1..e56924f 100644
--- a/phoenix-spark/src/it/resources/setup.sql
+++ b/phoenix-spark/src/it/resources/setup.sql
@@ -48,3 +48,9 @@ CREATE TABLE TEST_SMALL_TINY (ID BIGINT NOT NULL PRIMARY KEY, 
COL1 SMALLINT, COL
 UPSERT INTO TEST_SMALL_TINY VALUES (1, 32767, 127)
 CREATE TABLE DATE_TEST(ID BIGINT NOT NULL PRIMARY KEY, COL1 DATE)
 UPSERT INTO DATE_TEST VALUES(1, CURRENT_DATE())
+CREATE TABLE "space" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR)
+UPSERT INTO "space" VALUES ('key1', 'xyz')
+CREATE TABLE "small" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR, 
"salary" INTEGER )
+UPSERT INTO "small" VALUES ('key1', 'foo', 1)
+UPSERT INTO "small" VALUES ('key2', 'bar', 2)
+UPSERT INTO "small" VALUES ('key3', 'xyz', 3)

http://git-wip-us.apache.org/repos/asf/phoenix/blob/af20adac/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
--
diff --git 
a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala 
b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
index c216406..7d05f07 100644
--- a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
+++ b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
@@ -621,6 +621,55 @@ class PhoenixSparkIT extends FunSuite with Matchers with 
BeforeAndAfterAll {
 assert(Math.abs(epoch - dt) < 8640)
   }
 
+  test("Filter operation doesn't work for column names containing a white 
space (PHOENIX-2547)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("space"),
+  "zkUrl" -> quorumAddress))
+val res = df.filter(df.col("first name").equalTo("xyz"))
+// Make sure we got the right value back
+assert(res.collectAsList().size() == 1L)
+  }
+
+  test("Spark Phoenix cannot recognize Phoenix view fields (PHOENIX-2290)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+df.registerTempTable("temp")
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = sqlContext.sql("select * from temp where salary = '1' ")
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = sqlContext.sql("select * from temp where \"salary\" = '1' ")
+assert(res2.collectAsList().size() == 0L)
+
+val res3 = sqlContext.sql("select * from temp where salary > '1' ")
+assert(res3.collectAsList().size() == 2L)
+  }
+
+  test("Queries with small case column-names return empty result-set when 
working with Spark Datasource Plugin (PHOENIX-2336)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = df.filter(df.col("first name").equalTo("foo"))
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = df.filter("\"first name\" = 'foo'")
+assert(res2.collectAsLi

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

2016-08-15 Thread jmahonin

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-0.98 a1c2a97c8 -> 1d07324cc


PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan 
Hadoop)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/1d07324c
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1d07324c
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1d07324c

Branch: refs/heads/4.8-HBase-0.98
Commit: 1d07324cc2e75502724637a4f610851181769370
Parents: a1c2a97
Author: Josh Mahonin 
Authored: Mon Aug 15 11:55:56 2016 -0400
Committer: Josh Mahonin 
Committed: Mon Aug 15 14:09:57 2016 -0400

--
 phoenix-spark/src/it/resources/setup.sql|  6 +++
 .../apache/phoenix/spark/PhoenixSparkIT.scala   | 49 
 .../apache/phoenix/spark/PhoenixRelation.scala  | 26 ++-
 3 files changed, 70 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/1d07324c/phoenix-spark/src/it/resources/setup.sql
--
diff --git a/phoenix-spark/src/it/resources/setup.sql 
b/phoenix-spark/src/it/resources/setup.sql
index aa2cee1..e56924f 100644
--- a/phoenix-spark/src/it/resources/setup.sql
+++ b/phoenix-spark/src/it/resources/setup.sql
@@ -48,3 +48,9 @@ CREATE TABLE TEST_SMALL_TINY (ID BIGINT NOT NULL PRIMARY KEY, 
COL1 SMALLINT, COL
 UPSERT INTO TEST_SMALL_TINY VALUES (1, 32767, 127)
 CREATE TABLE DATE_TEST(ID BIGINT NOT NULL PRIMARY KEY, COL1 DATE)
 UPSERT INTO DATE_TEST VALUES(1, CURRENT_DATE())
+CREATE TABLE "space" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR)
+UPSERT INTO "space" VALUES ('key1', 'xyz')
+CREATE TABLE "small" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR, 
"salary" INTEGER )
+UPSERT INTO "small" VALUES ('key1', 'foo', 1)
+UPSERT INTO "small" VALUES ('key2', 'bar', 2)
+UPSERT INTO "small" VALUES ('key3', 'xyz', 3)

http://git-wip-us.apache.org/repos/asf/phoenix/blob/1d07324c/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
--
diff --git 
a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala 
b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
index 127f3fd..c0b4668 100644
--- a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
+++ b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
@@ -620,6 +620,55 @@ class PhoenixSparkIT extends FunSuite with Matchers with 
BeforeAndAfterAll {
 assert(Math.abs(epoch - dt) < 8640)
   }
 
+  test("Filter operation doesn't work for column names containing a white 
space (PHOENIX-2547)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("space"),
+  "zkUrl" -> quorumAddress))
+val res = df.filter(df.col("first name").equalTo("xyz"))
+// Make sure we got the right value back
+assert(res.collectAsList().size() == 1L)
+  }
+
+  test("Spark Phoenix cannot recognize Phoenix view fields (PHOENIX-2290)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+df.registerTempTable("temp")
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = sqlContext.sql("select * from temp where salary = '1' ")
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = sqlContext.sql("select * from temp where \"salary\" = '1' ")
+assert(res2.collectAsList().size() == 0L)
+
+val res3 = sqlContext.sql("select * from temp where salary > '1' ")
+assert(res3.collectAsList().size() == 2L)
+  }
+
+  test("Queries with small case column-names return empty result-set when 
working with Spark Datasource Plugin (PHOENIX-2336)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = df.filter(df.col("first name").equalTo("foo"))
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = df.filter("\"first name\" = 'foo'")
+assert(res2.collectAs

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

2016-08-15 Thread jmahonin

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 04dc321e9 -> d243b628f


PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan 
Hadoop)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/d243b628
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d243b628
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d243b628

Branch: refs/heads/4.x-HBase-0.98
Commit: d243b628fe61605a49643c38c44e4db04c13f1c3
Parents: 04dc321
Author: Josh Mahonin 
Authored: Mon Aug 15 11:55:56 2016 -0400
Committer: Josh Mahonin 
Committed: Mon Aug 15 14:09:15 2016 -0400

--
 phoenix-spark/src/it/resources/setup.sql|  6 +++
 .../apache/phoenix/spark/PhoenixSparkIT.scala   | 49 
 .../apache/phoenix/spark/PhoenixRelation.scala  | 26 ++-
 3 files changed, 70 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/d243b628/phoenix-spark/src/it/resources/setup.sql
--
diff --git a/phoenix-spark/src/it/resources/setup.sql 
b/phoenix-spark/src/it/resources/setup.sql
index aa2cee1..e56924f 100644
--- a/phoenix-spark/src/it/resources/setup.sql
+++ b/phoenix-spark/src/it/resources/setup.sql
@@ -48,3 +48,9 @@ CREATE TABLE TEST_SMALL_TINY (ID BIGINT NOT NULL PRIMARY KEY, 
COL1 SMALLINT, COL
 UPSERT INTO TEST_SMALL_TINY VALUES (1, 32767, 127)
 CREATE TABLE DATE_TEST(ID BIGINT NOT NULL PRIMARY KEY, COL1 DATE)
 UPSERT INTO DATE_TEST VALUES(1, CURRENT_DATE())
+CREATE TABLE "space" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR)
+UPSERT INTO "space" VALUES ('key1', 'xyz')
+CREATE TABLE "small" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR, 
"salary" INTEGER )
+UPSERT INTO "small" VALUES ('key1', 'foo', 1)
+UPSERT INTO "small" VALUES ('key2', 'bar', 2)
+UPSERT INTO "small" VALUES ('key3', 'xyz', 3)

http://git-wip-us.apache.org/repos/asf/phoenix/blob/d243b628/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
--
diff --git 
a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala 
b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
index 127f3fd..c0b4668 100644
--- a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
+++ b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
@@ -620,6 +620,55 @@ class PhoenixSparkIT extends FunSuite with Matchers with 
BeforeAndAfterAll {
 assert(Math.abs(epoch - dt) < 8640)
   }
 
+  test("Filter operation doesn't work for column names containing a white 
space (PHOENIX-2547)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("space"),
+  "zkUrl" -> quorumAddress))
+val res = df.filter(df.col("first name").equalTo("xyz"))
+// Make sure we got the right value back
+assert(res.collectAsList().size() == 1L)
+  }
+
+  test("Spark Phoenix cannot recognize Phoenix view fields (PHOENIX-2290)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+df.registerTempTable("temp")
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = sqlContext.sql("select * from temp where salary = '1' ")
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = sqlContext.sql("select * from temp where \"salary\" = '1' ")
+assert(res2.collectAsList().size() == 0L)
+
+val res3 = sqlContext.sql("select * from temp where salary > '1' ")
+assert(res3.collectAsList().size() == 2L)
+  }
+
+  test("Queries with small case column-names return empty result-set when 
working with Spark Datasource Plugin (PHOENIX-2336)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = df.filter(df.col("first name").equalTo("foo"))
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = df.filter("\"first name\" = 'foo'")
+assert(res2.collectAs

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

2016-08-15 Thread jmahonin

Repository: phoenix
Updated Branches:
  refs/heads/master ba82b1cb5 -> 2afb16dc2


PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan 
Hadoop)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/2afb16dc
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/2afb16dc
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/2afb16dc

Branch: refs/heads/master
Commit: 2afb16dc2032f2be9de220946e97f87336218e80
Parents: ba82b1c
Author: Josh Mahonin 
Authored: Mon Aug 15 11:55:56 2016 -0400
Committer: Josh Mahonin 
Committed: Mon Aug 15 11:58:41 2016 -0400

--
 phoenix-spark/src/it/resources/setup.sql|  6 +++
 .../apache/phoenix/spark/PhoenixSparkIT.scala   | 49 
 .../apache/phoenix/spark/PhoenixRelation.scala  | 26 ++-
 3 files changed, 70 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/2afb16dc/phoenix-spark/src/it/resources/setup.sql
--
diff --git a/phoenix-spark/src/it/resources/setup.sql 
b/phoenix-spark/src/it/resources/setup.sql
index aa2cee1..e56924f 100644
--- a/phoenix-spark/src/it/resources/setup.sql
+++ b/phoenix-spark/src/it/resources/setup.sql
@@ -48,3 +48,9 @@ CREATE TABLE TEST_SMALL_TINY (ID BIGINT NOT NULL PRIMARY KEY, 
COL1 SMALLINT, COL
 UPSERT INTO TEST_SMALL_TINY VALUES (1, 32767, 127)
 CREATE TABLE DATE_TEST(ID BIGINT NOT NULL PRIMARY KEY, COL1 DATE)
 UPSERT INTO DATE_TEST VALUES(1, CURRENT_DATE())
+CREATE TABLE "space" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR)
+UPSERT INTO "space" VALUES ('key1', 'xyz')
+CREATE TABLE "small" ("key" VARCHAR PRIMARY KEY, "first name" VARCHAR, 
"salary" INTEGER )
+UPSERT INTO "small" VALUES ('key1', 'foo', 1)
+UPSERT INTO "small" VALUES ('key2', 'bar', 2)
+UPSERT INTO "small" VALUES ('key3', 'xyz', 3)

http://git-wip-us.apache.org/repos/asf/phoenix/blob/2afb16dc/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
--
diff --git 
a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala 
b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
index c216406..7d05f07 100644
--- a/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
+++ b/phoenix-spark/src/it/scala/org/apache/phoenix/spark/PhoenixSparkIT.scala
@@ -621,6 +621,55 @@ class PhoenixSparkIT extends FunSuite with Matchers with 
BeforeAndAfterAll {
 assert(Math.abs(epoch - dt) < 8640)
   }
 
+  test("Filter operation doesn't work for column names containing a white 
space (PHOENIX-2547)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("space"),
+  "zkUrl" -> quorumAddress))
+val res = df.filter(df.col("first name").equalTo("xyz"))
+// Make sure we got the right value back
+assert(res.collectAsList().size() == 1L)
+  }
+
+  test("Spark Phoenix cannot recognize Phoenix view fields (PHOENIX-2290)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+df.registerTempTable("temp")
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = sqlContext.sql("select * from temp where salary = '1' ")
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = sqlContext.sql("select * from temp where \"salary\" = '1' ")
+assert(res2.collectAsList().size() == 0L)
+
+val res3 = sqlContext.sql("select * from temp where salary > '1' ")
+assert(res3.collectAsList().size() == 2L)
+  }
+
+  test("Queries with small case column-names return empty result-set when 
working with Spark Datasource Plugin (PHOENIX-2336)") {
+val sqlContext = new SQLContext(sc)
+val df = sqlContext.load("org.apache.phoenix.spark", Map("table" -> 
SchemaUtil.getEscapedArgument("small"),
+  "zkUrl" -> quorumAddress))
+
+// limitation: filter / where expressions are not allowed with "double 
quotes", instead of that pass it as column expressions
+// reason: if the expression contains "double quotes" then spark sql 
parser, ignoring evaluating .. giving to next level to handle
+
+val res1 = df.filter(df.col("first name").equalTo("foo"))
+assert(res1.collectAsList().size() == 1L)
+
+val res2 = df.filter("\"first name\" = 'foo'")
+assert(res2.collectAsList().size() ==

Jenkins build is back to normal : Phoenix-4.x-HBase-1.0 #605

Build failed in Jenkins: Phoenix | Master #1362

Jenkins build is back to normal : Phoenix | 4.x-HBase-0.98 #1267

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

phoenix git commit: PHOENIX-2944 DATE Comparison Broken(Saurabh Seth)

Build failed in Jenkins: Phoenix-4.x-HBase-1.1 #158

Apache-Phoenix | Master | Build Successful

Build failed in Jenkins: Phoenix | 4.x-HBase-0.98 #1266

Build failed in Jenkins: Phoenix-4.x-HBase-1.0 #604

[3/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[7/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[1/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[2/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[4/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[8/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[6/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

[5/8] phoenix git commit: PHOENIX-3164 Cache UGI instances for remote users in PQS

Apache-Phoenix | Master | Build Successful

Apache-Phoenix | 4.x-HBase-0.98 | Build Successful

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #22

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #21

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #20

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

phoenix git commit: PHOENIX-2236 PHOENIX-2290 PHOENIX-2547 Various phoenix-spark fixes (Kalyan Hadoop)

32 matches

Site Navigation

Mail list logo

Footer information