[incubator-iotdb] branch disable_mqtt_server updated: try to avoid hive-exec impact

[hx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hxd pushed a commit to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/disable_mqtt_server by this push:
     new 1aa4b43  try to avoid hive-exec impact
1aa4b43 is described below

commit 1aa4b4353da0b9b998488015ec83d752ed78ba15
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Apr 16 16:33:23 2020 +0800

    try to avoid hive-exec impact
---
 .travis.yml                                                      | 2 +-
 server/src/main/java/org/apache/iotdb/db/service/RPCService.java | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/.travis.yml b/.travis.yml
index 35616ee..2524fea 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -174,7 +174,7 @@ script:
     - mvn -B apache-rat:check
     # Output something every 10 minutes or Travis kills the job
     - while sleep 540; do echo "=====[ $SECONDS seconds still running ]====="; done &
-    - mvn -B clean test integration-test -pl '!site' -am
+    - mvn -B clean test integration-test -pl '!site','!hive-connector' -am
     # Killing background sleep loop
     - kill %1
 
diff --git a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
index 89bfa33..8983bda 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
@@ -198,13 +198,14 @@ public class RPCService implements RPCServiceMBean, IService {
     @SuppressWarnings("squid:S2093") // socket will be used later
     @Override
     public void run() {
+      logger.info("The RPC service thread begin to run...");
       try {
         IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
         serverTransport = new TServerSocket(new InetSocketAddress(config.getRpcAddress(),
             config.getRpcPort()));
         //this is for testing.
         if (!serverTransport.getServerSocket().isBound()) {
-          logger.error("The RPC service port is not binded.");
+          logger.error("The RPC service port is not bound.");
         }
         poolArgs = new Args(serverTransport).maxWorkerThreads(IoTDBDescriptor.
             getInstance().getConfig().getRpcMaxConcurrentClientNum()).minWorkerThreads(1)