cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [2/6] git commit: show the host and port when failing to connect
Date Tue, 05 Nov 2013 19:43:45 GMT
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 <brandonwilliams@apache.org>
Authored: Tue Nov 5 13:40:50 2013 -0600
Committer: Brandon Williams <brandonwilliams@apache.org>
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);
 


Mime
View raw message