You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by jh...@apache.org on 2014/05/20 07:38:47 UTC
git commit: TAJO-821: IllegalStateException occurs when a
NettyClientBase object is created within single thread. (hyoungjunkim via
jinho)
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 <ji...@gmail.com>
Authored: Tue May 20 14:38:16 2014 +0900
Committer: jinossy <ji...@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() {