diff --git a/README.md b/README.md index a890ed8be..533150936 100644 --- a/README.md +++ b/README.md @@ -48,7 +48,7 @@ Running Pravega benchmark tool locally: usage: pravega-benchmark -consumers Number of consumers -controller Controller URI - -enableConnectionPooling Set to false to disable connection + -enableConnectionPooling Set to true to enable connection pooling -events Number of events/records if 'time' not specified; diff --git a/src/main/java/io/pravega/perf/PravegaPerfTest.java b/src/main/java/io/pravega/perf/PravegaPerfTest.java index 779935aa2..7ee1db517 100644 --- a/src/main/java/io/pravega/perf/PravegaPerfTest.java +++ b/src/main/java/io/pravega/perf/PravegaPerfTest.java @@ -89,7 +89,7 @@ public static void main(String[] args) { options.addOption("readcsv", true, "CSV file to record read latencies"); options.addOption("writethroughputcsv", true, "CSV file to record write throughput"); options.addOption("readthroughputcsv", true, "CSV file to record read throughput"); - options.addOption("enableConnectionPooling", true, "Set to false to disable connection pooling"); + options.addOption("enableConnectionPooling", false, "Set to true to enable connection pooling"); options.addOption("writeWatermarkPeriodMillis", true, "If -1 (default), watermarks will not be written.\n" + "If 0 and not using transactions, watermarks will be written after every event.\n" + @@ -295,7 +295,7 @@ static private abstract class Test { reportingInterval = DEFAULT_REPORTING_INTERVAL; } - enableConnectionPooling = Boolean.parseBoolean(commandline.getOptionValue("enableConnectionPooling", "true")); + enableConnectionPooling = Boolean.parseBoolean(commandline.getOptionValue("enableConnectionPooling", "false")); writeWatermarkPeriodMillis = Long.parseLong(commandline.getOptionValue("writeWatermarkPeriodMillis", "-1")); readWatermarkPeriodMillis = Long.parseLong(commandline.getOptionValue("readWatermarkPeriodMillis", "-1"));