From bf1042c8320c42cf8cfc8c9b9af509bba8a18237 Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Wed, 12 Sep 2012 18:18:48 +0000 Subject: [PATCH] dbms: development [#CONV-2944]. --- .../DB/DataStreams/ParallelAggregatingBlockInputStream.h | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dbms/include/DB/DataStreams/ParallelAggregatingBlockInputStream.h b/dbms/include/DB/DataStreams/ParallelAggregatingBlockInputStream.h index 609506060be..e71f98c05ad 100644 --- a/dbms/include/DB/DataStreams/ParallelAggregatingBlockInputStream.h +++ b/dbms/include/DB/DataStreams/ParallelAggregatingBlockInputStream.h @@ -58,6 +58,10 @@ public: pool.schedule(boost::bind(&ParallelAggregatingBlockInputStream::calculate, this, boost::ref(inputs[i]), boost::ref(*many_data[i]), boost::ref(exceptions[i]))); } pool.wait(); + + for (size_t i = 0, size = exceptions.size(); i < size; ++i) + if (exceptions[i]) + exceptions[i]->rethrow(); AggregatedDataVariantsPtr res = aggregator->merge(many_data); return aggregator->convertToBlock(*res);