[HBASE-21574] createConnection / getTable should not return if there's no cluster available

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 2.1.1
• Component/s: Client
• Assignee: Unassigned
• Reporter: Cosmin Lehene
• Created: 10/Dec/18 21:20
• Updated: 15/Jun/22 00:30
• Resolved: 15/Jun/22 00:30

Description

You can get a connection / table successfully with no cluster (no zk, hms, hrs) and it also says it's open (closed = false)

Connection con = ConnectionFactory.createConnection(getConfiguration());
con.getTable(TableName.valueOf(customersTable));

con = \{ConnectionImplementation@5192} "hconnection-0x32093c94"
 hostnamesCanChange = true
 pause = 100
 pauseForCQTBE = 100
 useMetaReplicas = false
 metaReplicaCallTimeoutScanInMicroSecond = 1000000
 numTries = 16
 rpcTimeout = 60000
 asyncProcess = \{AsyncProcess@5242} 
 stats = null
 closed = false
 aborted = false
 clusterStatusListener = null
 metaRegionLock = \{Object@5249} 
 masterLock = \{Object@5250} 
 batchPool = \{ThreadPoolExecutor@5240} "java.util.concurrent.ThreadPoolExecutor@5bb40116[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]"
 metaLookupPool = null
 cleanupPool = true
 conf = \{Configuration@5238} "Configuration: core-default.xml, core-site.xml, hbase-default.xml, hbase-site.xml"
 connectionConfig = \{ConnectionConfiguration@5239} 
 rpcClient = \{NettyRpcClient@5251} 
 metaCache = \{MetaCache@5252} 
 metrics = null
 user = \{User$SecureHadoopUser@5253} "clehene (auth:SIMPLE)"
 rpcCallerFactory = \{RpcRetryingCallerFactory@5243} 
 rpcControllerFactory = \{RpcControllerFactory@5244} 
 interceptor = \{NoOpRetryableCallerInterceptor@5254} "NoOpRetryableCallerInterceptor"
 registry = \{ZKAsyncRegistry@5255} 
 backoffPolicy = \{ClientBackoffPolicyFactory$NoBackoffPolicy@5256} 
 alternateBufferedMutatorClassName = null
 userRegionLock = \{ReentrantLock@5257} "java.util.concurrent.locks.ReentrantLock@4d368ebc[Unlocked]"
 clusterId = "default-cluster"
 stubs = \{ConcurrentHashMap@5259} size = 0
 masterServiceState = \{ConnectionImplementation$MasterServiceState@5260} "MasterService"
table = \{HTable@5193} "customers;hconnection-0x32093c94"
 connection = \{ConnectionImplementation@5192} "hconnection-0x32093c94"
 tableName = \{TableName@5237} "customers"
 configuration = \{Configuration@5238} "Configuration: core-default.xml, core-site.xml, hbase-default.xml, hbase-site.xml"
 connConfiguration = \{ConnectionConfiguration@5239} 
 closed = false
 scannerCaching = 2147483647
 scannerMaxResultSize = 2097152
 pool = \{ThreadPoolExecutor@5240} "java.util.concurrent.ThreadPoolExecutor@5bb40116[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]"
 operationTimeoutMs = 1200000
 rpcTimeoutMs = 60000
 readRpcTimeoutMs = 60000
 writeRpcTimeoutMs = 60000
 cleanupPoolOnClose = false
 locator = \{HRegionLocator@5241} 
 multiAp = \{AsyncProcess@5242} 
 rpcCallerFactory = \{RpcRetryingCallerFactory@5243} 
 rpcControllerFactory = \{RpcControllerFactory@5244}