tajo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jh...@apache.org
Subject git commit: TAJO-821: IllegalStateException occurs when a NettyClientBase object is created within single thread. (hyoungjunkim via jinho)
Date Tue, 20 May 2014 05:38:47 GMT
Repository: tajo
Updated Branches:
  refs/heads/master 4a747a0f8 -> d0528d1bc


TAJO-821: IllegalStateException occurs when a NettyClientBase object is created within single
thread. (hyoungjunkim via jinho)


Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/d0528d1b
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/d0528d1b
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/d0528d1b

Branch: refs/heads/master
Commit: d0528d1bcb5b57b2287fd435701234cd226e8ac2
Parents: 4a747a0
Author: jinossy <jinossy@gmail.com>
Authored: Tue May 20 14:38:16 2014 +0900
Committer: jinossy <jinossy@gmail.com>
Committed: Tue May 20 14:38:16 2014 +0900

----------------------------------------------------------------------
 CHANGES                                                         | 3 +++
 tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java | 1 -
 2 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tajo/blob/d0528d1b/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index 41ac271..97d6c9c 100644
--- a/CHANGES
+++ b/CHANGES
@@ -41,6 +41,9 @@ Release 0.9.0 - unreleased
 
   BUG FIXES
 
+    TAJO-821: IllegalStateException occurs when a NettyClientBase object is created 
+    within single thread. (hyoungjunkim via jinho)
+
     TAJO-816: NULL delimiter doesn't apply with HCatalogStore. (jaehwa)
 
     TAJO-823: Missing INET4 handling in DatumFactory.cast(). (jihoon)

http://git-wip-us.apache.org/repos/asf/tajo/blob/d0528d1b/tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java b/tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
index fe41267..711c527 100644
--- a/tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
+++ b/tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
@@ -74,7 +74,6 @@ public abstract class NettyClientBase implements Closeable {
        addr = NetUtils.createSocketAddr(addr.getHostName(), addr.getPort());
     }
     this.channelFuture = bootstrap.connect(addr);
-    this.channelFuture.awaitUninterruptibly();
 
     final CountDownLatch latch = new CountDownLatch(1);
     this.channelFuture.addListener(new ChannelFutureListener() {


Mime
View raw message