thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

better

Browse Source
This commit is contained in:
Nikita Mikhaylov 2021-04-26 18:50:40 +03:00
parent 478d540617
commit 9a70136bcf
4 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Processors/Formats/Impl/ParallelParsingInputFormat.cpp
View File

@ -147,6 +147,13 @@ void ParallelParsingInputFormat::onBackgroundException(size_t offset)
Chunk ParallelParsingInputFormat::generate()
{
/// Delayed launching of segmenting thread
if (!parsing_started.exchange(true))
{
segmentator_thread = ThreadFromGlobalPool(
&ParallelParsingInputFormat::segmentatorThreadFunction, this, CurrentThread::getGroup());
}
if (isCancelled() || parsing_finished)
{
/**

4
src/Processors/Formats/Impl/ParallelParsingInputFormat.h
View File

@ -97,9 +97,6 @@ public:
// bump into reader thread on wraparound.
processing_units.resize(params.max_threads + 2);
segmentator_thread = ThreadFromGlobalPool(
&ParallelParsingInputFormat::segmentatorThreadFunction, this, CurrentThread::getGroup());
LOG_TRACE(&Poco::Logger::get("ParallelParsingInputFormat"), "Parallel parsing is used");
}
@ -205,6 +202,7 @@ private:
Poco::Event first_parser_finished;
std::atomic<bool> parsing_started{false};
std::atomic<bool> parsing_finished{false};
/// There are multiple "parsers", that's why we use thread pool.

1
tests/queries/0_stateless/01848_http_insert_segfault.reference Normal file
View File

@ -0,0 +1 @@
Ok.

8
tests/queries/0_stateless/01848_http_insert_segfault.sh Executable file
View File

@ -0,0 +1,8 @@
#!/usr/bin/env bash
CUR_DIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
# shellcheck source=../shell_config.sh
. "$CUR_DIR"/../shell_config.sh
${CLICKHOUSE_LOCAL} -q "select col1, initializeAggregation('argMaxState', col2, insertTime) as col2, now() as insertTime FROM generateRandom('col1 String, col2 Array(Float64)') LIMIT 1000000 FORMAT CSV" | curl -s 'http://localhost:8123/?query=INSERT%20INTO%20non_existing_table%20SELECT%20col1%2C%20initializeAggregation(%27argMaxState%27%2C%20col2%2C%20insertTime)%20as%20col2%2C%20now()%20as%20insertTime%20FROM%20input(%27col1%20String%2C%20col2%20Array(Float64)%27)%20FORMAT%20CSV' --data-binary @- | grep -q "Table default.non_existing_table doesn't exist" && echo 'Ok.' || echo 'FAIL' ||: