Tests parallel inserts with result set caching on. Parallel inserts have a coordinator instance but no coordinator fragment, so the query mem tracker is initialized differently. (IMPALA-963)
(self)
| 445 | @pytest.mark.execute_serially |
| 446 | @needs_session() |
| 447 | def test_parallel_insert(self): |
| 448 | """Tests parallel inserts with result set caching on. |
| 449 | Parallel inserts have a coordinator instance but no coordinator |
| 450 | fragment, so the query mem tracker is initialized differently. |
| 451 | (IMPALA-963) |
| 452 | """ |
| 453 | self.cleanup_db(self.TEST_DB) |
| 454 | self.client.set_configuration({'sync_ddl': 1}) |
| 455 | self.client.execute("create database %s" % self.TEST_DB) |
| 456 | self.client.execute("create table %s.orderclone like tpch.orders" % self.TEST_DB) |
| 457 | options = {self.IMPALA_RESULT_CACHING_OPT: "10"} |
| 458 | handle = self.run_query_expect_success("insert overwrite %s.orderclone " |
| 459 | "select * from tpch.orders " |
| 460 | "where o_orderkey < 0" % self.TEST_DB, options) |
| 461 | self.close(handle) |
| 462 | |
| 463 | @pytest.mark.execute_serially |
| 464 | @needs_session() |
nothing calls this directly
no test coverage detected