diff --git ql/src/test/queries/clientnegative/minimr_broken_pipe.q ql/src/test/queries/clientnegative/minimr_broken_pipe.q index 88a89d9..8dda9cd 100644 --- ql/src/test/queries/clientnegative/minimr_broken_pipe.q +++ ql/src/test/queries/clientnegative/minimr_broken_pipe.q @@ -1,4 +1,4 @@ set hive.input.format=org.apache.hadoop.hive.ql.io.HiveInputFormat; set hive.exec.script.allow.partial.consumption = false; -- Tests exception in ScriptOperator.close() by passing to the operator a small amount of data -SELECT TRANSFORM(*) USING 'true' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp; +SELECT TRANSFORM(*) USING 'true' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp; \ No newline at end of file diff --git ql/src/test/queries/clientnegative/script_broken_pipe1.q ql/src/test/queries/clientnegative/script_broken_pipe1.q index 0e9875b..6b1c09d 100644 --- ql/src/test/queries/clientnegative/script_broken_pipe1.q +++ ql/src/test/queries/clientnegative/script_broken_pipe1.q @@ -1,3 +1,3 @@ set hive.exec.script.allow.partial.consumption = false; -- Tests exception in ScriptOperator.close() by passing to the operator a small amount of data -SELECT TRANSFORM(*) USING 'true' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp; +SELECT TRANSFORM(*) USING 'true' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp; \ No newline at end of file diff --git ql/src/test/queries/clientnegative/script_broken_pipe3.q ql/src/test/queries/clientnegative/script_broken_pipe3.q index bdffb1f..60f93d2 100644 --- ql/src/test/queries/clientnegative/script_broken_pipe3.q +++ ql/src/test/queries/clientnegative/script_broken_pipe3.q @@ -1,3 +1,3 @@ set hive.exec.script.allow.partial.consumption = true; -- Test to ensure that a script with a bad error code still fails even with partial consumption -SELECT TRANSFORM(*) USING 'false' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp; +SELECT TRANSFORM(*) USING 'false' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp; diff --git ql/src/test/results/clientnegative/minimr_broken_pipe.q.out ql/src/test/results/clientnegative/minimr_broken_pipe.q.out index b4d51b4..5b0db2c 100644 --- ql/src/test/results/clientnegative/minimr_broken_pipe.q.out +++ ql/src/test/results/clientnegative/minimr_broken_pipe.q.out @@ -1,5 +1,5 @@ PREHOOK: query: -- Tests exception in ScriptOperator.close() by passing to the operator a small amount of data -SELECT TRANSFORM(*) USING 'true' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp +SELECT TRANSFORM(*) USING 'true' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp PREHOOK: type: QUERY PREHOOK: Input: default@src #### A masked pattern was here #### diff --git ql/src/test/results/clientnegative/script_broken_pipe1.q.out ql/src/test/results/clientnegative/script_broken_pipe1.q.out index bb8d1ba..9312331 100644 --- ql/src/test/results/clientnegative/script_broken_pipe1.q.out +++ ql/src/test/results/clientnegative/script_broken_pipe1.q.out @@ -1,5 +1,5 @@ PREHOOK: query: -- Tests exception in ScriptOperator.close() by passing to the operator a small amount of data -SELECT TRANSFORM(*) USING 'true' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp +SELECT TRANSFORM(*) USING 'true' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp PREHOOK: type: QUERY PREHOOK: Input: default@src #### A masked pattern was here #### diff --git ql/src/test/results/clientnegative/script_broken_pipe3.q.out ql/src/test/results/clientnegative/script_broken_pipe3.q.out index e2b3e79..15a6997 100644 --- ql/src/test/results/clientnegative/script_broken_pipe3.q.out +++ ql/src/test/results/clientnegative/script_broken_pipe3.q.out @@ -1,5 +1,5 @@ PREHOOK: query: -- Test to ensure that a script with a bad error code still fails even with partial consumption -SELECT TRANSFORM(*) USING 'false' AS a, b, c FROM (SELECT * FROM src LIMIT 1) tmp +SELECT TRANSFORM(*) USING 'false' AS a, b FROM (SELECT TRANSFORM(*) USING 'echo' AS a, b FROM src LIMIT 1) tmp PREHOOK: type: QUERY PREHOOK: Input: default@src #### A masked pattern was here ####