fix build

Signed-off-by: xufei <[email protected]>
pingcap · Apr 22, 2022 · e0d47bf · e0d47bf
1 parent eab0793
commit e0d47bf
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/dbms/src/Interpreters/Aggregator.cpp b/dbms/src/Interpreters/Aggregator.cpp
@@ -2021,10 +2021,12 @@ void Aggregator::mergeStream(const BlockInputStreamPtr & stream, AggregatedDataV
 
             auto task = [&merge_bucket, bucket, aggregates_pool] {
                 return merge_bucket(bucket, aggregates_pool);
-            }
+            };
 
-                        if (thread_pool) thread_pool->schedule(wrapInvocable(true, task));
-            else task();
+            if (thread_pool)
+                thread_pool->schedule(wrapInvocable(true, task));
+            else
+                task();
         }
 
         if (thread_pool)