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

wait write finish

Browse Source
This commit is contained in:
zhenjial 2022-09-13 14:19:40 +08:00
parent 456f8a0e62
commit 16c8cd0bd3
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Processors/Formats/IRowInputFormat.cpp
View File

@ -1,9 +1,7 @@
#include <Processors/Formats/IRowInputFormat.h>
#include <DataTypes/ObjectUtils.h>
#include <IO/WriteHelpers.h> // toString
#include <IO/WithFileName.h>
#include <IO/WriteBufferFromString.h>
#include <IO/Operators.h>
#include <base/chrono_io.h>
#include <Common/logger_useful.h>

2
tests/queries/0_stateless/02421_record_errors_row_by_input_format.sh
View File

@ -19,10 +19,12 @@ ${CLICKHOUSE_CLIENT} --query "create table data (A UInt8, B UInt8) engine=MergeT
# Server side
${CLICKHOUSE_CLIENT} --input_format_allow_errors_num 4 --input_format_record_errors_file_path "errors_server" --query "insert into data select * from file('a.csv', 'CSV', 'c1 UInt8, c2 UInt8');"
sleep 2
${CLICKHOUSE_CLIENT} --query "select * except (time) from file('errors_server', 'CSV', 'time DateTime, database Nullable(String), table Nullable(String), offset UInt32, reason String, raw_data String');"
# Client side
${CLICKHOUSE_CLIENT} --input_format_allow_errors_num 4 --input_format_record_errors_file_path "${CLICKHOUSE_USER_FILES_PATH}/errors_client" --query "insert into data(A, B) format CSV" < ${CLICKHOUSE_USER_FILES_PATH}/a.csv
sleep 2
${CLICKHOUSE_CLIENT} --query "select * except (time) from file('errors_client', 'CSV', 'time DateTime, database Nullable(String), table Nullable(String), offset UInt32, reason String, raw_data String');"
# Restore