From 112e6b3a046218fd4f3fac8d78feac65dff505f1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ra=C3=BAl=20Gracia?= Date: Mon, 17 Aug 2020 16:07:02 +0200 Subject: [PATCH] Set connection pooling to false by default MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Raúl Gracia --- README.md | 2 +- src/main/java/io/pravega/perf/PravegaPerfTest.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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"));