cqlsh> select * from article_infos limit 5;
ReadFailure: Error from server: code=1300 [Replica(s) failed to execute read] message="Operation failed - received 0 responses and 1 failures: UNKNOWN from /10.1.1.93:7000" info={'consistency': 'ONE', 'required_responses': 1, 'received_responses': 0, 'failures': 1, 'error_code_map': {'10.1.1.93': '0x0000'}}
当执行此类查询时，Cassandra日志打印：
ERROR [ReadStage-2] 2025-03-14 10:03:29,385 JVMStabilityInspector.java:70 - Exception in thread Thread[ReadStage-2,5,SharedPool]
java.lang.AssertionError: 7671074 > 7340032
at org.apache.cassandra.io.util.MmappedRegions$State.floor(MmappedRegions.java:363)
at org.apache.cassandra.io.util.MmappedRegions.floor(MmappedRegions.java:242)
at org.apache.cassandra.io.util.MmapRebufferer.rebuffer(MmapRebufferer.java:40)
at org.apache.cassandra.io.tries.Walker.<init>(Walker.java:75)
at org.apache.cassandra.io.tries.ValueIterator.<init>(ValueIterator.java:96)
at org.apache.cassandra.io.tries.ValueIterator.<init>(ValueIterator.java:80)
at org.apache.cassandra.io.sstable.format.bti.PartitionIndex$IndexPosIterator.<init>(PartitionIndex.java:407)
at org.apache.cassandra.io.sstable.format.bti.PartitionIterator.<init>(PartitionIterator.java:113)
at org.apache.cassandra.io.sstable.format.bti.PartitionIterator.create(PartitionIterator.java:75)
at org.apache.cassandra.io.sstable.format.bti.BtiTableReader.coveredKeysIterator(BtiTableReader.java:295)
at org.apache.cassandra.io.sstable.format.bti.BtiTableScanner$BtiScanningIterator.prepareToIterateRow(BtiTableScanner.java:114)
at org.apache.cassandra.io.sstable.format.SSTableScanner$BaseKeyScanningIterator.computeNext(SSTableScanner.java:264)
at org.apache.cassandra.io.sstable.format.SSTableScanner$BaseKeyScanningIterator.computeNext(SSTableScanner.java:244)
at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47)
at org.apache.cassandra.io.sstable.format.SSTableScanner.hasNext(SSTableScanner.java:206)
at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:90)
at org.apache.cassandra.utils.MergeIterator$Candidate.advance(MergeIterator.java:375)
at org.apache.cassandra.utils.MergeIterator$ManyToOne.advance(MergeIterator.java:187)
at org.apache.cassandra.utils.MergeIterator$ManyToOne.computeNext(MergeIterator.java:156)
at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47)
at org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$4.hasNext(UnfilteredPartitionIterators.java:264)
at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:90)
at org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$Serializer.serialize(UnfilteredPartitionIterators.java:334)
at org.apache.cassandra.db.ReadResponse$LocalDataResponse.build(ReadResponse.java:201)
at org.apache.cassandra.db.ReadResponse$LocalDataResponse.<init>(ReadResponse.java:186)
at org.apache.cassandra.db.ReadResponse.createDataResponse(ReadResponse.java:48)
at org.apache.cassandra.db.ReadCommand.createResponse(ReadCommand.java:372)
at org.apache.cassandra.service.StorageProxy$LocalReadRunnable.runMayThrow(StorageProxy.java:2210)
at org.apache.cassandra.service.StorageProxy$DroppableRunnable.run(StorageProxy.java:2607)
at org.apache.cassandra.concurrent.ExecutionFailure$2.run(ExecutionFailure.java:163)
at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:143)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)
ERROR [Reference-Reaper] 2025-03-14 10:03:55,267 Ref.java:243 - LEAK DETECTED: a reference (class org.apache.cassandra.io.util.FileHandle$Cleanup@1883489551:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Data.db) to class org.apache.cassandra.io.util.FileHandle$Cleanup@1883489551:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Data.db was not released before the reference was garbage collected
ERROR [Reference-Reaper] 2025-03-14 10:03:55,268 Ref.java:243 - LEAK DETECTED: a reference (class org.apache.cassandra.io.util.FileHandle$Cleanup@34244591:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Partitions.db) to class org.apache.cassandra.io.util.FileHandle$Cleanup@34244591:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Partitions.db was not released before the reference was garbage collected
ERROR [Reference-Reaper] 2025-03-14 10:03:55,268 Ref.java:243 - LEAK DETECTED: a reference (class org.apache.cassandra.io.util.FileHandle$Cleanup@713715721:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Rows.db) to class org.apache.cassandra.io.util.FileHandle$Cleanup@713715721:/scratch/USER/cassandra/data/PROJECT/article_infos-0e9822e0ff5111ef8c7267a1b8a131a2/da-3gok_1b58_3yj682gtxbd0q6ceck-bti-Rows.db was not released before the reference was garbage collected
我当前使用Kafka和DataStax Connector接收器将数据写入Cassandra，但是即使我直接使用插入语句，也不会浏览kafka。不确定的时间后，错误通常会消失，我可以查询数据库。 我想知道是否有人知道这里发生了什么。我很好奇，如果有人知道：
如果可以避免此错误如何在编写大量数据后如何知道数据库何时处于“良好”状态。即使假设上述查询成功，我已经观察到这个问题很多次，以至于它对基本数据完整性的信念动摇了。我知道卡桑德拉（Cassandra）即使完成数据编写完成后也会运行压实步骤，但是在上面的断言错误是令人不安的。
您描述的症状表明该节点已过载，并且无反应。这就是您在加载大量数据后不能查询它的原因。
如果您的群集的尺寸不正确，则在磁盘所能维持的吞吐量上加载数据就像进行DDOS攻击一样。例如，如果
commitlog/