natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use MAX_PARALLEL_TRANSFERS instead of default 

Patch by brandonwilliams, reviewed by mck for CASSANDRA-20532
This commit is contained in:
Brandon Williams 2025-04-25 14:27:11 -05:00
parent d4d858d382
commit 43746c13c2
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -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)

2
src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
View File

@ -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;