@ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 16:57:32.733809 2557 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 924a5e84b3d9031d:e07d643b7d223da6, backend: 2, instance: 924a5e84b3d9031d:e07d643b7d223daa done: true) I1009 17:02:28.985595 23058 authentication.cc:455] Successfully authenticated client user "hive@COE.CLOUDERA.COM" I1009 17:02:29.014210 22999 impala-hs2-server.cc:572] OpenSession(): username= I1009 17:02:29.048432 22999 impala-hs2-server.cc:690] GetInfo(): request=TGetInfoReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "f\xf3\xecY~\xf5B\xe2\x93\x17\r\xd0\x10\x95\x9d\xa7", 02: secret (string) = "\x91\x04\xd6P\xd4\xe7KG\x928\xa3}\x83\x97\xee\xe9", }, }, 02: infoType (i32) = 18, } I1009 17:02:29.059543 22999 impala-hs2-server.cc:690] GetInfo(): request=TGetInfoReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "f\xf3\xecY~\xf5B\xe2\x93\x17\r\xd0\x10\x95\x9d\xa7", 02: secret (string) = "\x91\x04\xd6P\xd4\xe7KG\x928\xa3}\x83\x97\xee\xe9", }, }, 02: infoType (i32) = 17, } I1009 17:02:29.070188 22999 impala-hs2-server.cc:677] CloseSession(): request=TCloseSessionReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "f\xf3\xecY~\xf5B\xe2\x93\x17\r\xd0\x10\x95\x9d\xa7", 02: secret (string) = "\x91\x04\xd6P\xd4\xe7KG\x928\xa3}\x83\x97\xee\xe9", }, }, } I1009 17:02:29.072374 22999 status.cc:111] Session closed @ 0x812969 (unknown) @ 0xa7b059 (unknown) @ 0xaa554c (unknown) @ 0xce2b76 (unknown) @ 0xcee8d4 (unknown) @ 0x7df90c (unknown) @ 0x1b29b7b (unknown) @ 0x1b116e9 (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:02:29.080009 22999 impala-hs2-server.cc:572] OpenSession(): username= I1009 17:02:29.094354 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "USE default", 04: runAsync (bool) = true, } I1009 17:02:29.094375 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "USE default", 04: runAsync (bool) = true, } I1009 17:02:29.095571 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.095835 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.095921 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 1073741824, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.097990 22999 Frontend.java:875] analyze query USE default I1009 17:02:29.099675 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xf7\xad\x02\xf3)\aB\x10\xa0\xcc\x8d\xe3XC\xca\xdc", 02: secret (string) = "\xf7\xad\x02\xf3)\aB\x10\xa0\xcc\x8d\xe3XC\xca\xdc", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = false, }, } I1009 17:02:29.130985 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=10420729f302adf7:dcca4358e38dcca0 I1009 17:02:29.131012 22999 impala-server.cc:914] UnregisterQuery(): query_id=10420729f302adf7:dcca4358e38dcca0 I1009 17:02:29.131017 22999 impala-server.cc:1000] Cancel(): query_id=10420729f302adf7:dcca4358e38dcca0 I1009 17:02:29.138514 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SET MEM_LIMIT=900000000", 04: runAsync (bool) = true, } I1009 17:02:29.138533 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SET MEM_LIMIT=900000000", 04: runAsync (bool) = true, } I1009 17:02:29.138840 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.139048 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.139118 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 1073741824, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.140728 22999 Frontend.java:875] analyze query SET MEM_LIMIT=900000000 I1009 17:02:29.141433 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xe6i\xdf\xfb\xdc\xa3GF\xae\xe7\x18@L1\"\x91", 02: secret (string) = "\xe6i\xdf\xfb\xdc\xa3GF\xae\xe7\x18@L1\"\x91", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.153312 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=4647a3dcfbdf69e6:9122314c4018e7ae I1009 17:02:29.153321 22999 impala-server.cc:914] UnregisterQuery(): query_id=4647a3dcfbdf69e6:9122314c4018e7ae I1009 17:02:29.153324 22999 impala-server.cc:1000] Cancel(): query_id=4647a3dcfbdf69e6:9122314c4018e7ae I1009 17:02:29.158083 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SET SYNC_DDL=1", 04: runAsync (bool) = true, } I1009 17:02:29.158126 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SET SYNC_DDL=1", 04: runAsync (bool) = true, } I1009 17:02:29.158383 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.158571 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.158638 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.160069 22999 Frontend.java:875] analyze query SET SYNC_DDL=1 I1009 17:02:29.160601 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "UT\xab_\x80oJ\xb1\x96%\xe2\x1f\xb4`\xd5N", 02: secret (string) = "UT\xab_\x80oJ\xb1\x96%\xe2\x1f\xb4`\xd5N", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.172524 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=b14a6f805fab5455:4ed560b41fe22596 I1009 17:02:29.172533 22999 impala-server.cc:914] UnregisterQuery(): query_id=b14a6f805fab5455:4ed560b41fe22596 I1009 17:02:29.172538 22999 impala-server.cc:1000] Cancel(): query_id=b14a6f805fab5455:4ed560b41fe22596 I1009 17:02:29.277554 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.277612 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.278017 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.278259 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.278337 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.279866 22999 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:02:29.282263 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\x8f:7\a+\xd9B\xd2\xa2Ea\x04\x1f\x85\xa6\xa9", 02: secret (string) = "\x8f:7\a+\xd9B\xd2\xa2Ea\x04\x1f\x85\xa6\xa9", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.332201 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=d242d92b07373a8f:a9a6851f046145a2 I1009 17:02:29.332216 22999 impala-server.cc:914] UnregisterQuery(): query_id=d242d92b07373a8f:a9a6851f046145a2 I1009 17:02:29.332221 22999 impala-server.cc:1000] Cancel(): query_id=d242d92b07373a8f:a9a6851f046145a2 I1009 17:02:29.339421 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.339442 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.339767 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.340082 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.340152 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.341619 22999 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:02:29.343551 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\x8f\xccF\xed\x86\x94O-\x8b\x02T}R\xe7\xa7\v", 02: secret (string) = "\x8f\xccF\xed\x86\x94O-\x8b\x02T}R\xe7\xa7\v", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.364009 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=2d4f9486ed46cc8f:ba7e7527d54028b I1009 17:02:29.364019 22999 impala-server.cc:914] UnregisterQuery(): query_id=2d4f9486ed46cc8f:ba7e7527d54028b I1009 17:02:29.364024 22999 impala-server.cc:1000] Cancel(): query_id=2d4f9486ed46cc8f:ba7e7527d54028b I1009 17:02:29.370649 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.370668 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:02:29.370980 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.371191 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.371268 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.372771 22999 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:02:29.374920 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "k(\x9c\xbf\v\x80H$\xb6\xc9\xb0\xe3\xa9\xfevL", 02: secret (string) = "k(\x9c\xbf\v\x80H$\xb6\xc9\xb0\xe3\xa9\xfevL", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.395581 22999 impala-hs2-server.cc:976] CloseOperation(): query_id=2448800bbf9c286b:4c76fea9e3b0c9b6 I1009 17:02:29.395591 22999 impala-server.cc:914] UnregisterQuery(): query_id=2448800bbf9c286b:4c76fea9e3b0c9b6 I1009 17:02:29.395596 22999 impala-server.cc:1000] Cancel(): query_id=2448800bbf9c286b:4c76fea9e3b0c9b6 I1009 17:02:29.464654 22999 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1`", 04: runAsync (bool) = true, } I1009 17:02:29.464704 22999 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "N\x1db\xbb\xf3\x9aN\xbe\x90\x81\x9b\xcf\xa1\xe6\xd2\x9b", 02: secret (string) = "c^\xf0\xf9f\x89O\xc4\x95\x91\xf2\xb1\xf5\x13Mp", }, }, 02: statement (string) = "SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1`", 04: runAsync (bool) = true, } I1009 17:02:29.465785 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.466536 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.466612 22999 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:02:29.468139 22999 Frontend.java:875] analyze query SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1` I1009 17:02:29.474377 22999 AggregateInfo.java:181] agg info: AggregateInfo{grouping_exprs=SlotRef{path=A.a1, type=STRING, id=0}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} mergeAggInfo: AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=4}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, SlotRef{type=STRING, id=5}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} I1009 17:02:29.477579 22999 SelectStmt.java:270] post-analysis AggregateInfo{grouping_exprs=SlotRef{path=A.a1, type=STRING, id=0}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} mergeAggInfo: AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=4}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, SlotRef{type=STRING, id=5}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} I1009 17:02:29.477778 22999 Frontend.java:953] create plan I1009 17:02:29.479876 22999 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:02:29.479969 22999 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:02:29.480058 22999 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:02:29.480111 22999 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:02:29.480650 22999 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:02:29.480715 22999 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:02:29.480783 22999 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:02:29.480840 22999 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:02:29.481376 22999 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:02:29.481439 22999 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:02:29.481518 22999 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:02:29.481568 22999 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:02:29.481926 22999 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:02:29.482308 22999 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:02:29.482491 22999 SingleNodePlanner.java:540] 0 chose b #lhs=-1 #rhs=-1 #ops=-2 I1009 17:02:29.482792 22999 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:02:29.482944 22999 SingleNodePlanner.java:540] 1 chose default.test_parquet #lhs=-1 #rhs=-1 #ops=-4 I1009 17:02:29.484483 22999 DistributedPlanner.java:78] create plan fragments I1009 17:02:29.484534 22999 DistributedPlanner.java:80] memlimit=900000000 I1009 17:02:29.484606 22999 DistributedPlanner.java:432] broadcast: cost=9223372036854775807 I1009 17:02:29.484664 22999 DistributedPlanner.java:433] card=-1 row_size=15.0 #nodes=2 I1009 17:02:29.484719 22999 DistributedPlanner.java:464] partition: cost=9223372036854775807 I1009 17:02:29.484771 22999 DistributedPlanner.java:465] lhs card=-1 row_size=30.0 I1009 17:02:29.484832 22999 DistributedPlanner.java:467] rhs card=-1 row_size=15.0 I1009 17:02:29.485756 22999 DistributedPlanner.java:469] 01:SCAN HDFS [default.test_parquet b, RANDOM] partitions=1/1 files=1221 size=7.95GB runtime filters: RF000 -> b.a1 table stats: unavailable column stats: unavailable hosts=2 per-host-mem=unavailable tuple-ids=1 row-size=15B cardinality=unavailable I1009 17:02:29.485874 22999 DistributedPlanner.java:432] broadcast: cost=9223372036854775807 I1009 17:02:29.485944 22999 DistributedPlanner.java:433] card=-1 row_size=15.0 #nodes=2 I1009 17:02:29.485998 22999 DistributedPlanner.java:464] partition: cost=9223372036854775807 I1009 17:02:29.486058 22999 DistributedPlanner.java:465] lhs card=-1 row_size=45.0 I1009 17:02:29.486114 22999 DistributedPlanner.java:467] rhs card=-1 row_size=15.0 I1009 17:02:29.486299 22999 DistributedPlanner.java:469] 02:SCAN HDFS [default.test_parquet, RANDOM] partitions=1/1 files=1221 size=7.95GB table stats: unavailable column stats: unavailable hosts=2 per-host-mem=unavailable tuple-ids=2 row-size=15B cardinality=unavailable I1009 17:02:29.487462 22999 Planner.java:127] desctbl: tuples: TupleDescriptor{id=0, name=BaseTableRef a, tbl=default.test_parquet, byte_size=40, is_materialized=true, slots=[SlotDescriptor{id=0, path=a.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=1, path=a.a2, type=STRING, materialized=true, byteSize=16, byteOffset=24, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=1, name=BaseTableRef b, tbl=default.test_parquet, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=3, path=b.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=2, name=BaseTableRef default.test_parquet, tbl=default.test_parquet, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=2, path=default.test_parquet.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=40, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=24, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=32, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=true, byteSize=8, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]} I1009 17:02:29.487581 22999 Planner.java:128] resultexprs: SlotRef{type=STRING, id=6} SlotRef{type=DOUBLE, id=7} I1009 17:02:29.487630 22999 Planner.java:129] finalize plan fragments I1009 17:02:29.489116 22999 Frontend.java:996] get scan range locations I1009 17:02:29.489329 22999 Planner.java:329] Estimated per-host peak memory requirement: 4596957184 I1009 17:02:29.489364 22999 Planner.java:330] Estimated per-host virtual cores requirement: 3 I1009 17:02:29.493180 22999 Frontend.java:1074] create result set metadata I1009 17:02:29.493268 22999 JniFrontend.java:148] Estimated Per-Host Requirements: Memory=4.28GB VCores=3 WARNING: The following tables are missing relevant table and/or column statistics. default.test_parquet 10:EXCHANGE [UNPARTITIONED] | hosts=2 per-host-mem=unavailable | tuple-ids=4 row-size=23B cardinality=unavailable | 09:AGGREGATE [FINALIZE] | output: avg:merge(length(rtrim(A.a2))) | group by: A.a1 | hosts=2 per-host-mem=128.00MB | tuple-ids=4 row-size=23B cardinality=unavailable | 08:EXCHANGE [HASH(A.a1)] | hosts=2 per-host-mem=0B | tuple-ids=3 row-size=23B cardinality=unavailable | 05:AGGREGATE [STREAMING] | output: avg(length(rtrim(A.a2))) | group by: A.a1 | hosts=2 per-host-mem=128.00MB | tuple-ids=3 row-size=23B cardinality=unavailable | 04:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: A.a1 = test_parquet.a1 | runtime filters: RF000 <- test_parquet.a1 | hosts=2 per-host-mem=2.00GB | tuple-ids=0,1,2 row-size=60B cardinality=unavailable | |--07:EXCHANGE [BROADCAST] | | hosts=2 per-host-mem=0B | | tuple-ids=2 row-size=15B cardinality=unavailable | | | 02:SCAN HDFS [default.test_parquet, RANDOM] | partitions=1/1 files=1221 size=7.95GB | table stats: unavailable | column stats: unavailable | hosts=2 per-host-mem=16.00MB | tuple-ids=2 row-size=15B cardinality=unavailable | 03:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: A.a1 = B.a1 | runtime filters: RF001 <- B.a1 | hosts=2 per-host-mem=2.00GB | tuple-ids=0,1 row-size=45B cardinality=unavailable | |--06:EXCHANGE [BROADCAST] | | hosts=2 per-host-mem=0B | | tuple-ids=1 row-size=15B cardinality=unavailable | | | 01:SCAN HDFS [default.test_parquet b, RANDOM] | partitions=1/1 files=1221 size=7.95GB | runtime filters: RF000 -> b.a1 | table stats: unavailable | column stats: unavailable | hosts=2 per-host-mem=16.00MB | tuple-ids=1 row-size=15B cardinality=unavailable | 00:SCAN HDFS [default.test_parquet a, RANDOM] partitions=1/1 files=1221 size=7.95GB runtime filters: RF000 -> A.a1, RF001 -> A.a1 table stats: unavailable column stats: unavailable hosts=2 per-host-mem=32.00MB tuple-ids=0 row-size=30B cardinality=unavailable I1009 17:02:29.508926 22999 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:02:29.511791 22999 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:02:29.511840 22999 admission-controller.cc:436] Schedule for id=92442b2d9b7951de:381adaf0c8f9a982 in pool_name=root.default cluster_mem_needed=1.68 GB PoolConfig: max_requests=1 max_queued=200 max_mem=-1.00 B I1009 17:02:29.511854 22999 admission-controller.cc:441] Stats: agg_num_running=0, agg_num_queued=0, agg_mem_reserved=0, local_host(local_mem_admitted=0, num_admitted_running=0, num_queued=0, backend_mem_reserved=0) I1009 17:02:29.511858 22999 admission-controller.cc:447] Admitted query id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:02:29.511906 22999 coordinator.cc:384] Exec() query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:02:29.511950 22999 plan-fragment-executor.cc:91] Prepare(): query_id=92442b2d9b7951de:381adaf0c8f9a982 instance_id=92442b2d9b7951de:381adaf0c8f9a983 I1009 17:02:29.511978 22999 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:02:29.511984 22999 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:02:29.512064 22999 plan-fragment-executor.cc:201] descriptor table for fragment=92442b2d9b7951de:381adaf0c8f9a983 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:02:29.512158 22999 coordinator.cc:547] starting 8 fragment instances for query 92442b2d9b7951de:381adaf0c8f9a982 I1009 17:02:29.512531 8487 fragment-mgr.cc:36] ExecPlanFragment() instance_id=92442b2d9b7951de:381adaf0c8f9a985 coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=1 I1009 17:02:29.513902 9578 fragment-mgr.cc:36] ExecPlanFragment() instance_id=92442b2d9b7951de:381adaf0c8f9a987 coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=3 I1009 17:02:29.514580 2367 fragment-mgr.cc:36] ExecPlanFragment() instance_id=92442b2d9b7951de:381adaf0c8f9a989 coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=5 I1009 17:02:29.514780 4111 plan-fragment-executor.cc:91] Prepare(): query_id=92442b2d9b7951de:381adaf0c8f9a982 instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:02:29.514839 4111 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:02:29.514847 4111 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:02:29.514928 4111 plan-fragment-executor.cc:201] descriptor table for fragment=92442b2d9b7951de:381adaf0c8f9a985 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:02:29.515270 8487 fragment-mgr.cc:36] ExecPlanFragment() instance_id=92442b2d9b7951de:381adaf0c8f9a98b coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=7 I1009 17:02:29.515609 4114 plan-fragment-executor.cc:91] Prepare(): query_id=92442b2d9b7951de:381adaf0c8f9a982 instance_id=92442b2d9b7951de:381adaf0c8f9a98b I1009 17:02:29.515713 4114 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:02:29.515741 4114 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:02:29.515794 4114 plan-fragment-executor.cc:201] descriptor table for fragment=92442b2d9b7951de:381adaf0c8f9a98b tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:02:29.517269 4112 plan-fragment-executor.cc:91] Prepare(): query_id=92442b2d9b7951de:381adaf0c8f9a982 instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:02:29.517375 4113 plan-fragment-executor.cc:91] Prepare(): query_id=92442b2d9b7951de:381adaf0c8f9a982 instance_id=92442b2d9b7951de:381adaf0c8f9a989 I1009 17:02:29.517498 4113 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:02:29.517505 4113 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:02:29.517504 4112 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:02:29.517516 4112 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:02:29.517561 4113 plan-fragment-executor.cc:201] descriptor table for fragment=92442b2d9b7951de:381adaf0c8f9a989 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:02:29.517587 4112 plan-fragment-executor.cc:201] descriptor table for fragment=92442b2d9b7951de:381adaf0c8f9a987 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:02:29.524080 4114 plan-fragment-executor.cc:310] Open(): instance_id=92442b2d9b7951de:381adaf0c8f9a98b I1009 17:02:29.524230 4118 plan-fragment-executor.cc:310] Open(): instance_id=92442b2d9b7951de:381adaf0c8f9a983 I1009 17:02:29.524268 22999 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xdeQy\x9b-+D\x92\x82\xa9\xf9\xc8\xf0\xda\x1a8", 02: secret (string) = "\xdeQy\x9b-+D\x92\x82\xa9\xf9\xc8\xf0\xda\x1a8", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:02:29.527098 4113 plan-fragment-executor.cc:310] Open(): instance_id=92442b2d9b7951de:381adaf0c8f9a989 I1009 17:02:29.661067 4111 plan-fragment-executor.cc:310] Open(): instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:02:29.680207 4112 plan-fragment-executor.cc:310] Open(): instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:02:30.528969 4114 hdfs-scan-node.cc:226] Only following filters arrived: , waited 1s004ms I1009 17:02:45.854918 9578 data-stream-mgr.cc:212] Reduced stream ID cache from 8 items, to 0, eviction took: 0 I1009 17:02:45.858505 8487 coordinator.cc:1618] Fragment instance 5(92442b2d9b7951de:381adaf0c8f9a989) on host host-10-17-101-152.coe.cloudera.com:22000 completed, 7 remaining: query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:02:45.858520 8487 coordinator.cc:1630] query_id=92442b2d9b7951de:381adaf0c8f9a982: first in-progress backend: host-10-17-101-153.coe.cloudera.com:22000 I1009 17:02:53.574738 2367 coordinator.cc:1618] Fragment instance 7(92442b2d9b7951de:381adaf0c8f9a98b) on host host-10-17-101-152.coe.cloudera.com:22000 completed, 6 remaining: query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:02:53.574756 2367 coordinator.cc:1630] query_id=92442b2d9b7951de:381adaf0c8f9a982: first in-progress backend: host-10-17-101-153.coe.cloudera.com:22000 I1009 17:03:13.506688 23058 authentication.cc:455] Successfully authenticated client user "hive@COE.CLOUDERA.COM" I1009 17:03:13.532501 23000 impala-hs2-server.cc:572] OpenSession(): username= I1009 17:03:13.556357 23000 impala-hs2-server.cc:690] GetInfo(): request=TGetInfoReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "W\xf2#\xaf,\x1fH\xdc\x95.\xe5\x84w\xca\xbc\xfb", 02: secret (string) = "F\x7f9\xe7d\xfdJ\xab\xbc\xcc\xa8\xb7f4\xc9\x95", }, }, 02: infoType (i32) = 18, } I1009 17:03:13.566587 23000 impala-hs2-server.cc:690] GetInfo(): request=TGetInfoReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "W\xf2#\xaf,\x1fH\xdc\x95.\xe5\x84w\xca\xbc\xfb", 02: secret (string) = "F\x7f9\xe7d\xfdJ\xab\xbc\xcc\xa8\xb7f4\xc9\x95", }, }, 02: infoType (i32) = 17, } I1009 17:03:13.577687 23000 impala-hs2-server.cc:677] CloseSession(): request=TCloseSessionReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "W\xf2#\xaf,\x1fH\xdc\x95.\xe5\x84w\xca\xbc\xfb", 02: secret (string) = "F\x7f9\xe7d\xfdJ\xab\xbc\xcc\xa8\xb7f4\xc9\x95", }, }, } I1009 17:03:13.579783 23000 status.cc:111] Session closed @ 0x812969 (unknown) @ 0xa7b059 (unknown) @ 0xaa554c (unknown) @ 0xce2b76 (unknown) @ 0xcee8d4 (unknown) @ 0x7df90c (unknown) @ 0x1b29b7b (unknown) @ 0x1b116e9 (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:03:13.586676 23000 impala-hs2-server.cc:572] OpenSession(): username= I1009 17:03:13.600708 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "USE default", 04: runAsync (bool) = true, } I1009 17:03:13.600738 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "USE default", 04: runAsync (bool) = true, } I1009 17:03:13.601348 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.601590 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.601709 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 1073741824, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.603246 23000 Frontend.java:875] analyze query USE default I1009 17:03:13.604569 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xf9\x1d\xbc\xb9\x106J\x8e\x8av\xff\x1c\x16\f\xe5\x94", 02: secret (string) = "\xf9\x1d\xbc\xb9\x106J\x8e\x8av\xff\x1c\x16\f\xe5\x94", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = false, }, } I1009 17:03:13.635468 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=8e4a3610b9bc1df9:94e50c161cff768a I1009 17:03:13.635476 23000 impala-server.cc:914] UnregisterQuery(): query_id=8e4a3610b9bc1df9:94e50c161cff768a I1009 17:03:13.635483 23000 impala-server.cc:1000] Cancel(): query_id=8e4a3610b9bc1df9:94e50c161cff768a I1009 17:03:13.643049 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SET MEM_LIMIT=900000000", 04: runAsync (bool) = true, } I1009 17:03:13.643079 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SET MEM_LIMIT=900000000", 04: runAsync (bool) = true, } I1009 17:03:13.643275 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.643460 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.643522 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 1073741824, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.645026 23000 Frontend.java:875] analyze query SET MEM_LIMIT=900000000 I1009 17:03:13.645488 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xb4\x80.\xd9\x8b\x82D\x8b\x9b\xa4\xce:\xde\x18 \xfe", 02: secret (string) = "\xb4\x80.\xd9\x8b\x82D\x8b\x9b\xa4\xce:\xde\x18 \xfe", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:03:13.654665 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=8b44828bd92e80b4:fe2018de3acea49b I1009 17:03:13.654672 23000 impala-server.cc:914] UnregisterQuery(): query_id=8b44828bd92e80b4:fe2018de3acea49b I1009 17:03:13.654676 23000 impala-server.cc:1000] Cancel(): query_id=8b44828bd92e80b4:fe2018de3acea49b I1009 17:03:13.660148 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SET SYNC_DDL=1", 04: runAsync (bool) = true, } I1009 17:03:13.660167 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SET SYNC_DDL=1", 04: runAsync (bool) = true, } I1009 17:03:13.660362 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.660547 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.660660 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = false, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.662063 23000 Frontend.java:875] analyze query SET SYNC_DDL=1 I1009 17:03:13.662441 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\x1c\x91\xbf\xd8\xafUN\xe6\xb5\xe8\xdb\r=\x84\xf6\xee", 02: secret (string) = "\x1c\x91\xbf\xd8\xafUN\xe6\xb5\xe8\xdb\r=\x84\xf6\xee", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:03:13.671778 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=e64e55afd8bf911c:eef6843d0ddbe8b5 I1009 17:03:13.671785 23000 impala-server.cc:914] UnregisterQuery(): query_id=e64e55afd8bf911c:eef6843d0ddbe8b5 I1009 17:03:13.671789 23000 impala-server.cc:1000] Cancel(): query_id=e64e55afd8bf911c:eef6843d0ddbe8b5 I1009 17:03:13.765266 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.765312 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.765730 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.766006 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.766120 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.767745 23000 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:03:13.770160 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "R\xeeG\x1fW\x92Nu\x9a\xc515\xd5q[:", 02: secret (string) = "R\xeeG\x1fW\x92Nu\x9a\xc515\xd5q[:", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:03:13.812718 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=754e92571f47ee52:3a5b71d53531c59a I1009 17:03:13.812726 23000 impala-server.cc:914] UnregisterQuery(): query_id=754e92571f47ee52:3a5b71d53531c59a I1009 17:03:13.812729 23000 impala-server.cc:1000] Cancel(): query_id=754e92571f47ee52:3a5b71d53531c59a I1009 17:03:13.820183 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.820221 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.820444 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.820626 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.820719 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.822264 23000 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:03:13.823995 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "4\xfa\x80\xa5\xa1UE\xdc\xa2d\x1d\x02N\f'i", 02: secret (string) = "4\xfa\x80\xa5\xa1UE\xdc\xa2d\x1d\x02N\f'i", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:03:13.841830 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=dc4555a1a580fa34:69270c4e021d64a2 I1009 17:03:13.841837 23000 impala-server.cc:914] UnregisterQuery(): query_id=dc4555a1a580fa34:69270c4e021d64a2 I1009 17:03:13.841842 23000 impala-server.cc:1000] Cancel(): query_id=dc4555a1a580fa34:69270c4e021d64a2 I1009 17:03:13.849983 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.850003 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "DESCRIBE default.test_parquet", 04: runAsync (bool) = true, } I1009 17:03:13.850219 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.850363 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.850425 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.852001 23000 Frontend.java:875] analyze query DESCRIBE default.test_parquet I1009 17:03:13.853781 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\xc5G\x00\xb5\xb4iAs\xa8\rNDg\x97$\xda", 02: secret (string) = "\xc5G\x00\xb5\xb4iAs\xa8\rNDg\x97$\xda", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:03:13.879945 23000 impala-hs2-server.cc:976] CloseOperation(): query_id=734169b4b50047c5:da249767444e0da8 I1009 17:03:13.879953 23000 impala-server.cc:914] UnregisterQuery(): query_id=734169b4b50047c5:da249767444e0da8 I1009 17:03:13.879958 23000 impala-server.cc:1000] Cancel(): query_id=734169b4b50047c5:da249767444e0da8 I1009 17:03:13.936384 23000 impala-hs2-server.cc:718] ExecuteStatement(): request=TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1`", 04: runAsync (bool) = true, } I1009 17:03:13.936413 23000 impala-hs2-server.cc:529] TExecuteStatementReq: TExecuteStatementReq { 01: sessionHandle (struct) = TSessionHandle { 01: sessionId (struct) = THandleIdentifier { 01: guid (string) = "\xc6\x18\x14\xbf\xc1\xd2N\x1b\xb4\x02UF\x03\x19\xc7\xb9", 02: secret (string) = "\xb7ll\x8a\xca\x91D\xdc\x84Fmr$L\xae\x15", }, }, 02: statement (string) = "SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1`", 04: runAsync (bool) = true, } I1009 17:03:13.936817 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.937064 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.937142 23000 impala-hs2-server.cc:562] TClientRequest.queryOptions: TQueryOptions { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 0, 03: disable_codegen (bool) = false, 04: batch_size (i32) = 0, 05: num_nodes (i32) = 0, 06: max_scan_range_length (i64) = 0, 07: num_scanner_threads (i32) = 0, 08: max_io_buffers (i32) = 0, 09: allow_unsupported_formats (bool) = false, 10: default_order_by_limit (i64) = -1, 11: debug_action (string) = "", 12: mem_limit (i64) = 900000000, 13: abort_on_default_limit_exceeded (bool) = false, 15: hbase_caching (i32) = 0, 16: hbase_cache_blocks (bool) = false, 17: parquet_file_size (i64) = 0, 18: explain_level (i32) = 1, 19: sync_ddl (bool) = true, 23: disable_cached_reads (bool) = false, 24: disable_outermost_topn (bool) = false, 25: rm_initial_mem (i64) = 0, 26: query_timeout_s (i32) = 0, 28: appx_count_distinct (bool) = false, 29: disable_unsafe_spills (bool) = false, 31: exec_single_node_rows_threshold (i32) = 100, 32: optimize_partition_key_scans (bool) = false, 34: schedule_random_replica (bool) = false, 35: scan_node_codegen_threshold (i64) = 1800000, 36: disable_streaming_preaggregations (bool) = false, 37: runtime_filter_mode (i32) = 2, 38: runtime_bloom_filter_size (i32) = 1048576, 39: runtime_filter_wait_time_ms (i32) = 0, 40: disable_row_runtime_filtering (bool) = false, 41: max_num_runtime_filters (i32) = 10, 42: parquet_annotate_strings_utf8 (bool) = false, 43: parquet_fallback_schema_resolution (i32) = 0, 44: mt_num_cores (i32) = 1, 45: s3_skip_insert_staging (bool) = true, 46: runtime_filter_min_size (i32) = 1048576, 47: runtime_filter_max_size (i32) = 16777216, 48: prefetch_mode (i32) = 1, 49: strict_mode (bool) = false, } I1009 17:03:13.938727 23000 Frontend.java:875] analyze query SELECT `A`.`a1`, AVG(ALL LENGTH(RTRIM(`A`.`a2`))) as `expr_0` FROM `default`.`test_parquet` `A`, `default`.`test_parquet` `B`, `default`.`test_parquet` WHERE ((`test_parquet`.`a1` = `A`.`a1`) AND (`A`.`a1` = `B`.`a1`)) GROUP BY `A`.`a1` I1009 17:03:13.944548 23000 AggregateInfo.java:181] agg info: AggregateInfo{grouping_exprs=SlotRef{path=A.a1, type=STRING, id=0}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} mergeAggInfo: AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=4}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, SlotRef{type=STRING, id=5}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} I1009 17:03:13.947464 23000 SelectStmt.java:270] post-analysis AggregateInfo{grouping_exprs=SlotRef{path=A.a1, type=STRING, id=0}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} mergeAggInfo: AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=4}, aggregate_exprs=FunctionCallExpr{name=avg, isStar=false, isDistinct=false, SlotRef{type=STRING, id=5}}, intermediate_tuple=TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=false, byteSize=0, byteOffset=-1, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=4}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=STRING, id=5})), output_smap=smap(A.a1:A.a1 (SlotRef{path=A.a1, type=STRING, id=0}:SlotRef{type=STRING, id=6}) avg(length(rtrim(A.a2))):avg(length(rtrim(A.a2))) (FunctionCallExpr{name=avg, isStar=false, isDistinct=false, CastExpr{isImplicit=true, target=BIGINT, FunctionCallExpr{name=length, isStar=false, isDistinct=false, FunctionCallExpr{name=rtrim, isStar=false, isDistinct=false, SlotRef{path=A.a2, type=STRING, id=1}}}}}:SlotRef{type=DOUBLE, id=7}))} I1009 17:03:13.947638 23000 Frontend.java:953] create plan I1009 17:03:13.949484 23000 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:03:13.949563 23000 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:03:13.949650 23000 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:03:13.949697 23000 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:03:13.950202 23000 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:03:13.950285 23000 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:03:13.950368 23000 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:03:13.950423 23000 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:03:13.950983 23000 HdfsScanNode.java:364] collecting partitions for table test_parquet I1009 17:03:13.951066 23000 HdfsScanNode.java:429] computeStats HdfsScan: cardinality_=-1 I1009 17:03:13.951158 23000 HdfsScanNode.java:485] computeNumNodes totalRanges=1221 localRanges=2 remoteRanges=0 localHostSet.size=2 clusterNodes=2 I1009 17:03:13.951233 23000 HdfsScanNode.java:432] computeStats HdfsScan: #nodes=2 I1009 17:03:13.951562 23000 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:03:13.951910 23000 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:03:13.952062 23000 SingleNodePlanner.java:540] 0 chose b #lhs=-1 #rhs=-1 #ops=-2 I1009 17:03:13.952354 23000 JoinNode.java:450] stats Join: cardinality=-1 I1009 17:03:13.953147 23000 SingleNodePlanner.java:540] 1 chose default.test_parquet #lhs=-1 #rhs=-1 #ops=-4 I1009 17:03:13.954480 23000 DistributedPlanner.java:78] create plan fragments I1009 17:03:13.954530 23000 DistributedPlanner.java:80] memlimit=900000000 I1009 17:03:13.954591 23000 DistributedPlanner.java:432] broadcast: cost=9223372036854775807 I1009 17:03:13.954644 23000 DistributedPlanner.java:433] card=-1 row_size=15.0 #nodes=2 I1009 17:03:13.954699 23000 DistributedPlanner.java:464] partition: cost=9223372036854775807 I1009 17:03:13.954743 23000 DistributedPlanner.java:465] lhs card=-1 row_size=30.0 I1009 17:03:13.954784 23000 DistributedPlanner.java:467] rhs card=-1 row_size=15.0 I1009 17:03:13.955051 23000 DistributedPlanner.java:469] 01:SCAN HDFS [default.test_parquet b, RANDOM] partitions=1/1 files=1221 size=7.95GB runtime filters: RF000 -> b.a1 table stats: unavailable column stats: unavailable hosts=2 per-host-mem=unavailable tuple-ids=1 row-size=15B cardinality=unavailable I1009 17:03:13.955157 23000 DistributedPlanner.java:432] broadcast: cost=9223372036854775807 I1009 17:03:13.955214 23000 DistributedPlanner.java:433] card=-1 row_size=15.0 #nodes=2 I1009 17:03:13.955258 23000 DistributedPlanner.java:464] partition: cost=9223372036854775807 I1009 17:03:13.955299 23000 DistributedPlanner.java:465] lhs card=-1 row_size=45.0 I1009 17:03:13.955339 23000 DistributedPlanner.java:467] rhs card=-1 row_size=15.0 I1009 17:03:13.955513 23000 DistributedPlanner.java:469] 02:SCAN HDFS [default.test_parquet, RANDOM] partitions=1/1 files=1221 size=7.95GB table stats: unavailable column stats: unavailable hosts=2 per-host-mem=unavailable tuple-ids=2 row-size=15B cardinality=unavailable I1009 17:03:13.956889 23000 Planner.java:127] desctbl: tuples: TupleDescriptor{id=0, name=BaseTableRef a, tbl=default.test_parquet, byte_size=40, is_materialized=true, slots=[SlotDescriptor{id=0, path=a.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=1, path=a.a2, type=STRING, materialized=true, byteSize=16, byteOffset=24, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=1, name=BaseTableRef b, tbl=default.test_parquet, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=3, path=b.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=2, name=BaseTableRef default.test_parquet, tbl=default.test_parquet, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=2, path=default.test_parquet.a1, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=3, name=agg-tuple-intermed, tbl=null, byte_size=40, is_materialized=true, slots=[SlotDescriptor{id=4, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=5, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=24, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]} TupleDescriptor{id=4, name=agg-tuple-out, tbl=null, byte_size=32, is_materialized=true, slots=[SlotDescriptor{id=6, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullable=true, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=15.0, maxSize_=-1, numDistinct_=-1, numNulls_=-1}}, SlotDescriptor{id=7, path=null, type=DOUBLE, materialized=true, byteSize=8, byteOffset=8, nullable=true, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=-1, numNulls_=-1}}]} I1009 17:03:13.957007 23000 Planner.java:128] resultexprs: SlotRef{type=STRING, id=6} SlotRef{type=DOUBLE, id=7} I1009 17:03:13.957062 23000 Planner.java:129] finalize plan fragments I1009 17:03:13.958247 23000 Frontend.java:996] get scan range locations I1009 17:03:13.958434 23000 Planner.java:329] Estimated per-host peak memory requirement: 4596957184 I1009 17:03:13.958469 23000 Planner.java:330] Estimated per-host virtual cores requirement: 3 I1009 17:03:13.962157 23000 Frontend.java:1074] create result set metadata I1009 17:03:13.962237 23000 JniFrontend.java:148] Estimated Per-Host Requirements: Memory=4.28GB VCores=3 WARNING: The following tables are missing relevant table and/or column statistics. default.test_parquet 10:EXCHANGE [UNPARTITIONED] | hosts=2 per-host-mem=unavailable | tuple-ids=4 row-size=23B cardinality=unavailable | 09:AGGREGATE [FINALIZE] | output: avg:merge(length(rtrim(A.a2))) | group by: A.a1 | hosts=2 per-host-mem=128.00MB | tuple-ids=4 row-size=23B cardinality=unavailable | 08:EXCHANGE [HASH(A.a1)] | hosts=2 per-host-mem=0B | tuple-ids=3 row-size=23B cardinality=unavailable | 05:AGGREGATE [STREAMING] | output: avg(length(rtrim(A.a2))) | group by: A.a1 | hosts=2 per-host-mem=128.00MB | tuple-ids=3 row-size=23B cardinality=unavailable | 04:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: A.a1 = test_parquet.a1 | runtime filters: RF000 <- test_parquet.a1 | hosts=2 per-host-mem=2.00GB | tuple-ids=0,1,2 row-size=60B cardinality=unavailable | |--07:EXCHANGE [BROADCAST] | | hosts=2 per-host-mem=0B | | tuple-ids=2 row-size=15B cardinality=unavailable | | | 02:SCAN HDFS [default.test_parquet, RANDOM] | partitions=1/1 files=1221 size=7.95GB | table stats: unavailable | column stats: unavailable | hosts=2 per-host-mem=16.00MB | tuple-ids=2 row-size=15B cardinality=unavailable | 03:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: A.a1 = B.a1 | runtime filters: RF001 <- B.a1 | hosts=2 per-host-mem=2.00GB | tuple-ids=0,1 row-size=45B cardinality=unavailable | |--06:EXCHANGE [BROADCAST] | | hosts=2 per-host-mem=0B | | tuple-ids=1 row-size=15B cardinality=unavailable | | | 01:SCAN HDFS [default.test_parquet b, RANDOM] | partitions=1/1 files=1221 size=7.95GB | runtime filters: RF000 -> b.a1 | table stats: unavailable | column stats: unavailable | hosts=2 per-host-mem=16.00MB | tuple-ids=1 row-size=15B cardinality=unavailable | 00:SCAN HDFS [default.test_parquet a, RANDOM] partitions=1/1 files=1221 size=7.95GB runtime filters: RF000 -> A.a1, RF001 -> A.a1 table stats: unavailable column stats: unavailable hosts=2 per-host-mem=32.00MB tuple-ids=0 row-size=30B cardinality=unavailable I1009 17:03:13.972476 23000 RequestPoolService.java:274] resolveRequestPool(pool=, user=hive@COE.CLOUDERA.COM): resolved_pool=root.default, has_access=true I1009 17:03:13.975467 23000 RequestPoolService.java:372] getPoolConfig(pool=root.default): max_mem_resources=-1, max_requests=1, max_queued=200, queue_timeout_ms=3600000, default_query_options= I1009 17:03:13.975529 23000 admission-controller.cc:436] Schedule for id=64c001dc6dcd712:2562d42c35a26399 in pool_name=root.default cluster_mem_needed=1.68 GB PoolConfig: max_requests=1 max_queued=200 max_mem=-1.00 B I1009 17:03:13.975545 23000 admission-controller.cc:441] Stats: agg_num_running=1, agg_num_queued=0, agg_mem_reserved=1.68 GB, local_host(local_mem_admitted=1.68 GB, num_admitted_running=1, num_queued=0, backend_mem_reserved=858.31 MB) I1009 17:03:13.975589 23000 admission-controller.cc:458] Queuing, query id=64c001dc6dcd712:2562d42c35a26399 I1009 17:03:23.201800 8487 fragment-mgr.cc:146] Unknown fragment (ID: 92442b2d9b7951de:381adaf0c8f9a98b) for filter (ID: 0) I1009 17:03:23.202067 8502 coordinator.cc:1618] Fragment instance 4(92442b2d9b7951de:381adaf0c8f9a988) on host host-10-17-101-153.coe.cloudera.com:22000 completed, 5 remaining: query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:03:23.202080 8502 coordinator.cc:1630] query_id=92442b2d9b7951de:381adaf0c8f9a982: first in-progress backend: host-10-17-101-153.coe.cloudera.com:22000 I1009 17:03:23.321648 4112 hdfs-scan-node.cc:219] Filters arrived. Waited 0 I1009 17:03:23.321921 8502 coordinator.cc:1618] Fragment instance 6(92442b2d9b7951de:381adaf0c8f9a98a) on host host-10-17-101-153.coe.cloudera.com:22000 completed, 4 remaining: query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:03:23.321936 8502 coordinator.cc:1630] query_id=92442b2d9b7951de:381adaf0c8f9a982: first in-progress backend: host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:35.112604 5114 status.cc:111] Cancelled from Impala's debug web interface @ 0x812969 (unknown) @ 0xa998f0 (unknown) @ 0xb9d6e5 (unknown) @ 0xb9eb05 (unknown) @ 0xbac110 (unknown) @ 0xbae88d (unknown) @ 0xbaef1d (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.112624 5114 impala-server.cc:914] UnregisterQuery(): query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:06:35.112645 5114 impala-server.cc:1000] Cancel(): query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:06:35.112664 5114 coordinator.cc:1434] Cancel() query_id=92442b2d9b7951de:381adaf0c8f9a982 I1009 17:06:35.112669 5114 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:35.112671 5114 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a983 I1009 17:06:35.112674 5114 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a983 I1009 17:06:35.112680 5114 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=92442b2d9b7951de:381adaf0c8f9a983 node_id=10 I1009 17:06:35.112695 5114 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=92442b2d9b7951de:381adaf0c8f9a984 backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:35.235612 5114 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=92442b2d9b7951de:381adaf0c8f9a985 backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:35.235743 8487 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:35.235769 8487 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:35.235772 8487 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:35.235776 8487 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:35.235781 8487 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=92442b2d9b7951de:381adaf0c8f9a985 node_id=8 I1009 17:06:35.235858 5114 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=92442b2d9b7951de:381adaf0c8f9a986 backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:35.236065 5114 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=92442b2d9b7951de:381adaf0c8f9a987 backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:35.236119 9578 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:35.236127 9578 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:35.236129 9578 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:35.236132 9578 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:35.236150 9578 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=92442b2d9b7951de:381adaf0c8f9a987 node_id=6 I1009 17:06:35.236155 9578 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=92442b2d9b7951de:381adaf0c8f9a987 node_id=7 I1009 17:06:35.237331 23000 admission-controller.cc:518] Admitted queued query id=64c001dc6dcd712:2562d42c35a26399 I1009 17:06:35.237342 23000 coordinator.cc:384] Exec() query_id=64c001dc6dcd712:2562d42c35a26399 I1009 17:06:35.237414 23000 plan-fragment-executor.cc:91] Prepare(): query_id=64c001dc6dcd712:2562d42c35a26399 instance_id=64c001dc6dcd712:2562d42c35a2639a I1009 17:06:35.237467 23000 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:06:35.237473 23000 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:06:35.237576 23000 plan-fragment-executor.cc:201] descriptor table for fragment=64c001dc6dcd712:2562d42c35a2639a tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:06:35.237833 23000 coordinator.cc:547] starting 8 fragment instances for query 64c001dc6dcd712:2562d42c35a26399 I1009 17:06:35.239053 2367 fragment-mgr.cc:36] ExecPlanFragment() instance_id=64c001dc6dcd712:2562d42c35a2639c coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=1 I1009 17:06:35.239940 8487 fragment-mgr.cc:36] ExecPlanFragment() instance_id=64c001dc6dcd712:2562d42c35a2639e coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=3 I1009 17:06:35.240871 9578 fragment-mgr.cc:36] ExecPlanFragment() instance_id=64c001dc6dcd712:2562d42c35a263a0 coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=5 I1009 17:06:35.241271 5322 plan-fragment-executor.cc:91] Prepare(): query_id=64c001dc6dcd712:2562d42c35a26399 instance_id=64c001dc6dcd712:2562d42c35a2639e I1009 17:06:35.241389 5322 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:06:35.241395 5322 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:06:35.241453 5322 plan-fragment-executor.cc:201] descriptor table for fragment=64c001dc6dcd712:2562d42c35a2639e tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:06:35.247344 5321 plan-fragment-executor.cc:91] Prepare(): query_id=64c001dc6dcd712:2562d42c35a26399 instance_id=64c001dc6dcd712:2562d42c35a2639c I1009 17:06:35.247390 5321 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:06:35.247397 5321 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:06:35.247532 5321 plan-fragment-executor.cc:201] descriptor table for fragment=64c001dc6dcd712:2562d42c35a2639c tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:06:35.247535 5323 plan-fragment-executor.cc:91] Prepare(): query_id=64c001dc6dcd712:2562d42c35a26399 instance_id=64c001dc6dcd712:2562d42c35a263a0 I1009 17:06:35.248762 5323 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:06:35.248771 5323 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:06:35.248867 5323 plan-fragment-executor.cc:201] descriptor table for fragment=64c001dc6dcd712:2562d42c35a263a0 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:06:35.251139 5323 plan-fragment-executor.cc:310] Open(): instance_id=64c001dc6dcd712:2562d42c35a263a0 I1009 17:06:35.257650 5114 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=92442b2d9b7951de:381adaf0c8f9a983, node=10 I1009 17:06:35.407387 5321 plan-fragment-executor.cc:310] Open(): instance_id=64c001dc6dcd712:2562d42c35a2639c I1009 17:06:35.433545 5322 plan-fragment-executor.cc:310] Open(): instance_id=64c001dc6dcd712:2562d42c35a2639e I1009 17:06:35.523272 2554 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 2, instance: 92442b2d9b7951de:381adaf0c8f9a986 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.523283 2554 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 2, instance: 92442b2d9b7951de:381adaf0c8f9a986 done: true) I1009 17:06:35.535145 22999 impala-server.cc:1676] Connection from client 10.17.102.128:46680 closed, closing 2 associated session(s) I1009 17:06:35.537045 22999 status.cc:111] Session closed @ 0x812969 (unknown) @ 0xa7b059 (unknown) @ 0xa7b558 (unknown) @ 0x9ae380 (unknown) @ 0x1b2a653 (unknown) @ 0x1b116e9 (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.684939 8502 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 0, instance: 92442b2d9b7951de:381adaf0c8f9a984 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.684991 8502 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 0, instance: 92442b2d9b7951de:381adaf0c8f9a984 done: true) I1009 17:06:35.778825 8487 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 1, instance: 92442b2d9b7951de:381adaf0c8f9a985 done: false) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.778841 8487 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 1, instance: 92442b2d9b7951de:381adaf0c8f9a985 done: false) I1009 17:06:35.778918 4127 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:35.778923 4127 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:35.778928 4127 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:35.789528 2367 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 3, instance: 92442b2d9b7951de:381adaf0c8f9a987 done: false) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:35.789541 2367 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 3, instance: 92442b2d9b7951de:381adaf0c8f9a987 done: false) I1009 17:06:35.789598 4130 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:35.789605 4130 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:35.789611 4130 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:38.189906 9578 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 3, instance: 92442b2d9b7951de:381adaf0c8f9a987 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:38.189925 9578 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 3, instance: 92442b2d9b7951de:381adaf0c8f9a987 done: true) I1009 17:06:38.190093 4112 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:38.190137 4112 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:38.190150 4112 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a987 I1009 17:06:38.192739 8487 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 1, instance: 92442b2d9b7951de:381adaf0c8f9a985 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:38.192752 8487 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 92442b2d9b7951de:381adaf0c8f9a982, backend: 1, instance: 92442b2d9b7951de:381adaf0c8f9a985 done: true) I1009 17:06:38.192800 4111 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:38.192807 4111 plan-fragment-executor.cc:552] Cancel(): instance_id=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:38.192812 4111 data-stream-mgr.cc:254] cancelling all streams for fragment=92442b2d9b7951de:381adaf0c8f9a985 I1009 17:06:38.201683 4111 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=92442b2d9b7951de:381adaf0c8f9a985, node=8 I1009 17:06:38.205739 4112 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=92442b2d9b7951de:381adaf0c8f9a987, node=6 I1009 17:06:38.205792 4112 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=92442b2d9b7951de:381adaf0c8f9a987, node=7 I1009 17:06:43.082967 22899 authentication.cc:422] Successfully authenticated principal "impala/host-10-17-101-152.coe.cloudera.com@COE.CLOUDERA.COM" on an internal connection I1009 17:06:43.084060 5437 fragment-mgr.cc:36] ExecPlanFragment() instance_id=64c001dc6dcd712:2562d42c35a263a2 coord=host-10-17-101-152.coe.cloudera.com:22000 fragment instance#=7 I1009 17:06:43.084233 5438 plan-fragment-executor.cc:91] Prepare(): query_id=64c001dc6dcd712:2562d42c35a26399 instance_id=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:43.085048 5439 plan-fragment-executor.cc:310] Open(): instance_id=64c001dc6dcd712:2562d42c35a2639a I1009 17:06:43.085088 23000 impala-hs2-server.cc:788] ExecuteStatement(): return_val=TExecuteStatementResp { 01: status (struct) = TStatus { 01: statusCode (i32) = 0, }, 02: operationHandle (struct) = TOperationHandle { 01: operationId (struct) = THandleIdentifier { 01: guid (string) = "\x12\xd7\xdc\xc6\x1d\x00L\x06\x99c\xa25,\xd4b%", 02: secret (string) = "\x12\xd7\xdc\xc6\x1d\x00L\x06\x99c\xa25,\xd4b%", }, 02: operationType (i32) = 0, 03: hasResultSet (bool) = true, }, } I1009 17:06:43.085119 23000 thrift-util.cc:109] TSocket::write_partial() send() Broken pipe I1009 17:06:43.085196 23000 impala-server.cc:1676] Connection from client 10.17.102.128:46724 closed, closing 2 associated session(s) I1009 17:06:43.087879 23000 status.cc:111] Session closed @ 0x812969 (unknown) @ 0xa7b059 (unknown) @ 0xa7b558 (unknown) @ 0x9ae380 (unknown) @ 0x1b2a653 (unknown) @ 0x1b116e9 (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:43.087887 23000 impala-server.cc:914] UnregisterQuery(): query_id=64c001dc6dcd712:2562d42c35a26399 I1009 17:06:43.087893 23000 impala-server.cc:1000] Cancel(): query_id=64c001dc6dcd712:2562d42c35a26399 I1009 17:06:43.087931 23000 coordinator.cc:1434] Cancel() query_id=64c001dc6dcd712:2562d42c35a26399 I1009 17:06:43.087936 23000 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:43.087939 23000 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a2639a I1009 17:06:43.087941 23000 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a2639a I1009 17:06:43.087950 23000 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=64c001dc6dcd712:2562d42c35a2639a node_id=10 I1009 17:06:43.087965 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a2639b backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:43.088145 5438 plan-fragment-executor.cc:150] Using query memory limit from query options: 858.31 MB I1009 17:06:43.088163 5438 mem-tracker.cc:192] Using query memory limit: 858.31 MB I1009 17:06:43.088255 5438 plan-fragment-executor.cc:201] descriptor table for fragment=64c001dc6dcd712:2562d42c35a263a2 tuples: Tuple(id=0 size=40 slots=[Slot(id=0 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[1] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=1 size=24 slots=[Slot(id=3 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=2 size=24 slots=[Slot(id=2 type=STRING col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) Tuple(id=3 size=40 slots=[Slot(id=4 type=STRING col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=5 type=STRING col_path=[] offset=24 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[]) Tuple(id=4 size=32 slots=[Slot(id=6 type=STRING col_path=[] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=DOUBLE col_path=[] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[]) I1009 17:06:43.089022 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a2639c backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:43.089076 8487 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=64c001dc6dcd712:2562d42c35a2639c I1009 17:06:43.089083 8487 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:43.089087 8487 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a2639c I1009 17:06:43.089092 8487 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a2639c I1009 17:06:43.089100 8487 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=64c001dc6dcd712:2562d42c35a2639c node_id=8 I1009 17:06:43.089365 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a2639d backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:43.090111 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a2639e backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:43.090168 9578 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=64c001dc6dcd712:2562d42c35a2639e I1009 17:06:43.090178 9578 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:43.090181 9578 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a2639e I1009 17:06:43.090184 9578 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a2639e I1009 17:06:43.090188 9578 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=64c001dc6dcd712:2562d42c35a2639e node_id=6 I1009 17:06:43.090194 9578 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=64c001dc6dcd712:2562d42c35a2639e node_id=7 I1009 17:06:43.090260 5339 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=64c001dc6dcd712:2562d42c35a2639e, node=7 I1009 17:06:43.090265 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a2639f backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:43.090939 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a263a0 backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:43.091433 9578 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=64c001dc6dcd712:2562d42c35a263a0 I1009 17:06:43.091440 9578 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:43.091442 9578 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a263a0 I1009 17:06:43.091445 9578 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a263a0 I1009 17:06:43.091507 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a263a1 backend=host-10-17-101-153.coe.cloudera.com:22000 I1009 17:06:43.091760 23000 coordinator.cc:1483] sending CancelPlanFragment rpc for instance_id=64c001dc6dcd712:2562d42c35a263a2 backend=host-10-17-101-152.coe.cloudera.com:22000 I1009 17:06:43.091787 8487 fragment-mgr.cc:125] CancelPlanFragment(): instance_id=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:43.091804 8487 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:43.093210 5438 plan-fragment-executor.cc:310] Open(): instance_id=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:43.093230 8487 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:43.093233 8487 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:43.094005 5321 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=64c001dc6dcd712:2562d42c35a2639c, node=8 I1009 17:06:43.099720 5322 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=64c001dc6dcd712:2562d42c35a2639e, node=6 I1009 17:06:43.106788 23000 data-stream-mgr.cc:222] DeregisterRecvr(): fragment_instance_id=64c001dc6dcd712:2562d42c35a2639a, node=10 I1009 17:06:43.159597 2557 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 6, instance: 64c001dc6dcd712:2562d42c35a263a1 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:43.159610 2557 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 6, instance: 64c001dc6dcd712:2562d42c35a263a1 done: true) I1009 17:06:44.107429 5438 hdfs-scan-node.cc:226] Only following filters arrived: , waited 1s006ms I1009 17:06:44.110819 8487 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 7, instance: 64c001dc6dcd712:2562d42c35a263a2 done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:44.110829 8487 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 7, instance: 64c001dc6dcd712:2562d42c35a263a2 done: true) I1009 17:06:44.110911 5438 plan-fragment-executor.cc:544] Cancelling plan fragment... I1009 17:06:44.110915 5438 plan-fragment-executor.cc:552] Cancel(): instance_id=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:44.110920 5438 data-stream-mgr.cc:254] cancelling all streams for fragment=64c001dc6dcd712:2562d42c35a263a2 I1009 17:06:44.157320 9596 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 0, instance: 64c001dc6dcd712:2562d42c35a2639b done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:44.157337 9596 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 0, instance: 64c001dc6dcd712:2562d42c35a2639b done: true) I1009 17:06:44.159576 2554 status.cc:44] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 2, instance: 64c001dc6dcd712:2562d42c35a2639d done: true) @ 0x81183a (unknown) @ 0xa6c23d (unknown) @ 0xcaa25c (unknown) @ 0xca6a79 (unknown) @ 0x7df90c (unknown) @ 0x9b9c6f (unknown) @ 0x9b43d9 (unknown) @ 0x9b4e32 (unknown) @ 0xb92977 (unknown) @ 0xb932b4 (unknown) @ 0xdfc57a (unknown) @ 0x7f616b885aa1 start_thread @ 0x7f616a7d6aad clone I1009 17:06:44.159586 2554 impala-server.cc:1110] ReportExecStatus(): Received report for unknown query ID (probably closed or cancelled). (query_id: 64c001dc6dcd712:2562d42c35a26399, backend: 2, instance: 64c001dc6dcd712:2562d42c35a2639d done: true) I1009 17:07:43.410126 22819 authentication.cc:494] Registering impala/host-10-17-101-152.coe.cloudera.com@COE.CLOUDERA.COM, keytab file /var/run/cloudera-scm-agent/process/2521-impala-IMPALAD/impala.keytab