You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/04/29 20:14:02 UTC
[pulsar] branch master updated: [pulsar-perf] Change the default for max-connections from 100 to 1 (#15387)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 74747b1c17c [pulsar-perf] Change the default for max-connections from 100 to 1 (#15387)
74747b1c17c is described below
commit 74747b1c17c77dcd0a71a767307aaf8726c9d925
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Fri Apr 29 23:13:54 2022 +0300
[pulsar-perf] Change the default for max-connections from 100 to 1 (#15387)
---
.../src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java | 2 +-
.../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 2 +-
.../src/main/java/org/apache/pulsar/testclient/PerformanceReader.java | 2 +-
.../main/java/org/apache/pulsar/testclient/PerformanceTransaction.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
index bdee5e2df08..0b9b719bfa2 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
@@ -150,7 +150,7 @@ public class PerformanceConsumer {
@Parameter(names = { "-c",
"--max-connections" }, description = "Max number of TCP connections to a single broker")
- public int maxConnections = 100;
+ public int maxConnections = 1;
@Parameter(names = { "-i",
"--stats-interval-seconds" },
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
index f18f4a84e13..ea40aa31ae2 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
@@ -182,7 +182,7 @@ public class PerformanceProducer {
@Parameter(names = { "-c",
"--max-connections" }, description = "Max number of TCP connections to a single broker")
- public int maxConnections = 100;
+ public int maxConnections = 1;
@Parameter(names = { "-m",
"--num-messages" }, description = "Number of messages to publish in total. If <= 0, it will keep "
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
index dee3a6c57c1..724cb4378b3 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java
@@ -96,7 +96,7 @@ public class PerformanceReader {
@Parameter(names = { "-c",
"--max-connections" }, description = "Max number of TCP connections to a single broker")
- public int maxConnections = 100;
+ public int maxConnections = 1;
@Parameter(names = { "-i",
"--stats-interval-seconds" },
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
index 31e566919ba..52af64d1bea 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java
@@ -142,7 +142,7 @@ public class PerformanceTransaction {
@Parameter(names = {"-c",
"--max-connections"}, description = "Max number of TCP connections to a single broker")
- public int maxConnections = 100;
+ public int maxConnections = 1;
@Parameter(names = {"-time",
"--test-duration"}, description = "Test duration (in second). 0 means keeping publishing")