Merge remote-tracking branch 'origin/release130' into release130

Author: lucaijun

src/com/xxdb/data/BasicArrayVector.java

@@ -340,7 +340,7 @@ public void Append(Vector value) throws Exception{
 			int indexCount = rowIndicesSize;
 			int prev = indexCount == 0? 0 : rowIndices[indexCount - 1];
 			if (rowIndicesSize + 1 > capacity){
-				rowIndices = Arrays.copyOf(rowIndices, rowIndices.length * 2);
+				rowIndices = Arrays.copyOf(rowIndices, Math.max(2, rowIndices.length * 2));
 				capacity = rowIndices.length;
 			}
 			if (value.rows() != 0){

src/com/xxdb/multithreadedtablewriter/MultithreadedTableWriter.java

@@ -357,6 +357,7 @@ public MultithreadedTableWriter(String hostName, int port, String userId, String
         init(hostName,port,userId, password,dbName, tableName, useSSL,enableHighAvailability,highAvailabilitySites,
                 batchSize, throttle,threadCount,partitionCol,compressTypes, Mode.M_Append, null, callbackHandler);
     }
+
     private void init(String hostName, int port, String userId, String password,
                       String dbName, String tableName, boolean useSSL,
                       boolean enableHighAvailability, String[] highAvailabilitySites,

src/com/xxdb/streaming/client/PollingClient.java

@@ -19,6 +19,10 @@ public class PollingClient extends AbstractClient {
     TopicPoller topicPoller = null;
     private HashMap<List<String>, List<String>> users = new HashMap<>();
 
+    public PollingClient() throws SocketException {
+        super(0);
+    }
+
     public PollingClient(int subscribePort) throws SocketException {
         super(subscribePort);
     }

src/com/xxdb/streaming/client/ThreadPooledClient.java

@@ -37,6 +37,10 @@ public ThreadPooledClient() throws SocketException {
         this("", DEFAULT_PORT, CORES);
     }
 
+    public ThreadPooledClient(int threadCount) throws SocketException {
+        this("", 0, threadCount);
+    }
+
     public ThreadPooledClient(int subscribePort, int threadCount) throws SocketException {
         this("", subscribePort, threadCount);
     }