show the host and port when failing to connect
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/cd7b05ff Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/cd7b05ff Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/cd7b05ff Branch: refs/heads/cassandra-2.0 Commit: cd7b05ffb6d2859eb4fbb9567d1fe38af3f39d27 Parents: 3d58c5a Author: Brandon Williams <[email protected]> Authored: Tue Nov 5 13:40:50 2013 -0600 Committer: Brandon Williams <[email protected]> Committed: Tue Nov 5 13:40:50 2013 -0600 ---------------------------------------------------------------------- .../cassandra/hadoop/AbstractColumnFamilyInputFormat.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/cd7b05ff/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java index 16d03f9..8fd66ab 100644 --- a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java @@ -55,6 +55,7 @@ import org.apache.thrift.TException; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TTransport; +import org.apache.thrift.transport.TTransportException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -92,7 +93,12 @@ public abstract class AbstractColumnFamilyInputFormat<K, Y> extends InputFormat< public static Cassandra.Client createAuthenticatedClient(String location, int port, Configuration conf) throws Exception { logger.debug("Creating authenticated client for CF input format"); - TTransport transport = ConfigHelper.getClientTransportFactory(conf).openTransport(location, port, conf); + TTransport transport; + try { + transport = ConfigHelper.getClientTransportFactory(conf).openTransport(location, port, conf); + } catch (Exception e) { + throw new TTransportException("Failed to open a transport to " + location + ":" + port + ".", e); + } TProtocol binaryProtocol = new TBinaryProtocol(transport, true, true); Cassandra.Client client = new Cassandra.Client(binaryProtocol);
