This is an automated email from the ASF dual-hosted git repository.

dcapwell pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git


    from 995c3abc42 Merge branch 'cassandra-4.1' into trunk
     new 5be1038c5d Streaming progress virtual table lock contention can 
trigger TCP_USER_TIMEOUT and fail streaming
     new 7df4530882 Merge branch 'cassandra-4.1' into trunk

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 CHANGES.txt                                        |   1 +
 conf/cassandra.yaml                                |  10 ++
 src/java/org/apache/cassandra/config/Config.java   |   3 +
 .../cassandra/config/DatabaseDescriptor.java       |  27 ++++
 .../org/apache/cassandra/config/DurationSpec.java  |  10 ++
 .../streaming/CassandraCompressedStreamReader.java |   7 +-
 .../streaming/CassandraCompressedStreamWriter.java |   3 +-
 .../CassandraEntireSSTableStreamReader.java        |   2 +-
 .../CassandraEntireSSTableStreamWriter.java        |   2 +-
 .../db/streaming/CassandraStreamReader.java        |   7 +-
 .../db/streaming/CassandraStreamWriter.java        |   6 +-
 .../apache/cassandra/streaming/ProgressInfo.java   |   5 +-
 .../apache/cassandra/streaming/StreamEvent.java    |   4 +-
 .../apache/cassandra/streaming/StreamManager.java  |  26 ++++
 .../cassandra/streaming/StreamManagerMBean.java    |  20 +++
 .../cassandra/streaming/StreamResultFuture.java    |  15 ++-
 .../apache/cassandra/streaming/StreamSession.java  |  22 ++--
 .../apache/cassandra/streaming/StreamingState.java | 143 +++++----------------
 .../management/ProgressInfoCompositeData.java      |   3 +
 .../test/streaming/RebuildStreamingTest.java       |  33 ++++-
 .../test/streaming/StreamingStatsDisabledTest.java |  65 ++++++++++
 .../distributed/util/QueryResultUtil.java          |   7 +
 .../db/virtual/StreamingVirtualTableTest.java      |  85 +++++++++---
 .../cassandra/streaming/SessionInfoTest.java       |   4 +-
 24 files changed, 360 insertions(+), 150 deletions(-)
 create mode 100644 
test/distributed/org/apache/cassandra/distributed/test/streaming/StreamingStatsDisabledTest.java


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to