浏览代码

Do not fail silentely on TTransportExceptions

Let's add a debug statement with the exception to help debug
client-server connection issues (e.g., timeout definition).

Testing done: Ran a client with a short timeout saw the statement in the
log of the jobtracker.

Signed-off-by: bc Wong <bcwalrus@cloudera.com>
Gilad Wolff 13 年之前
父节点
当前提交
d3dda42

+ 1 - 1
desktop/libs/hadoop/java/src/main/java/org/apache/hadoop/thriftfs/SanerThreadPoolServer.java

@@ -282,7 +282,7 @@ public class SanerThreadPoolServer extends TServer {
         // down. this is necessary for graceful shutdown.
         while (!stopped_ && processor.process(inputProtocol, outputProtocol)) {}
       } catch (TTransportException ttx) {
-        // Assume the client died and continue silently
+        LOGGER.debug("Received transport exception. Assuming client went away.", ttx);
       } catch (TException tx) {
         LOGGER.error("Thrift error occurred during processing of message.", tx);
       } catch (Exception x) {