thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-23 02:00:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #33362 from kitaisreal/user-defined-executable-function-fix-exception

Browse Source 
UserDefinedExecutableFunction fix exception
This commit is contained in:
Maksim Kita 2022-01-02 19:58:28 +03:00 committed by GitHub
commit 106e742f98
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Interpreters/UserDefinedExecutableFunctionFactory.cpp
View File

@ -98,7 +98,7 @@ public:
column_with_type.column = castColumnAccurate(column_to_cast, argument_type); column_with_type.column = castColumnAccurate(column_to_cast, argument_type);
column_with_type.type = argument_type; column_with_type.type = argument_type;
column_with_type = column_to_cast; column_with_type = std::move(column_to_cast);
} }
ColumnWithTypeAndName result(result_type, "result"); ColumnWithTypeAndName result(result_type, "result");
@ -110,7 +110,7 @@ public:
ShellCommandSourceConfiguration shell_command_source_configuration; ShellCommandSourceConfiguration shell_command_source_configuration;
if (coordinator->getConfiguration().is_executable_pool) if (coordinator_configuration.is_executable_pool)
{ {
shell_command_source_configuration.read_fixed_number_of_rows = true; shell_command_source_configuration.read_fixed_number_of_rows = true;
shell_command_source_configuration.number_of_rows_to_read = input_rows_count; shell_command_source_configuration.number_of_rows_to_read = input_rows_count;
@ -143,8 +143,8 @@ public:
size_t result_column_size = result_column->size(); size_t result_column_size = result_column->size();
if (result_column_size != input_rows_count) if (result_column_size != input_rows_count)
throw Exception(ErrorCodes::UNSUPPORTED_METHOD, throw Exception(ErrorCodes::UNSUPPORTED_METHOD,
"Function {} wrong result rows count expected {} actual {}", "Function {}: wrong result, expected {} row(s), actual {}",
getName(), quoteString(getName()),
input_rows_count, input_rows_count,
result_column_size); result_column_size);