external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

worker_check_invalid_arguments: invalid task/job ids

pull/2911/head
Philip Dubé 2019-08-27 17:23:12 +00:00
parent 5f9e88b260
commit 8979fd038b
2 changed files with 40 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/test/regress/expected/worker_check_invalid_arguments.out
View File

@ -67,8 +67,27 @@ ERROR: column name array size: 2 and type array size: 3 do not match
SELECT worker_merge_files_into_table(:JobId, :TaskId,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'integer']);
ERROR: invalid input syntax for integer: "\x0b50"
ERROR: invalid input syntax for type integer: "\x0b50"
CONTEXT: COPY task_101108, line 1, column binarycolumn: "\x0b50"
-- Check that we fail to merge when ids are wrong
SELECT worker_merge_files_into_table(-1, :TaskId,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'bytea']);
ERROR: could not open directory "base/pgsql_job_cache/job_18446744073709551615/task_101108": No such file or directory
SELECT worker_merge_files_into_table(:JobId, -1,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'bytea']);
ERROR: could not open directory "base/pgsql_job_cache/job_201010/task_4294967295": No such file or directory
SELECT worker_merge_files_and_run_query(-1, :TaskId,
'CREATE TABLE task_000001_merge(merge_column_0 int)',
'CREATE TABLE task_000001 (a) AS SELECT sum(merge_column_0) FROM task_000001_merge'
);
ERROR: could not open directory "base/pgsql_job_cache/job_18446744073709551615/task_101108": No such file or directory
SELECT worker_merge_files_and_run_query(:JobId, -1,
'CREATE TABLE task_000001_merge(merge_column_0 int)',
'CREATE TABLE task_000001 (a) AS SELECT sum(merge_column_0) FROM task_000001_merge'
);
ERROR: could not open directory "base/pgsql_job_cache/job_201010/task_4294967295": No such file or directory
-- Finally, merge partitioned files using valid arguments
SELECT worker_merge_files_into_table(:JobId, :TaskId,
ARRAY['textcolumn', 'binarycolumn'],

20
src/test/regress/sql/worker_check_invalid_arguments.sql
View File

@ -75,6 +75,26 @@ SELECT worker_merge_files_into_table(:JobId, :TaskId,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'integer']);
-- Check that we fail to merge when ids are wrong
SELECT worker_merge_files_into_table(-1, :TaskId,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'bytea']);
SELECT worker_merge_files_into_table(:JobId, -1,
ARRAY['textcolumn', 'binarycolumn'],
ARRAY['text', 'bytea']);
SELECT worker_merge_files_and_run_query(-1, :TaskId,
'CREATE TABLE task_000001_merge(merge_column_0 int)',
'CREATE TABLE task_000001 (a) AS SELECT sum(merge_column_0) FROM task_000001_merge'
);
SELECT worker_merge_files_and_run_query(:JobId, -1,
'CREATE TABLE task_000001_merge(merge_column_0 int)',
'CREATE TABLE task_000001 (a) AS SELECT sum(merge_column_0) FROM task_000001_merge'
);
-- Finally, merge partitioned files using valid arguments
SELECT worker_merge_files_into_table(:JobId, :TaskId,