Fix data race in infinity::UnSyncCounter@physical_limit::Offset(unsig…

…ned long)
infiniflow · Jan 9, 2025 · 7033b39 · 7033b39
1 parent b732f36
commit 7033b39
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/executor/operator/physical_limit.cpp b/src/executor/operator/physical_limit.cpp
@@ -154,7 +154,7 @@ PhysicalLimit::PhysicalLimit(u64 id,
         offset = (static_pointer_cast<ValueExpression>(offset_expr_))->GetValue().value_.big_int;
     }
 
-    counter_ = MakeUnique<UnSyncCounter>(offset, limit);
+    counter_ = MakeUnique<AtomicCounter>(offset, limit);
 }
 
 void PhysicalLimit::Init() {}