From 6640f0c514c4d1a83324dff22f89262c12beba9d Mon Sep 17 00:00:00 2001 From: M Kelly Date: Thu, 5 Dec 2024 16:16:43 -0500 Subject: [PATCH] HPCC-33081 Roxie continuation cursor positions log msg should be a WARNING Signed-off-by: M Kelly --- roxie/ccd/ccdactivities.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/roxie/ccd/ccdactivities.cpp b/roxie/ccd/ccdactivities.cpp index 25404c2dffd..12f6af71e35 100644 --- a/roxie/ccd/ccdactivities.cpp +++ b/roxie/ccd/ccdactivities.cpp @@ -2717,7 +2717,8 @@ class CRoxieIndexActivity : public CRoxieKeyedActivity compressToBuffer(compressed, si.length() - compressed.length(), si.toByteArray() + compressed.length()); bool report = logctx.queryTraceLevel() && (doTrace(traceRoxiePackets) || si.length() >= continuationWarnThreshold); if (report) - logctx.CTXLOG("ERROR: continuation data size %u for %d cursor positions is large - compressed to %u", si.length(), tlk->numActiveKeys(), compressed.length()); + logctx.CTXLOG("WARNING: continuation data size %u for %d cursor positions is large - compressed to %u", si.length(), tlk->numActiveKeys(), compressed.length()); + // should we check if compressed.length() is > continuationErrorThreshold ? siLen = compressed.length() - sizeof(siLen); compressed.writeDirect(0, sizeof(siLen), &siLen); output->sendMetaInfo(compressed.toByteArray(), compressed.length()); @@ -4130,7 +4131,8 @@ class CRoxieKeyedJoinIndexActivity : public CRoxieKeyedActivity compressToBuffer(compressed, si.length() - compressed.length(), si.toByteArray() + compressed.length()); bool report = logctx.queryTraceLevel() && (doTrace(traceRoxiePackets) || si.length() >= continuationWarnThreshold); if (report) - DBGLOG("ERROR: continuation data size %u for %d cursor positions is large - compressed to %u", si.length(), tlk->numActiveKeys(), compressed.length()); + DBGLOG("WARNING: continuation data size %u for %d cursor positions is large - compressed to %u", si.length(), tlk->numActiveKeys(), compressed.length()); + // should we check if compressed.length() is > continuationErrorThreshold ? siLen = compressed.length() - sizeof(siLen); compressed.writeDirect(0, sizeof(siLen), &siLen); output->sendMetaInfo(compressed.toByteArray(), compressed.length());