Jenkins build is back to normal : Phoenix | Master #1185

[Apache Jenkins Server]

See 

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

[Apache Jenkins Server]

See 

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

[Apache Jenkins Server]

See 

phoenix git commit: PHOENIX-1478 Can't upsert value of 127 into column of type unsigned tinyint(Biju Nair)

[rajeshbabu]

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 8261d0d7a -> 843c64abb


PHOENIX-1478 Can't upsert value of 127 into column of type unsigned 
tinyint(Biju Nair)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 843c64abb6851dbcc6ebebee7a74d768ffe2e7c4
Parents: 8261d0d
Author: Rajeshbabu Chintaguntla 
Authored: Wed Apr 6 19:52:20 2016 +0530
Committer: Rajeshbabu Chintaguntla 
Committed: Wed Apr 6 19:52:20 2016 +0530

--
 .../src/main/java/org/apache/phoenix/schema/types/PDouble.java   | 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PFloat.java| 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PInteger.java  | 2 +-
 .../src/main/java/org/apache/phoenix/schema/types/PLong.java | 4 ++--
 4 files changed, 7 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/843c64ab/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
index 95a526e..f390813 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
@@ -175,9 +175,9 @@ public class PDouble extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (d >= Short.MIN_VALUE && d <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (d >= Byte.MIN_VALUE && d < Byte.MAX_VALUE);
+return (d >= Byte.MIN_VALUE && d <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (d >= 0 && d < Byte.MAX_VALUE);
+return (d >= 0 && d <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/843c64ab/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
index 75f8efa..31aa251 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
@@ -173,9 +173,9 @@ public class PFloat extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (f >= Short.MIN_VALUE && f <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (f >= Byte.MIN_VALUE && f < Byte.MAX_VALUE);
+return (f >= Byte.MIN_VALUE && f <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (f >= 0 && f < Byte.MAX_VALUE);
+return (f >= 0 && f <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/843c64ab/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
index 3c26fd5..2a523e7 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
@@ -106,7 +106,7 @@ public class PInteger extends PWholeNumber {
 return (i >= Byte.MIN_VALUE && i <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
 i = (Integer) value;
-return (i >= 0 && i < Byte.MAX_VALUE);
+return (i >= 0 && i <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/843c64ab/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
index f2a0e92..82fd8d3 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
+++ 

phoenix git commit: PHOENIX-1478 Can't upsert value of 127 into column of type unsigned tinyint(Biju Nair)

[rajeshbabu]

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 8cf6457bb -> c4aae6635


PHOENIX-1478 Can't upsert value of 127 into column of type unsigned 
tinyint(Biju Nair)


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

Branch: refs/heads/4.x-HBase-1.0
Commit: c4aae66355605f32ed3789213510e6ea4bfc047b
Parents: 8cf6457
Author: Rajeshbabu Chintaguntla 
Authored: Wed Apr 6 19:51:34 2016 +0530
Committer: Rajeshbabu Chintaguntla 
Committed: Wed Apr 6 19:51:34 2016 +0530

--
 .../src/main/java/org/apache/phoenix/schema/types/PDouble.java   | 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PFloat.java| 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PInteger.java  | 2 +-
 .../src/main/java/org/apache/phoenix/schema/types/PLong.java | 4 ++--
 4 files changed, 7 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c4aae663/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
index 95a526e..f390813 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
@@ -175,9 +175,9 @@ public class PDouble extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (d >= Short.MIN_VALUE && d <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (d >= Byte.MIN_VALUE && d < Byte.MAX_VALUE);
+return (d >= Byte.MIN_VALUE && d <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (d >= 0 && d < Byte.MAX_VALUE);
+return (d >= 0 && d <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c4aae663/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
index 75f8efa..31aa251 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
@@ -173,9 +173,9 @@ public class PFloat extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (f >= Short.MIN_VALUE && f <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (f >= Byte.MIN_VALUE && f < Byte.MAX_VALUE);
+return (f >= Byte.MIN_VALUE && f <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (f >= 0 && f < Byte.MAX_VALUE);
+return (f >= 0 && f <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c4aae663/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
index 3c26fd5..2a523e7 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
@@ -106,7 +106,7 @@ public class PInteger extends PWholeNumber {
 return (i >= Byte.MIN_VALUE && i <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
 i = (Integer) value;
-return (i >= 0 && i < Byte.MAX_VALUE);
+return (i >= 0 && i <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c4aae663/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
index f2a0e92..82fd8d3 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
+++ 

phoenix git commit: PHOENIX-1478 Can't upsert value of 127 into column of type unsigned tinyint(Biju Nair)

[rajeshbabu]

Repository: phoenix
Updated Branches:
  refs/heads/master b8427937d -> 1e4782187


PHOENIX-1478 Can't upsert value of 127 into column of type unsigned 
tinyint(Biju Nair)


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

Branch: refs/heads/master
Commit: 1e47821876af8100d5b4bc4dad03168eca7f5652
Parents: b842793
Author: Rajeshbabu Chintaguntla 
Authored: Wed Apr 6 19:48:53 2016 +0530
Committer: Rajeshbabu Chintaguntla 
Committed: Wed Apr 6 19:48:53 2016 +0530

--
 .../src/main/java/org/apache/phoenix/schema/types/PDouble.java   | 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PFloat.java| 4 ++--
 .../src/main/java/org/apache/phoenix/schema/types/PInteger.java  | 2 +-
 .../src/main/java/org/apache/phoenix/schema/types/PLong.java | 4 ++--
 4 files changed, 7 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/1e478218/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
index 95a526e..f390813 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDouble.java
@@ -175,9 +175,9 @@ public class PDouble extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (d >= Short.MIN_VALUE && d <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (d >= Byte.MIN_VALUE && d < Byte.MAX_VALUE);
+return (d >= Byte.MIN_VALUE && d <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (d >= 0 && d < Byte.MAX_VALUE);
+return (d >= 0 && d <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/1e478218/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
index 75f8efa..31aa251 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PFloat.java
@@ -173,9 +173,9 @@ public class PFloat extends PRealNumber {
   } else if (targetType.equals(PSmallint.INSTANCE)) {
 return (f >= Short.MIN_VALUE && f <= Short.MAX_VALUE);
   } else if (targetType.equals(PTinyint.INSTANCE)) {
-return (f >= Byte.MIN_VALUE && f < Byte.MAX_VALUE);
+return (f >= Byte.MIN_VALUE && f <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
-return (f >= 0 && f < Byte.MAX_VALUE);
+return (f >= 0 && f <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/1e478218/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
index 3c26fd5..2a523e7 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PInteger.java
@@ -106,7 +106,7 @@ public class PInteger extends PWholeNumber {
 return (i >= Byte.MIN_VALUE && i <= Byte.MAX_VALUE);
   } else if (targetType.equals(PUnsignedTinyint.INSTANCE)) {
 i = (Integer) value;
-return (i >= 0 && i < Byte.MAX_VALUE);
+return (i >= 0 && i <= Byte.MAX_VALUE);
   }
 }
 return super.isCoercibleTo(targetType, value);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/1e478218/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
index f2a0e92..82fd8d3 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PLong.java
+++ 

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

[Apache Jenkins Server]

See 

Changes:

[ankitsinghal59] PHOENIX-2817 Phoenix-Spark plugin doesn't work in secured 
env(Sergey

--
[...truncated 657 lines...]
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.111 sec - in 
org.apache.phoenix.end2end.RegexpReplaceFunctionIT
Running org.apache.phoenix.end2end.RegexpSubstrFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.642 sec - in 
org.apache.phoenix.end2end.ReadOnlyIT
Running org.apache.phoenix.end2end.ReverseFunctionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.722 sec - in 
org.apache.phoenix.end2end.RegexpSubstrFunctionIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.199 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.ReverseScanIT
Running org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.422 sec - in 
org.apache.phoenix.end2end.ReverseFunctionIT
Running org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.384 sec - in 
org.apache.phoenix.end2end.ServerExceptionIT
Running org.apache.phoenix.end2end.SignFunctionEnd2EndIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 23.282 sec - in 
org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.SkipScanAfterManualSplitIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.536 sec - in 
org.apache.phoenix.end2end.ReverseScanIT
Running org.apache.phoenix.end2end.SkipScanQueryIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.249 sec - in 
org.apache.phoenix.end2end.SignFunctionEnd2EndIT
Running org.apache.phoenix.end2end.SortMergeJoinIT
Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.596 sec - 
in org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Running org.apache.phoenix.end2end.SortMergeJoinMoreIT
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.136 sec - 
in org.apache.phoenix.end2end.SkipScanQueryIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.379 sec - in 
org.apache.phoenix.end2end.SortMergeJoinMoreIT
Running org.apache.phoenix.end2end.SortOrderIT
Running org.apache.phoenix.end2end.SpooledSortMergeJoinIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 33.982 sec - in 
org.apache.phoenix.end2end.SkipScanAfterManualSplitIT
Running org.apache.phoenix.end2end.SpooledTmpFileDeleteIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.639 sec - in 
org.apache.phoenix.end2end.SpooledTmpFileDeleteIT
Running org.apache.phoenix.end2end.SqrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.08 sec - in 
org.apache.phoenix.end2end.SqrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.StatementHintsIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.167 sec - in 
org.apache.phoenix.end2end.StatementHintsIT
Running org.apache.phoenix.end2end.StddevIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.778 sec - in 
org.apache.phoenix.end2end.StddevIT
Running org.apache.phoenix.end2end.StoreNullsIT
Tests run: 96, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 170.173 sec - 
in org.apache.phoenix.end2end.HashJoinIT
Running org.apache.phoenix.end2end.StringIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.505 sec - in 
org.apache.phoenix.end2end.StoreNullsIT
Running org.apache.phoenix.end2end.StringToArrayFunctionIT
Tests run: 45, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 50.473 sec - 
in org.apache.phoenix.end2end.SortOrderIT
Running org.apache.phoenix.end2end.SubqueryIT
Tests run: 13, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.272 sec - 
in org.apache.phoenix.end2end.StringIT
Running org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT
Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.861 sec - 
in org.apache.phoenix.end2end.StringToArrayFunctionIT
Running org.apache.phoenix.end2end.TenantIdTypeIT
Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 55.867 sec - 
in org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT
Running org.apache.phoenix.end2end.TenantSpecificViewIndexIT
Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.517 sec - in 
org.apache.phoenix.end2end.TenantSpecificViewIndexIT
Running org.apache.phoenix.end2end.TenantSpecificViewIndexSaltedIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 83.718 sec - 
in org.apache.phoenix.end2end.SubqueryIT
Running org.apache.phoenix.end2end.TimezoneOffsetFunctionIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.941 sec - in 
org.apache.phoenix.end2end.TenantSpecificViewIndexSaltedIT
Running 

phoenix git commit: PHOENIX-2817 Phoenix-Spark plugin doesn't work in secured env(Sergey Soldatov)

[ankit]

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 cede5a991 -> 8cf6457bb


PHOENIX-2817 Phoenix-Spark plugin doesn't work in secured env(Sergey Soldatov)


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

Branch: refs/heads/4.x-HBase-1.0
Commit: 8cf6457bbc252fc78a55af2b7761a91d69e2239c
Parents: cede5a9
Author: Ankit Singhal 
Authored: Wed Apr 6 12:10:01 2016 +0530
Committer: Ankit Singhal 
Committed: Wed Apr 6 12:10:01 2016 +0530

--
 .../apache/phoenix/spark/PhoenixSparkIT.scala   |  7 +
 .../phoenix/spark/ConfigurationUtil.scala   | 27 
 .../org/apache/phoenix/spark/PhoenixRDD.scala   | 13 +-
 3 files changed, 30 insertions(+), 17 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/8cf6457b/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 08c123a..ad4791d 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
@@ -53,16 +53,11 @@ class PhoenixSparkIT extends FunSuite with Matchers with 
BeforeAndAfterAll {
 
   lazy val hbaseConfiguration = {
 val conf = PhoenixSparkITHelper.getTestClusterConfig
-// The zookeeper quorum address defaults to "localhost" which is 
incorrect, let's fix it
-val quorum = conf.get("hbase.zookeeper.quorum")
-val clientPort = conf.get("hbase.zookeeper.property.clientPort")
-val znodeParent = conf.get("zookeeper.znode.parent")
-conf.set(HConstants.ZOOKEEPER_QUORUM, s"$quorum:$clientPort:$znodeParent")
 conf
   }
 
   lazy val quorumAddress = {
-hbaseConfiguration.get(HConstants.ZOOKEEPER_QUORUM)
+ConfigurationUtil.getZookeeperURL(hbaseConfiguration).get
   }
 
   override def beforeAll() {

http://git-wip-us.apache.org/repos/asf/phoenix/blob/8cf6457b/phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala
--
diff --git 
a/phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala 
b/phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala
index 2f306f0..2f4311f 100644
--- 
a/phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala
+++ 
b/phoenix-spark/src/main/scala/org/apache/phoenix/spark/ConfigurationUtil.scala
@@ -15,6 +15,7 @@ package org.apache.phoenix.spark
 
 import org.apache.hadoop.conf.Configuration
 import org.apache.hadoop.hbase.{HBaseConfiguration, HConstants}
+import org.apache.phoenix.jdbc.PhoenixEmbeddedDriver
 import org.apache.phoenix.mapreduce.util.{ColumnInfoToStringEncoderDecoder, 
PhoenixConfigurationUtil}
 import org.apache.phoenix.util.ColumnInfo
 import scala.collection.JavaConversions._
@@ -38,20 +39,29 @@ object ConfigurationUtil extends Serializable {
 
 // Override the Zookeeper URL if present. Throw exception if no address 
given.
 zkUrl match {
-  case Some(url) => config.set(HConstants.ZOOKEEPER_QUORUM, url )
+  case Some(url) => setZookeeperURL(config, url)
   case _ => {
-if(config.get(HConstants.ZOOKEEPER_QUORUM) == null) {
+if (ConfigurationUtil.getZookeeperURL(config).isEmpty) {
   throw new UnsupportedOperationException(
 s"One of zkUrl or '${HConstants.ZOOKEEPER_QUORUM}' config property 
must be provided"
   )
 }
   }
 }
-
 // Return the configuration object
 config
   }
 
+  def setZookeeperURL(conf: Configuration, zkUrl: String) = {
+val info = PhoenixEmbeddedDriver.ConnectionInfo.create(zkUrl)
+conf.set(HConstants.ZOOKEEPER_QUORUM, info.getZookeeperQuorum)
+if (info.getPort != null)
+  conf.setInt(HConstants.ZOOKEEPER_CLIENT_PORT, info.getPort)
+if (info.getRootNode != null)
+  conf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, info.getRootNode)
+
+  }
+
   // Return a serializable representation of the columns
   def encodeColumns(conf: Configuration) = {
 ColumnInfoToStringEncoderDecoder.encode(conf, 
PhoenixConfigurationUtil.getUpsertColumnMetadataList(conf)
@@ -62,8 +72,15 @@ object ConfigurationUtil extends Serializable {
   def decodeColumns(conf: Configuration): List[ColumnInfo] = {
 ColumnInfoToStringEncoderDecoder.decode(conf).toList
   }
-  
+
   def getZookeeperURL(conf: Configuration): Option[String] 

Build failed in Jenkins: Phoenix | Master #1184

[Apache Jenkins Server]

See 

Changes:

[ankitsinghal59] PHOENIX-2817 Phoenix-Spark plugin doesn't work in secured 
env(Sergey

--
[...truncated 229 lines...]
Running org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.01 sec - in 
org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest
Running org.apache.phoenix.index.IndexMaintainerTest
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.116 sec - in 
org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtilTest
Running org.apache.phoenix.iterate.AggregateResultScannerTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.364 sec - in 
org.apache.phoenix.iterate.AggregateResultScannerTest
Running org.apache.phoenix.iterate.ConcatResultIteratorTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.005 sec - in 
org.apache.phoenix.iterate.ConcatResultIteratorTest
Running org.apache.phoenix.iterate.SpoolingResultIteratorTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.022 sec - in 
org.apache.phoenix.iterate.SpoolingResultIteratorTest
Running org.apache.phoenix.iterate.MergeSortResultIteratorTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec - in 
org.apache.phoenix.iterate.MergeSortResultIteratorTest
Running org.apache.phoenix.memory.MemoryManagerTest
Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.962 sec - in 
org.apache.phoenix.index.IndexMaintainerTest
Running org.apache.phoenix.filter.SkipScanBigFilterTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.376 sec - in 
org.apache.phoenix.filter.SkipScanBigFilterTest
Running org.apache.phoenix.filter.SkipScanFilterIntersectTest
Tests run: 19, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.024 sec - in 
org.apache.phoenix.filter.SkipScanFilterIntersectTest
Running org.apache.phoenix.filter.SkipScanFilterTest
Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.031 sec - in 
org.apache.phoenix.filter.SkipScanFilterTest
Running org.apache.phoenix.util.LikeExpressionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in 
org.apache.phoenix.util.LikeExpressionTest
Running org.apache.phoenix.util.PropertiesUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.022 sec - in 
org.apache.phoenix.util.PropertiesUtilTest
Running org.apache.phoenix.util.PhoenixEncodeDecodeTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.155 sec - in 
org.apache.phoenix.util.PhoenixEncodeDecodeTest
Running org.apache.phoenix.util.SequenceUtilTest
Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.011 sec - in 
org.apache.phoenix.util.SequenceUtilTest
Running org.apache.phoenix.util.MetaDataUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec - in 
org.apache.phoenix.util.MetaDataUtilTest
Running org.apache.phoenix.util.LogUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.052 sec - in 
org.apache.phoenix.util.LogUtilTest
Running org.apache.phoenix.util.DateUtilTest
Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec - in 
org.apache.phoenix.util.DateUtilTest
Running org.apache.phoenix.util.ByteUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.054 sec - in 
org.apache.phoenix.util.ByteUtilTest
Running org.apache.phoenix.util.csv.CsvUpsertExecutorTest
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.202 sec - in 
org.apache.phoenix.util.csv.CsvUpsertExecutorTest
Running org.apache.phoenix.util.csv.StringToArrayConverterTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.189 sec - in 
org.apache.phoenix.util.csv.StringToArrayConverterTest
Running org.apache.phoenix.util.Base62EncoderTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.013 sec - in 
org.apache.phoenix.util.Base62EncoderTest
Running org.apache.phoenix.util.TenantIdByteConversionTest
Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.015 sec - in 
org.apache.phoenix.util.TenantIdByteConversionTest
Running org.apache.phoenix.util.ColumnInfoTest
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.004 sec - in 
org.apache.phoenix.util.ColumnInfoTest
Running org.apache.phoenix.util.IndexUtilTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002 sec - in 
org.apache.phoenix.util.IndexUtilTest
Running org.apache.phoenix.util.StringUtilTest
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002 sec - in 
org.apache.phoenix.util.StringUtilTest
Running org.apache.phoenix.util.PrefixByteEncoderDecoderTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002 sec - in 
org.apache.phoenix.util.PrefixByteEncoderDecoderTest
Running org.apache.phoenix.util.PhoenixContextExecutorTest