diff --git a/src/Functions/blockNumber.cpp b/src/Functions/blockNumber.cpp index 0a8e51206a6..52263061c4e 100644 --- a/src/Functions/blockNumber.cpp +++ b/src/Functions/blockNumber.cpp @@ -61,7 +61,7 @@ public: ColumnPtr executeImpl(const ColumnsWithTypeAndName &, const DataTypePtr &, size_t input_rows_count) const override { - size_t current_columns_number = columns_number++; + size_t current_columns_number = columns_number.fetch_add(1, std::memory_order_relaxed); return ColumnUInt64::create(input_rows_count, current_columns_number); } };