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/window_function Commit: d0528d1bcb5b57b2287fd435701234cd226e8ac2 Parents: 4a747a0 Author: jinossy <[email protected]> Authored: Tue May 20 14:38:16 2014 +0900 Committer: jinossy <[email protected]> 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() {
