HPCC-33081 Roxie continuation cursor positions log msg should be a WA…

…RNING Signed-off-by: M Kelly <[email protected]>
hpcc-systems · Dec 5, 2024 · 6640f0c · 6640f0c
1 parent 32e2bda
commit 6640f0c
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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());