This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch FastFail
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/FastFail by this push:
new d766c76e21b Reduce log frequency
d766c76e21b is described below
commit d766c76e21b2154adbb443b806bd4935682ae703
Author: JackieTien97 <[email protected]>
AuthorDate: Tue Aug 19 19:27:24 2025 +0800
Reduce log frequency
---
.../dataregion/memtable/AbstractWritableMemChunk.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractWritableMemChunk.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractWritableMemChunk.java
index 72e39f3cbbb..268a9213b3c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractWritableMemChunk.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractWritableMemChunk.java
@@ -58,12 +58,18 @@ public abstract class AbstractWritableMemChunk implements
IWritableMemChunk {
protected void maybeReleaseTvList(TVList tvList) {
long startTimeInMs = System.currentTimeMillis();
boolean succeed = false;
+ int retryCount = 0;
while (!succeed) {
try {
tryReleaseTvList(tvList);
succeed = true;
} catch (MemoryNotEnoughException ex) {
- LOGGER.warn("Failed to transfer tvlist memory owner to query engine,
{}", ex.getMessage());
+ // print log every 5 seconds
+ if (retryCount % 50 == 0) {
+ LOGGER.warn(
+ "Failed to transfer tvlist memory owner to query engine, {}",
ex.getMessage());
+ }
+ retryCount++;
long waitQueryInMs = System.currentTimeMillis() - startTimeInMs;
if (waitQueryInMs > MAX_WAIT_QUERY_MS) {
// Abort first query in the list. When all queries in the list have
been aborted,
