diff --git a/docs/examples/java/src/main/java/com/taos/example/highvolume/ReadTask.java b/docs/examples/java/src/main/java/com/taos/example/highvolume/ReadTask.java
index 2cef5302a2f4ea937c565c7ef0f8dd551aa8e402..c43dffb51a626352d7ab8dd410e01c8426f882c4 100644
--- a/docs/examples/java/src/main/java/com/taos/example/highvolume/ReadTask.java
+++ b/docs/examples/java/src/main/java/com/taos/example/highvolume/ReadTask.java
@@ -66,7 +66,7 @@ class ReadTask {
             while (it.hasNext()) {
                 String line = it.next();
                 String tbName = line.substring(0, line.indexOf(','));
-                int writeTaskId = tbName.hashCode() % numberWriteTask;
+                int writeTaskId = Math.abs(tbName.hashCode()) % numberWriteTask;
                 writeTasks.get(writeTaskId).put(line);
             }
         } catch (InterruptedException e) {
diff --git a/docs/examples/java/src/main/java/com/taos/example/highvolume/WriteTask.java b/docs/examples/java/src/main/java/com/taos/example/highvolume/WriteTask.java
index 7fe09eec02658c627303ab7a1e56805014b49654..6a5083c69908155a4de401e5d132b60cafc0c98b 100644
--- a/docs/examples/java/src/main/java/com/taos/example/highvolume/WriteTask.java
+++ b/docs/examples/java/src/main/java/com/taos/example/highvolume/WriteTask.java
@@ -11,7 +11,6 @@ import java.util.concurrent.LinkedBlockingDeque;
 
 // ANCHOR: WriteTask
 class WriteTask {
-    // How many records will trigger writing before queue
     final static int maxBatchSize = 500;
     //
     final static int taskQueueCapacity = 1000;
@@ -36,7 +35,7 @@ class WriteTask {
     }
 
     private static Connection getConnection() throws SQLException {
-        String jdbcUrl = "jdbc:TAOS-RS://localhost:6041?user=root&password=taosdata";
+        String jdbcUrl = "jdbc:TAOS://localhost:6030?user=root&password=taosdata";
         return DriverManager.getConnection(jdbcUrl);
     }