Details

      Description

      Currently, RPC does not handle error for disconnection and a client does not throw if async RPC failed.
      for example. when a client calling and then it has lost a connection, callback has not been called.
      Callfuture.get() should throw ExecutionException and RPC client should handle a recoverable exception

      • Server internal exception handling
        • Application exceptions
          • send RemoteCallException to client
        • Unexpected exceptions (Server failure)
          • close current channel (client will receive channel inactive event)
      • Client internal exception handling
        • Add internal retry when a stub is failed by connection lost
        • Application exceptions
          • throw exception to callback
        • Max retry exceeded
          • throw RecoverableException to internal exception handler
        • Server hangs(server shutdown, OOM..)
          • trigger the ping expired event. and throw ServiceException
        • Unexpected exceptions (Client failure, connection lost)
          • throw exception to all callback
      1. TAJO-1563_2.patch
        149 kB
        Jinho Kim
      2. TAJO-1563_3.patch
        152 kB
        Jinho Kim
      3. TAJO-1563_4.patch
        152 kB
        Jinho Kim
      4. TAJO-1563.patch
        146 kB
        Jinho Kim

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user jinossy opened a pull request:

          https://github.com/apache/tajo/pull/554

          TAJO-1563: Add disconnected network handling in RPC

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/jinossy/tajo TAJO-1563

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/tajo/pull/554.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #554


          commit b7b45ea3a8fa67cb2f12915f9ee3d543440c9430
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-21T14:12:27Z

          TAJO-1563

          commit 19d1516de620e901b15a315ecb31e44d567a767f
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-22T03:29:35Z

          add connection retry in rpc client

          commit 035e45a57b1adbe7d2fb374a6a9de23d3e2e9891
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-22T03:30:30Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1563

          commit b19680e806b79298e0a33f1c371a71606b5c8e2c
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-23T06:58:42Z

          cleanup codes and add comments

          commit 7b76c9dbdeb2215ab69e7df58c61f9657fc7ac4f
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-23T07:05:45Z

          fix compilation error

          commit d4c47d1ce3ff5b333317a84498e22df4df34ce36
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-23T08:58:31Z

          fix infinite loop of async future

          commit 43d7df7046e787b1bf3d1e453132fd40dbdb3144
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-23T11:33:45Z

          fix worker heartbeat when tajo startup

          commit b9a0035541b26e01c0e57ab7777e24533b655c04
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-23T16:59:07Z

          add more test case

          commit d9d9de6a2297b4fa686eea8037227944f97b3aad
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-24T07:43:39Z

          cleanup the duplicate codes

          commit d43fb24363a83b728c853cb04e00446e85c7c138
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-24T07:44:14Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1563

          commit 630fed62adadc6809ba2774ab8afebff8e3503f2
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-24T07:49:35Z

          remove atomicUpdater

          commit 24f5c90e5a5a4eda916158d7bcd68a5010f477ac
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-24T07:58:49Z

          fix missing sequence id

          commit b7722989c06920d896d33d893da2ac61cbb31ad2
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-04-24T09:51:03Z

          add default configs


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user jinossy opened a pull request: https://github.com/apache/tajo/pull/554 TAJO-1563 : Add disconnected network handling in RPC You can merge this pull request into a Git repository by running: $ git pull https://github.com/jinossy/tajo TAJO-1563 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/tajo/pull/554.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #554 commit b7b45ea3a8fa67cb2f12915f9ee3d543440c9430 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-21T14:12:27Z TAJO-1563 commit 19d1516de620e901b15a315ecb31e44d567a767f Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-22T03:29:35Z add connection retry in rpc client commit 035e45a57b1adbe7d2fb374a6a9de23d3e2e9891 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-22T03:30:30Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1563 commit b19680e806b79298e0a33f1c371a71606b5c8e2c Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-23T06:58:42Z cleanup codes and add comments commit 7b76c9dbdeb2215ab69e7df58c61f9657fc7ac4f Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-23T07:05:45Z fix compilation error commit d4c47d1ce3ff5b333317a84498e22df4df34ce36 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-23T08:58:31Z fix infinite loop of async future commit 43d7df7046e787b1bf3d1e453132fd40dbdb3144 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-23T11:33:45Z fix worker heartbeat when tajo startup commit b9a0035541b26e01c0e57ab7777e24533b655c04 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-23T16:59:07Z add more test case commit d9d9de6a2297b4fa686eea8037227944f97b3aad Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-24T07:43:39Z cleanup the duplicate codes commit d43fb24363a83b728c853cb04e00446e85c7c138 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-24T07:44:14Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1563 commit 630fed62adadc6809ba2774ab8afebff8e3503f2 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-24T07:49:35Z remove atomicUpdater commit 24f5c90e5a5a4eda916158d7bcd68a5010f477ac Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-24T07:58:49Z fix missing sequence id commit b7722989c06920d896d33d893da2ac61cbb31ad2 Author: Jinho Kim <jhkim@apache.org> Date: 2015-04-24T09:51:03Z add default configs
          Hide
          tajoqa Tajo QA added a comment -

          -1 overall. Here are the results of testing the latest attachment
          http://issues.apache.org/jira/secure/attachment/12728315/TAJO-1563.patch
          against master revision release-0.9.0-rc0-273-g50ac828.

          +1 @author. The patch does not contain any @author tags.

          +1 tests included. The patch appears to include 6 new or modified test files.

          +1 javac. The applied patch does not increase the total number of javac compiler warnings.

          +1 javadoc. The applied patch does not increase the total number of javadoc warnings.

          +1 checkstyle. The patch generated 0 code style errors.

          -1 findbugs. The patch appears to introduce 20 new Findbugs (version 2.0.3) warnings.

          +1 release audit. The applied patch does not increase the total number of release audit warnings.

          +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf.

          Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/759//testReport/
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/759//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/759//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html
          Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/759//console

          This message is automatically generated.

          Show
          tajoqa Tajo QA added a comment - -1 overall. Here are the results of testing the latest attachment http://issues.apache.org/jira/secure/attachment/12728315/TAJO-1563.patch against master revision release-0.9.0-rc0-273-g50ac828. +1 @author. The patch does not contain any @author tags. +1 tests included. The patch appears to include 6 new or modified test files. +1 javac. The applied patch does not increase the total number of javac compiler warnings. +1 javadoc. The applied patch does not increase the total number of javadoc warnings. +1 checkstyle. The patch generated 0 code style errors. -1 findbugs. The patch appears to introduce 20 new Findbugs (version 2.0.3) warnings. +1 release audit. The applied patch does not increase the total number of release audit warnings. +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf. Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/759//testReport/ Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/759//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/759//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/759//console This message is automatically generated.
          Hide
          tajoqa Tajo QA added a comment -

          -1 overall. Here are the results of testing the latest attachment
          http://issues.apache.org/jira/secure/attachment/12728321/TAJO-1563_2.patch
          against master revision release-0.9.0-rc0-274-g9acb3a6.

          +1 @author. The patch does not contain any @author tags.

          +1 tests included. The patch appears to include 6 new or modified test files.

          +1 javac. The applied patch does not increase the total number of javac compiler warnings.

          +1 javadoc. The applied patch does not increase the total number of javadoc warnings.

          +1 checkstyle. The patch generated 0 code style errors.

          -1 findbugs. The patch appears to introduce 19 new Findbugs (version 2.0.3) warnings.

          +1 release audit. The applied patch does not increase the total number of release audit warnings.

          +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf.

          Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/760//testReport/
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/760//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/760//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html
          Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/760//console

          This message is automatically generated.

          Show
          tajoqa Tajo QA added a comment - -1 overall. Here are the results of testing the latest attachment http://issues.apache.org/jira/secure/attachment/12728321/TAJO-1563_2.patch against master revision release-0.9.0-rc0-274-g9acb3a6. +1 @author. The patch does not contain any @author tags. +1 tests included. The patch appears to include 6 new or modified test files. +1 javac. The applied patch does not increase the total number of javac compiler warnings. +1 javadoc. The applied patch does not increase the total number of javadoc warnings. +1 checkstyle. The patch generated 0 code style errors. -1 findbugs. The patch appears to introduce 19 new Findbugs (version 2.0.3) warnings. +1 release audit. The applied patch does not increase the total number of release audit warnings. +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf. Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/760//testReport/ Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/760//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/760//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/760//console This message is automatically generated.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on the pull request:

          https://github.com/apache/tajo/pull/554#issuecomment-96581039

          I’ve test of two failure case. It can resolve by TAJO-1215 and task re-assign

          • Node shutdown during query running
          • Node shutdown before query start
          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on the pull request: https://github.com/apache/tajo/pull/554#issuecomment-96581039 I’ve test of two failure case. It can resolve by TAJO-1215 and task re-assign Node shutdown during query running Node shutdown before query start
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on the pull request:

          https://github.com/apache/tajo/pull/554#issuecomment-96584216

          Thanks for your contribution.
          If you fix bugs according to FindBugs report, it would more nice patch.

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on the pull request: https://github.com/apache/tajo/pull/554#issuecomment-96584216 Thanks for your contribution. If you fix bugs according to FindBugs report, it would more nice patch.
          Hide
          jhkim Jinho Kim added a comment -

          remove findbug warnings

          Show
          jhkim Jinho Kim added a comment - remove findbug warnings
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on the pull request:

          https://github.com/apache/tajo/pull/554#issuecomment-96602318

          I've remove findbug warnings
          Thanks

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on the pull request: https://github.com/apache/tajo/pull/554#issuecomment-96602318 I've remove findbug warnings Thanks
          Hide
          tajoqa Tajo QA added a comment -

          -1 overall. Here are the results of testing the latest attachment
          http://issues.apache.org/jira/secure/attachment/12728373/TAJO-1563_3.patch
          against master revision release-0.9.0-rc0-275-gb50831f.

          +1 @author. The patch does not contain any @author tags.

          +1 tests included. The patch appears to include 6 new or modified test files.

          +1 javac. The applied patch does not increase the total number of javac compiler warnings.

          +1 javadoc. The applied patch does not increase the total number of javadoc warnings.

          +1 checkstyle. The patch generated 0 code style errors.

          -1 findbugs. The patch appears to introduce 2 new Findbugs (version 2.0.3) warnings.

          +1 release audit. The applied patch does not increase the total number of release audit warnings.

          +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf.

          Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/761//testReport/
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/761//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html
          Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/761//console

          This message is automatically generated.

          Show
          tajoqa Tajo QA added a comment - -1 overall. Here are the results of testing the latest attachment http://issues.apache.org/jira/secure/attachment/12728373/TAJO-1563_3.patch against master revision release-0.9.0-rc0-275-gb50831f. +1 @author. The patch does not contain any @author tags. +1 tests included. The patch appears to include 6 new or modified test files. +1 javac. The applied patch does not increase the total number of javac compiler warnings. +1 javadoc. The applied patch does not increase the total number of javadoc warnings. +1 checkstyle. The patch generated 0 code style errors. -1 findbugs. The patch appears to introduce 2 new Findbugs (version 2.0.3) warnings. +1 release audit. The applied patch does not increase the total number of release audit warnings. +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf. Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/761//testReport/ Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/761//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-rpc-protobuf.html Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/761//console This message is automatically generated.
          Hide
          jhkim Jinho Kim added a comment -

          remove warnings

          Show
          jhkim Jinho Kim added a comment - remove warnings
          Hide
          tajoqa Tajo QA added a comment -

          +1 overall. Here are the results of testing the latest attachment
          http://issues.apache.org/jira/secure/attachment/12728396/TAJO-1563_4.patch
          against master revision release-0.9.0-rc0-275-gb50831f.

          +1 @author. The patch does not contain any @author tags.

          +1 tests included. The patch appears to include 6 new or modified test files.

          +1 javac. The applied patch does not increase the total number of javac compiler warnings.

          +1 javadoc. The applied patch does not increase the total number of javadoc warnings.

          +1 checkstyle. The patch generated 0 code style errors.

          +1 findbugs. The patch does not introduce any new Findbugs (version 2.0.3) warnings.

          +1 release audit. The applied patch does not increase the total number of release audit warnings.

          +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf.

          Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/762//testReport/
          Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/762//console

          This message is automatically generated.

          Show
          tajoqa Tajo QA added a comment - +1 overall. Here are the results of testing the latest attachment http://issues.apache.org/jira/secure/attachment/12728396/TAJO-1563_4.patch against master revision release-0.9.0-rc0-275-gb50831f. +1 @author. The patch does not contain any @author tags. +1 tests included. The patch appears to include 6 new or modified test files. +1 javac. The applied patch does not increase the total number of javac compiler warnings. +1 javadoc. The applied patch does not increase the total number of javadoc warnings. +1 checkstyle. The patch generated 0 code style errors. +1 findbugs. The patch does not introduce any new Findbugs (version 2.0.3) warnings. +1 release audit. The applied patch does not increase the total number of release audit warnings. +1 core tests. The patch passed unit tests in tajo-client tajo-core tajo-rpc/tajo-rpc-common tajo-rpc/tajo-rpc-protobuf. Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/762//testReport/ Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/762//console This message is automatically generated.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29205757

          — Diff: tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java —
          @@ -87,6 +87,10 @@ public SessionConnection(ServiceTracker tracker, @Nullable String baseDatabase,
          this.properties = properties;

          this.manager = RpcClientManager.getInstance();
          + this.manager.setRetries(properties.getInt(RpcConstants.RPC_CLIENT_RETRY_MAX, RpcConstants.DEFAULT_RPC_RETRIES));
          + this.manager.setTimeoutSeconds(
          + properties.getInt(RpcConstants.RPC_CLIENT_TIMEOUT_SECS, 0)); // disable rpc timeout
          — End diff –

          Could you explain why you disabled rpc timeout?

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29205757 — Diff: tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java — @@ -87,6 +87,10 @@ public SessionConnection(ServiceTracker tracker, @Nullable String baseDatabase, this.properties = properties; this.manager = RpcClientManager.getInstance(); + this.manager.setRetries(properties.getInt(RpcConstants.RPC_CLIENT_RETRY_MAX, RpcConstants.DEFAULT_RPC_RETRIES)); + this.manager.setTimeoutSeconds( + properties.getInt(RpcConstants.RPC_CLIENT_TIMEOUT_SECS, 0)); // disable rpc timeout — End diff – Could you explain why you disabled rpc timeout?
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29206122

          — Diff: tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java —
          @@ -98,17 +98,17 @@ public void serviceInit(Configuration conf) {
          systemConf.setVar(TajoConf.ConfVars.RESOURCE_TRACKER_RPC_ADDRESS, NetUtils.normalizeInetSocketAddress(bindAddress));

          LOG.info("TajoResourceTracker starts up (" + this.bindAddress + ")");

          • super.start();
            + super.serviceInit(conf);
              • End diff –

          This is a good point.

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29206122 — Diff: tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java — @@ -98,17 +98,17 @@ public void serviceInit(Configuration conf) { systemConf.setVar(TajoConf.ConfVars.RESOURCE_TRACKER_RPC_ADDRESS, NetUtils.normalizeInetSocketAddress(bindAddress)); LOG.info("TajoResourceTracker starts up (" + this.bindAddress + ")"); super.start(); + super.serviceInit(conf); End diff – This is a good point.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29206249

          — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java —
          @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) {

          QueryCoordinatorProtocolService masterClientService = tmClient.getStub();
          masterClientService.heartbeat(future.getController(), queryHeartbeat, future);
          + future.get(10, TimeUnit.SECONDS);
          — End diff –

          Could you explain why you get 10 seconds?

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29206249 — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java — @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) { QueryCoordinatorProtocolService masterClientService = tmClient.getStub(); masterClientService.heartbeat(future.getController(), queryHeartbeat, future); + future.get(10, TimeUnit.SECONDS); — End diff – Could you explain why you get 10 seconds?
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29207462

          — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java —
          @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) {

          QueryCoordinatorProtocolService masterClientService = tmClient.getStub();
          masterClientService.heartbeat(future.getController(), queryHeartbeat, future);
          + future.get(10, TimeUnit.SECONDS);
          — End diff –

          It can handle the RPC error. Have you better idea?

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29207462 — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java — @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) { QueryCoordinatorProtocolService masterClientService = tmClient.getStub(); masterClientService.heartbeat(future.getController(), queryHeartbeat, future); + future.get(10, TimeUnit.SECONDS); — End diff – It can handle the RPC error. Have you better idea?
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29207664

          — Diff: tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java —
          @@ -87,6 +87,10 @@ public SessionConnection(ServiceTracker tracker, @Nullable String baseDatabase,
          this.properties = properties;

          this.manager = RpcClientManager.getInstance();
          + this.manager.setRetries(properties.getInt(RpcConstants.RPC_CLIENT_RETRY_MAX, RpcConstants.DEFAULT_RPC_RETRIES));
          + this.manager.setTimeoutSeconds(
          + properties.getInt(RpcConstants.RPC_CLIENT_TIMEOUT_SECS, 0)); // disable rpc timeout
          — End diff –

          IMO, It should be handled in session timeout.
          If timeout is set to properties, it will work

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29207664 — Diff: tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java — @@ -87,6 +87,10 @@ public SessionConnection(ServiceTracker tracker, @Nullable String baseDatabase, this.properties = properties; this.manager = RpcClientManager.getInstance(); + this.manager.setRetries(properties.getInt(RpcConstants.RPC_CLIENT_RETRY_MAX, RpcConstants.DEFAULT_RPC_RETRIES)); + this.manager.setTimeoutSeconds( + properties.getInt(RpcConstants.RPC_CLIENT_TIMEOUT_SECS, 0)); // disable rpc timeout — End diff – IMO, It should be handled in session timeout. If timeout is set to properties, it will work
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on the pull request:

          https://github.com/apache/tajo/pull/554#issuecomment-96975400

          +1

          Thanks for your comments.
          I also agree with your opinions.
          Ship it.

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on the pull request: https://github.com/apache/tajo/pull/554#issuecomment-96975400 +1 Thanks for your comments. I also agree with your opinions. Ship it.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user blrunner commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29224201

          — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java —
          @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) {

          QueryCoordinatorProtocolService masterClientService = tmClient.getStub();
          masterClientService.heartbeat(future.getController(), queryHeartbeat, future);
          + future.get(10, TimeUnit.SECONDS);
          — End diff –

          If you separate 10 seconds to RpcConstants, it would be better nice.

          Show
          githubbot ASF GitHub Bot added a comment - Github user blrunner commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29224201 — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java — @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) { QueryCoordinatorProtocolService masterClientService = tmClient.getStub(); masterClientService.heartbeat(future.getController(), queryHeartbeat, future); + future.get(10, TimeUnit.SECONDS); — End diff – If you separate 10 seconds to RpcConstants, it would be better nice.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on a diff in the pull request:

          https://github.com/apache/tajo/pull/554#discussion_r29224778

          — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java —
          @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) {

          QueryCoordinatorProtocolService masterClientService = tmClient.getStub();
          masterClientService.heartbeat(future.getController(), queryHeartbeat, future);
          + future.get(10, TimeUnit.SECONDS);
          — End diff –

          Sure!

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on a diff in the pull request: https://github.com/apache/tajo/pull/554#discussion_r29224778 — Diff: tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java — @@ -341,6 +339,7 @@ public void stopQuery(QueryId queryId) { QueryCoordinatorProtocolService masterClientService = tmClient.getStub(); masterClientService.heartbeat(future.getController(), queryHeartbeat, future); + future.get(10, TimeUnit.SECONDS); — End diff – Sure!
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on the pull request:

          https://github.com/apache/tajo/pull/554#issuecomment-96982498

          Thank you for your review!
          I'll commit soon

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on the pull request: https://github.com/apache/tajo/pull/554#issuecomment-96982498 Thank you for your review! I'll commit soon
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/tajo/pull/554

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/tajo/pull/554
          Hide
          jhkim Jinho Kim added a comment -

          committed it

          Show
          jhkim Jinho Kim added a comment - committed it
          Hide
          hudson Hudson added a comment -

          ABORTED: Integrated in Tajo-master-CODEGEN-build #329 (See https://builds.apache.org/job/Tajo-master-CODEGEN-build/329/)
          TAJO-1563: Improve RPC error handling. (jinho) (jhkim: rev 2e7d03dff9480ecb7a4e4ed09a5578ba618de2ae)

          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolAsyncImpl.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/CallFuture.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ConnectionCloseFutureListener.java
          • tajo-core/src/main/java/org/apache/tajo/worker/WorkerHeartbeatService.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorClientHandler.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcServer.java
          • tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ChannelEventListener.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcClient.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoDeclaration.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoServerChannelInitializer.java
          • tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcChannelFactory.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcServer.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
          • tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolBlockingImpl.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java
          • tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java
          • tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcConstants.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorStateEvent.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerConnectionInfoResponse.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoClientChannelInitializer.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerResponse.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorServerHandler.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/resources/DatabasesResource.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoResourceAllocator.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcClient.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoChannelInitializer.java
          • tajo-core/src/main/java/org/apache/tajo/master/TajoMaster.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestBlockingRpc.java
          • tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RecoverableException.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/DefaultRpcController.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/proto/TestProtocol.proto
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RpcClientManager.java
          • CHANGES
          Show
          hudson Hudson added a comment - ABORTED: Integrated in Tajo-master-CODEGEN-build #329 (See https://builds.apache.org/job/Tajo-master-CODEGEN-build/329/ ) TAJO-1563 : Improve RPC error handling. (jinho) (jhkim: rev 2e7d03dff9480ecb7a4e4ed09a5578ba618de2ae) tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolAsyncImpl.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/CallFuture.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ConnectionCloseFutureListener.java tajo-core/src/main/java/org/apache/tajo/worker/WorkerHeartbeatService.java tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorClientHandler.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcServer.java tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ChannelEventListener.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcClient.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoDeclaration.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoServerChannelInitializer.java tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcChannelFactory.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcServer.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolBlockingImpl.java tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcConstants.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorStateEvent.java tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerConnectionInfoResponse.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoClientChannelInitializer.java tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerResponse.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorServerHandler.java tajo-core/src/main/java/org/apache/tajo/ws/rs/resources/DatabasesResource.java tajo-core/src/main/java/org/apache/tajo/worker/TajoResourceAllocator.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcClient.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoChannelInitializer.java tajo-core/src/main/java/org/apache/tajo/master/TajoMaster.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestBlockingRpc.java tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RecoverableException.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/DefaultRpcController.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java tajo-rpc/tajo-rpc-protobuf/src/main/proto/TestProtocol.proto tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RpcClientManager.java CHANGES
          Hide
          hudson Hudson added a comment -

          SUCCESS: Integrated in Tajo-master-build #690 (See https://builds.apache.org/job/Tajo-master-build/690/)
          TAJO-1563: Improve RPC error handling. (jinho) (jhkim: rev 2e7d03dff9480ecb7a4e4ed09a5578ba618de2ae)

          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/WorkerHeartbeatService.java
          • tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ConnectionCloseFutureListener.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoDeclaration.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcClient.java
          • CHANGES
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcClient.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolBlockingImpl.java
          • tajo-core/src/main/java/org/apache/tajo/master/TajoMaster.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/CallFuture.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RpcClientManager.java
          • tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoClientChannelInitializer.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcServer.java
          • tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcConstants.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoChannelInitializer.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerResponse.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/DefaultRpcController.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorServerHandler.java
          • tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java
          • tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ChannelEventListener.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestBlockingRpc.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
          • tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcChannelFactory.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcServer.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorStateEvent.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorClientHandler.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoServerChannelInitializer.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoResourceAllocator.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java
          • tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolAsyncImpl.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerConnectionInfoResponse.java
          • tajo-core/src/main/java/org/apache/tajo/ws/rs/resources/DatabasesResource.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
          • tajo-rpc/tajo-rpc-protobuf/src/main/proto/TestProtocol.proto
          • tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RecoverableException.java
          Show
          hudson Hudson added a comment - SUCCESS: Integrated in Tajo-master-build #690 (See https://builds.apache.org/job/Tajo-master-build/690/ ) TAJO-1563 : Improve RPC error handling. (jinho) (jhkim: rev 2e7d03dff9480ecb7a4e4ed09a5578ba618de2ae) tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java tajo-core/src/main/java/org/apache/tajo/worker/WorkerHeartbeatService.java tajo-core/src/main/java/org/apache/tajo/querymaster/QueryMaster.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ConnectionCloseFutureListener.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoDeclaration.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcClient.java CHANGES tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcClient.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolBlockingImpl.java tajo-core/src/main/java/org/apache/tajo/master/TajoMaster.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/CallFuture.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RpcClientManager.java tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoClientChannelInitializer.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/BlockingRpcServer.java tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcConstants.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoChannelInitializer.java tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerResponse.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/DefaultRpcController.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorServerHandler.java tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java tajo-client/src/main/java/org/apache/tajo/client/SessionConnection.java tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ChannelEventListener.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestBlockingRpc.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcChannelFactory.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/AsyncRpcServer.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorStateEvent.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/MonitorClientHandler.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/ProtoServerChannelInitializer.java tajo-core/src/main/java/org/apache/tajo/worker/TajoResourceAllocator.java tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/test/impl/DummyProtocolAsyncImpl.java tajo-core/src/main/java/org/apache/tajo/ws/rs/responses/WorkerConnectionInfoResponse.java tajo-core/src/main/java/org/apache/tajo/ws/rs/resources/DatabasesResource.java tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java tajo-rpc/tajo-rpc-protobuf/src/main/proto/TestProtocol.proto tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/RecoverableException.java

            People

            • Assignee:
              jhkim Jinho Kim
              Reporter:
              jhkim Jinho Kim
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development