[core] limit number of client threads based on op count. (brianfrankc…

…ooper#1323) Fixes brianfrankcooper#1176
wowjason · Sep 7, 2019 · 2ff658c · 2ff658c
1 parent d1ad3ec
commit 2ff658c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/java/com/yahoo/ycsb/Client.java b/core/src/main/java/com/yahoo/ycsb/Client.java
@@ -418,7 +418,10 @@ private static List<ClientThread> initDb(String dbname, Properties props, int th
           opcount = Integer.parseInt(props.getProperty(RECORD_COUNT_PROPERTY, DEFAULT_RECORD_COUNT));
         }
       }
-
+      if (threadcount > opcount){
+        threadcount = opcount;
+        System.out.println("Warning: the threadcount is bigger than recordcount, the threadcount will be recordcount!");
+      }
       for (int threadid = 0; threadid < threadcount; threadid++) {
         DB db;
         try {