Details
Description
Pair<String,TTransport> getAnyTransport(List<ThriftTransportKey> servers, boolean preferCachedConnection) throws TTransportException { .... if (!preferCachedConnection) { synchronized (this) { List<CachedConnection> cachedConnList = getCache().get(ttk); if (cachedConnList != null) { for (CachedConnection cachedConnection : cachedConnList) { if (!cachedConnection.isReserved()) { cachedConnection.setReserved(true); final String serverAddr = ttk.getServer().toString(); log.trace("Using existing connection to {} timeout {}", serverAddr, ttk.getTimeout()); return new Pair<String,TTransport>(serverAddr, cachedConnection.transport); } } } } }
It appears that ThriftTransportPool.getAnyTransport is returning a cache connection when the caller requested that a new connection is returned instead of a cached one.
Attachments
Issue Links
- is broken by
-
ACCUMULO-422 Bulk import failing when tablet server dies
- Resolved