This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch cassandra-4.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cassandra-4.0 by this push:
new 43746c13c2 Use MAX_PARALLEL_TRANSFERS instead of default
43746c13c2 is described below
commit 43746c13c2d07e75adfb9f3c28d7b446d1184b1e
Author: Brandon Williams <brandonwilli...@apache.org>
AuthorDate: Fri Apr 25 14:27:11 2025 -0500
Use MAX_PARALLEL_TRANSFERS instead of default
Patch by brandonwilliams, reviewed by mck for CASSANDRA-20532
---
CHANGES.txt | 1 +
.../apache/cassandra/streaming/async/NettyStreamingMessageSender.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/CHANGES.txt b/CHANGES.txt
index ddd87100ad..70761240f1 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
4.0.18
+ * Honor MAX_PARALLEL_TRANSFERS correctly (CASSANDRA-20532)
* Updating a column with a new TTL but same expiration time is
non-deterministic and causes repair mismatches. (CASSANDRA-20561)
* Grant permission on keyspaces system_views and system_virtual_schema not
possible (CASSANDRA-20171)
* Avoid computing prepared statement size for unprepared batches
(CASSANDRA-20556)
diff --git
a/src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
b/src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
index 4334382be4..46480cd7c4 100644
---
a/src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
+++
b/src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
@@ -89,7 +89,7 @@ public class NettyStreamingMessageSender implements
StreamingMessageSender
private static final long DEFAULT_CLOSE_WAIT_IN_MILLIS =
TimeUnit.MINUTES.toMillis(5);
// a simple mechansim for allowing a degree of fairnes across multiple
sessions
- private static final Semaphore fileTransferSemaphore = new
Semaphore(DEFAULT_MAX_PARALLEL_TRANSFERS, true);
+ private static final Semaphore fileTransferSemaphore = new
Semaphore(MAX_PARALLEL_TRANSFERS, true);
private final StreamSession session;
private final boolean isPreview;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
