temp

hpcc-systems · Jun 25, 2024 · f877085 · f877085
1 parent 2b71ffb
commit f877085
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/thorlcr/activities/thactivityutil.cpp b/thorlcr/activities/thactivityutil.cpp
@@ -218,7 +218,7 @@ class CRowStreamLookAhead : public CSimpleInterfaceOf<IStartableEngineRowStream>
         count = 0;
 
         newLookAhead = activity.getOptBool("newlookahead", false);
-        if (activity.getOptBool("forcenewlookahead", false))
+        if (activity.getOptBool("forcenewlookahead", true)) // JCSMORE - temporarily force newlookahead
         {
             newLookAhead = true;
             allowspill = true;

diff --git a/thorlcr/thorutil/thbuf.cpp b/thorlcr/thorutil/thbuf.cpp
@@ -613,7 +613,7 @@ class CSmartRowInMemoryBuffer: public CSimpleInterface, implements ISmartRowBuff
 // based on query that produces records with a single sequential (from 1) unsigned4
 // #define VERIFY_ROW_IDS_SPILLING_ROWSTREAM
 
-//#define STRESSTEST_SPILLING_ROWSTREAM // 'stressLookAhead' code, which when enabled, reduces buffer sizes etc. to stress test the lookahead spilling
+#define STRESSTEST_SPILLING_ROWSTREAM // 'stressLookAhead' code, which when enabled, reduces buffer sizes etc. to stress test the lookahead spilling
 
 
 
@@ -979,7 +979,7 @@ class CCompressedSpillingRowStream: public CSimpleInterfaceOf<ISmartRowBuffer>,
         size32_t minSize = meta->getMinRecordSize();
 
 #ifdef STRESSTEST_SPILLING_ROWSTREAM
-        stressTest = activity.getOptBool("stressLookAhead");
+        stressTest = activity.getOptBool("stressLookAhead", true); // JCSMORE temporarily defaulting to true
         if (stressTest)
         {
             options.inMemMaxMem = minSize * 4;
@@ -1078,6 +1078,7 @@ class CCompressedSpillingRowStream: public CSimpleInterfaceOf<ISmartRowBuffer>,
             case rs_stopped:
                 return nullptr;
         }
+        throwUnexpected();
     }
     virtual void stop() override
     {