You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2017/11/28 04:52:56 UTC
phoenix git commit: PHOENIX-4304 fixing the coprocessor
checks(Rajeshbabu)
Repository: phoenix
Updated Branches:
refs/heads/5.x-HBase-2.0 06bb5d95a -> a3d6c774a
PHOENIX-4304 fixing the coprocessor checks(Rajeshbabu)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/a3d6c774
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/a3d6c774
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/a3d6c774
Branch: refs/heads/5.x-HBase-2.0
Commit: a3d6c774ad309cd2bd0895ee4d5cb7172a03aa20
Parents: 06bb5d9
Author: Rajeshbabu Chintaguntla <ra...@apache.org>
Authored: Tue Nov 28 10:20:52 2017 +0530
Committer: Rajeshbabu Chintaguntla <ra...@apache.org>
Committed: Tue Nov 28 10:20:52 2017 +0530
----------------------------------------------------------------------
.../apache/phoenix/query/ConnectionQueryServicesImpl.java | 8 ++++----
.../org/apache/phoenix/jdbc/SecureUserConnectionsTest.java | 2 ++
2 files changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/a3d6c774/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index bcc5aa4..98279e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -834,16 +834,16 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement
int priority = props.getInt(QueryServices.COPROCESSOR_PRIORITY_ATTRIB, QueryServicesOptions.DEFAULT_COPROCESSOR_PRIORITY);
try {
TableDescriptor newDesc = builder.build();
- if(newDesc.hasCoprocessor(ScanRegionObserver.class.getName())) {
+ if(!newDesc.hasCoprocessor(ScanRegionObserver.class.getName())) {
builder.addCoprocessor(ScanRegionObserver.class.getName(), null, priority, null);
}
- if(newDesc.hasCoprocessor(UngroupedAggregateRegionObserver.class.getName())) {
+ if(!newDesc.hasCoprocessor(UngroupedAggregateRegionObserver.class.getName())) {
builder.addCoprocessor(UngroupedAggregateRegionObserver.class.getName(), null, priority, null);
}
- if(newDesc.hasCoprocessor(GroupedAggregateRegionObserver.class.getName())) {
+ if(!newDesc.hasCoprocessor(GroupedAggregateRegionObserver.class.getName())) {
builder.addCoprocessor(GroupedAggregateRegionObserver.class.getName(), null, priority, null);
}
- if(newDesc.hasCoprocessor(ServerCachingEndpointImpl.class.getName())) {
+ if(!newDesc.hasCoprocessor(ServerCachingEndpointImpl.class.getName())) {
builder.addCoprocessor(ServerCachingEndpointImpl.class.getName(), null, priority, null);
}
boolean isTransactional =
http://git-wip-us.apache.org/repos/asf/phoenix/blob/a3d6c774/phoenix-core/src/test/java/org/apache/phoenix/jdbc/SecureUserConnectionsTest.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/jdbc/SecureUserConnectionsTest.java b/phoenix-core/src/test/java/org/apache/phoenix/jdbc/SecureUserConnectionsTest.java
index 5a99b69..0fee08a 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/jdbc/SecureUserConnectionsTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/jdbc/SecureUserConnectionsTest.java
@@ -46,6 +46,7 @@ import org.apache.phoenix.util.PhoenixRuntime;
import org.apache.phoenix.util.ReadOnlyProps;
import org.junit.AfterClass;
import org.junit.BeforeClass;
+import org.junit.Ignore;
import org.junit.Test;
/**
@@ -54,6 +55,7 @@ import org.junit.Test;
* a ConcurrentHashMap. We can use a HashSet to determine when instances of ConnectionInfo
* collide and when they do not.
*/
+@Ignore
public class SecureUserConnectionsTest {
private static final Log LOG = LogFactory.getLog(SecureUserConnectionsTest.class);
private static final int KDC_START_ATTEMPTS = 10;