[jira] [Updated] (IMPALA-7685) Connect to impala database via JDBC and the connection is not closed when the query is finished

["yuxuqi (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/IMPALA-7685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

yuxuqi updated IMPALA-7685:
---------------------------
    Description: 
CDH：
h2. 查询详细信息

DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
h3. 查询信息
 * 查询 ID: *94492dca691a08fd:dc057ad200000000*
 * 用户:**
 * 数据库: *ADM_DB*
 * Coordinator: [node01|http://47.106.246.104:7180/cmf/hardware/hosts/8/status]
 * 查询类型: *DDL*
 * 查询状态: *FINISHED*
 * 开始时间: *2018-10-10 9:35:01*
 * 持续时间: *2小时，22分钟*
 * DDL 类型: *DESCRIBE_TABLE*
 * Impala 版本: *impalad version 2.12.0-cdh5.15.0 RELEASE (build 23f574543323301846b41fa5433690df32efe085)*
 * Statistics Corrupt: *false*
 * 会话 ID: *a8436493f9c60748:9ba7d78b5db3f082*
 * 会话类型: *HIVESERVER2*
 * 内存不足: *false*
 * 客户端获取等待时间: *19毫秒*
 * 客户端获取等待时间百分比: *0*
 * 文件格式:**
 * 查询状态: *OK*
 * 缺少统计数据: *false*
 * 网络地址: *172.18.230.235:52018*
 * 规划等待时间: *19毫秒*
 * 规划等待时间百分比: *0*
 * 许可结果: *Unknown*
h3. Query Timeline

 # Query submitted: *0纳秒 (0纳秒)*
 # Planning finished: *19毫秒 (19毫秒)*
 # Rows available: *30毫秒 (11毫秒)*
 # First row fetched: *49毫秒 (19毫秒)*
 1010 10:35:00.015696 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle
Unknown macro: \{ 01}
,
 02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
 04: runAsync (bool) = false,
 }
 I1010 10:35:00.015733 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle
Unknown macro: \{ 01}
,
 02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
 04: runAsync (bool) = false,
 }
 I1010 10:35:00.015977 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions
{ 01: abort_on_error (bool) = false, 02: max_errors (i32) = 100, 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) = 0, 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, 33: replica_preference (i32) = 0, 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, 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, 50: scratch_limit (i64) = -1, 51: enable_expr_rewrites (bool) = true, 52: decimal_v2 (bool) = false, 53: parquet_dictionary_filtering (bool) = true, 54: parquet_array_resolution (i32) = 2, 55: parquet_read_statistics (bool) = true, 56: default_join_distribution_mode (i32) = 0, 57: disable_codegen_rows_threshold (i32) = 50000, 58: default_spillable_buffer_size (i64) = 2097152, 59: min_spillable_buffer_size (i64) = 65536, 60: max_row_size (i64) = 524288, 61: idle_session_timeout (i32) = 0, 62: compute_stats_min_sample_size (i64) = 1073741824, 63: exec_time_limit_s (i32) = 0, }
I1010 10:35:00.016960 7925 Frontend.java:952] Analyzing query: DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
 I1010 10:35:00.017251 7925 Frontend.java:964] Analysis finished.
 I1010 10:35:00.018157 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
 01: status (struct) = TStatus
{ 01: statusCode (i32) = 0, }
,
 02: operationHandle (struct) = TOperationHandle
Unknown macro: \{ 01}
,
 }
 I1010 10:35:00.035727 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle
Unknown macro: \{ 01}
,
 02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
 04: runAsync (bool) = false,
 }
 I1010 10:35:00.035758 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle
Unknown macro: \{ 01}
,
 02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
 04: runAsync (bool) = false,
 }
 I1010 10:35:00.035972 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions
{ 01: abort_on_error (bool) = false, 02: max_errors (i32) = 100, 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) = 0, 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, 33: replica_preference (i32) = 0, 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, 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, 50: scratch_limit (i64) = -1, 51: enable_expr_rewrites (bool) = true, 52: decimal_v2 (bool) = false, 53: parquet_dictionary_filtering (bool) = true, 54: parquet_array_resolution (i32) = 2, 55: parquet_read_statistics (bool) = true, 56: default_join_distribution_mode (i32) = 0, 57: disable_codegen_rows_threshold (i32) = 50000, 58: default_spillable_buffer_size (i64) = 2097152, 59: min_spillable_buffer_size (i64) = 65536, 60: max_row_size (i64) = 524288, 61: idle_session_timeout (i32) = 0, 62: compute_stats_min_sample_size (i64) = 1073741824, 63: exec_time_limit_s (i32) = 0, }
I1010 10:35:00.036954 7925 Frontend.java:952] Analyzing query: select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
 I1010 10:35:00.037784 7925 Frontend.java:964] Analysis finished.
 I1010 10:35:00.040915 7925 admission-controller.cc:508] Schedule for id=874972c15ebbfcc3:435ee5b300000000 in pool_name=root.default cluster_mem_needed=96.00 MB PoolConfig: max_requests=-1 max_queued=200 max_mem=-1.00 B
 I1010 10:35:00.040940 7925 admission-controller.cc:513] 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)
 I1010 10:35:00.040946 7925 admission-controller.cc:529] Admitted query id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.040961 7925 coordinator.cc:99] Exec() query_id=874972c15ebbfcc3:435ee5b300000000 stmt=select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
 I1010 10:35:00.041177 7925 coordinator.cc:357] starting execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.042062 6918 impala-internal-service.cc:44] ExecQueryFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.042078 6918 query-exec-mgr.cc:46] StartQueryFInstances() query_id=874972c15ebbfcc3:435ee5b300000000 coord=node01:22000
 I1010 10:35:00.042086 6918 query-state.cc:178] Buffer pool limit for 874972c15ebbfcc3:435ee5b300000000: 1717986918
 I1010 10:35:00.042158 6918 initial-reservations.cc:60] Successfully claimed initial reservations (0) for query 874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.042580 32639 query-state.cc:309] StartFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000 #instances=2
 I1010 10:35:00.042834 32639 query-state.cc:322] descriptor table for query=874972c15ebbfcc3:435ee5b300000000
 tuples:
 Tuple(id=1 size=0 slots=[] tuple_path=[])
 Tuple(id=0 size=674 slots=[Slot(id=0 type=BIGINT col_path=[1] offset=656 null=(offset=673 mask=2) slot_idx=41 field_idx=-1), Slot(id=1 type=STRING col_path=[2] offset=0 null=(offset=668 mask=1) slot_idx=0 field_idx=-1), Slot(id=2 type=STRING col_path=[3] offset=16 null=(offset=668 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[4] offset=32 null=(offset=668 mask=4) slot_idx=2 field_idx=-1), Slot(id=4 type=STRING col_path=[5] offset=48 null=(offset=668 mask=8) slot_idx=3 field_idx=-1), Slot(id=5 type=STRING col_path=[6] offset=64 null=(offset=668 mask=10) slot_idx=4 field_idx=-1), Slot(id=6 type=STRING col_path=[7] offset=80 null=(offset=668 mask=20) slot_idx=5 field_idx=-1), Slot(id=7 type=STRING col_path=[8] offset=96 null=(offset=668 mask=40) slot_idx=6 field_idx=-1), Slot(id=8 type=STRING col_path=[9] offset=112 null=(offset=668 mask=80) slot_idx=7 field_idx=-1), Slot(id=9 type=STRING col_path=[10] offset=128 null=(offset=669 mask=1) slot_idx=8 field_idx=-1), Slot(id=10 type=STRING col_path=[11] offset=144 null=(offset=669 mask=2) slot_idx=9 field_idx=-1), Slot(id=11 type=STRING col_path=[12] offset=160 null=(offset=669 mask=4) slot_idx=10 field_idx=-1), Slot(id=12 type=STRING col_path=[13] offset=176 null=(offset=669 mask=8) slot_idx=11 field_idx=-1), Slot(id=13 type=STRING col_path=[14] offset=192 null=(offset=669 mask=10) slot_idx=12 field_idx=-1), Slot(id=14 type=STRING col_path=[15] offset=208 null=(offset=669 mask=20) slot_idx=13 field_idx=-1), Slot(id=15 type=STRING col_path=[16] offset=224 null=(offset=669 mask=40) slot_idx=14 field_idx=-1), Slot(id=16 type=STRING col_path=[17] offset=240 null=(offset=669 mask=80) slot_idx=15 field_idx=-1), Slot(id=17 type=STRING col_path=[18] offset=256 null=(offset=670 mask=1) slot_idx=16 field_idx=-1), Slot(id=18 type=STRING col_path=[19] offset=272 null=(offset=670 mask=2) slot_idx=17 field_idx=-1), Slot(id=19 type=STRING col_path=[20] offset=288 null=(offset=670 mask=4) slot_idx=18 field_idx=-1), Slot(id=20 type=STRING col_path=[21] offset=304 null=(offset=670 mask=8) slot_idx=19 field_idx=-1), Slot(id=21 type=STRING col_path=[22] offset=320 null=(offset=670 mask=10) slot_idx=20 field_idx=-1), Slot(id=22 type=STRING col_path=[23] offset=336 null=(offset=670 mask=20) slot_idx=21 field_idx=-1), Slot(id=23 type=STRING col_path=[24] offset=352 null=(offset=670 mask=40) slot_idx=22 field_idx=-1), Slot(id=24 type=STRING col_path=[25] offset=368 null=(offset=670 mask=80) slot_idx=23 field_idx=-1), Slot(id=25 type=STRING col_path=[26] offset=384 null=(offset=671 mask=1) slot_idx=24 field_idx=-1), Slot(id=26 type=STRING col_path=[27] offset=400 null=(offset=671 mask=2) slot_idx=25 field_idx=-1), Slot(id=27 type=STRING col_path=[28] offset=416 null=(offset=671 mask=4) slot_idx=26 field_idx=-1), Slot(id=28 type=STRING col_path=[29] offset=432 null=(offset=671 mask=8) slot_idx=27 field_idx=-1), Slot(id=29 type=STRING col_path=[30] offset=448 null=(offset=671 mask=10) slot_idx=28 field_idx=-1), Slot(id=30 type=STRING col_path=[31] offset=464 null=(offset=671 mask=20) slot_idx=29 field_idx=-1), Slot(id=31 type=DECIMAL(20,17) col_path=[32] offset=480 null=(offset=671 mask=40) slot_idx=30 field_idx=-1), Slot(id=32 type=DECIMAL(20,17) col_path=[33] offset=496 null=(offset=671 mask=80) slot_idx=31 field_idx=-1), Slot(id=33 type=STRING col_path=[34] offset=512 null=(offset=672 mask=1) slot_idx=32 field_idx=-1), Slot(id=34 type=STRING col_path=[35] offset=528 null=(offset=672 mask=2) slot_idx=33 field_idx=-1), Slot(id=35 type=STRING col_path=[36] offset=544 null=(offset=672 mask=4) slot_idx=34 field_idx=-1), Slot(id=36 type=STRING col_path=[37] offset=560 null=(offset=672 mask=8) slot_idx=35 field_idx=-1), Slot(id=37 type=STRING col_path=[38] offset=576 null=(offset=672 mask=10) slot_idx=36 field_idx=-1), Slot(id=38 type=INT col_path=[39] offset=664 null=(offset=673 mask=4) slot_idx=42 field_idx=-1), Slot(id=39 type=STRING col_path=[40] offset=592 null=(offset=672 mask=20) slot_idx=37 field_idx=-1), Slot(id=40 type=TIMESTAMP col_path=[41] offset=608 null=(offset=672 mask=40) slot_idx=38 field_idx=-1), Slot(id=41 type=STRING col_path=[42] offset=624 null=(offset=672 mask=80) slot_idx=39 field_idx=-1), Slot(id=42 type=STRING col_path=[0] offset=640 null=(offset=673 mask=1) slot_idx=40 field_idx=-1)] tuple_path=[])
 I1010 10:35:00.043081 32640 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000000 fragment_idx=0 per_fragment_instance_idx=0 coord_state_idx=0 #in-flight=1
 I1010 10:35:00.043423 32642 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000003 fragment_idx=1 per_fragment_instance_idx=2 coord_state_idx=0 #in-flight=2
 I1010 10:35:00.043524 32642 hdfs-scan-node.cc:160] Max row batch queue size for scan node '0' in fragment instance '874972c15ebbfcc3:435ee5b300000003': 60
 I1010 10:35:00.043931 32639 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=4
 I1010 10:35:00.049700 32642 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000003 #in-flight=1 status=OK
 I1010 10:35:00.049711 32642 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=3
 I1010 10:35:00.058981 7925 coordinator.cc:370] started execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.059780 6742 coordinator.cc:956] Backend completed: host=node02:22000 remaining=2 query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.059793 6742 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
 I1010 10:35:00.060022 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
 01: status (struct) = TStatus
{ 01: statusCode (i32) = 0, }
,
 02: operationHandle (struct) = TOperationHandle
Unknown macro: \{ 01}
,
 }
 I1010 10:35:00.063166 7925 impala-hs2-server.cc:721] GetResultSetMetadata(): query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.063527 7925 impala-hs2-server.cc:755] GetResultSetMetadata(): return_val=TGetResultSetMetadataResp {
 01: status (struct) = TStatus
{ 01: statusCode (i32) = 0, }
,
 02: schema (struct) = TTableSchema {
 01: columns (list) = list<struct>[43] {
 [0] = TColumnDesc {
 01: columnName (string) = "id",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 0,
 },
 [1] = TColumnDesc {
 01: columnName (string) = "customer_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 1,
 },
 [2] = TColumnDesc {
 01: columnName (string) = "user_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 2,
 },
 [3] = TColumnDesc {
 01: columnName (string) = "merchant_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 3,
 },
 [4] = TColumnDesc {
 01: columnName (string) = "merchant_name",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 4,
 },
 [5] = TColumnDesc {
 01: columnName (string) = "merchant_type_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 5,
 },
 [6] = TColumnDesc {
 01: columnName (string) = "merchant_type_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 6,
 },
 [7] = TColumnDesc {
 01: columnName (string) = "merchant_province_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 7,
 },
 [8] = TColumnDesc {
 01: columnName (string) = "merchant_province_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 8,
 },
 [9] = TColumnDesc {
 01: columnName (string) = "merchant_city_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 9,
 },
 [10] = TColumnDesc {
 01: columnName (string) = "merchant_city_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 10,
 },
 [11] = TColumnDesc {
 01: columnName (string) = "merchant_address_cn",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 11,
 },
 [12] = TColumnDesc {
 01: columnName (string) = "merchant_address",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 12,
 },
 [13] = TColumnDesc {
 01: columnName (string) = "merchant_telephone",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 13,
 },
 [14] = TColumnDesc {
 01: columnName (string) = "company_name",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 14,
 },
 [15] = TColumnDesc {
 01: columnName (string) = "company_type",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 15,
 },
 [16] = TColumnDesc {
 01: columnName (string) = "legal_representative",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 16,
 },
 [17] = TColumnDesc {
 01: columnName (string) = "merchant_region_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 17,
 },
 [18] = TColumnDesc {
 01: columnName (string) = "merchant_region_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 18,
 },
 [19] = TColumnDesc {
 01: columnName (string) = "address",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 19,
 },
 [20] = TColumnDesc {
 01: columnName (string) = "industry",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 20,
 },
 [21] = TColumnDesc {
 01: columnName (string) = "establish_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 21,
 },
 [22] = TColumnDesc {
 01: columnName (string) = "registration_number",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 22,
 },
 [23] = TColumnDesc {
 01: columnName (string) = "taxpayer_identification_number",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 23,
 },
 [24] = TColumnDesc {
 01: columnName (string) = "organization_code",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 24,
 },
 [25] = TColumnDesc {
 01: columnName (string) = "social_credit_code",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 25,
 },
 [26] = TColumnDesc {
 01: columnName (string) = "management_status",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 26,
 },
 [27] = TColumnDesc {
 01: columnName (string) = "business_limit",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 27,
 },
 [28] = TColumnDesc {
 01: columnName (string) = "registered_capital",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 28,
 },
 [29] = TColumnDesc {
 01: columnName (string) = "registration_authority",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 29,
 },
 [30] = TColumnDesc {
 01: columnName (string) = "create_source",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 30,
 },
 [31] = TColumnDesc {
 01: columnName (string) = "longitude",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 15,
 02: typeQualifiers (struct) = TTypeQualifiers {
 01: qualifiers (map) = map<string,struct>[2]
Unknown macro: \{ "precision" -> TTypeQualifierValue { 01: i32Value (i32) = 20, }, "scale" -> TTypeQualifierValue \{ 01: i32Value (i32) = 17, }, }
,
 },
 },
 },
 },
 },
 03: position (i32) = 31,
 },
 [32] = TColumnDesc {
 01: columnName (string) = "latitude",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 15,
 02: typeQualifiers (struct) = TTypeQualifiers {
 01: qualifiers (map) = map<string,struct>[2]
Unknown macro: \{ "precision" -> TTypeQualifierValue { 01: i32Value (i32) = 20, }, "scale" -> TTypeQualifierValue \{ 01: i32Value (i32) = 17, }, }
,
 },
 },
 },
 },
 },
 03: position (i32) = 32,
 },
 [33] = TColumnDesc {
 01: columnName (string) = "merchant_status",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 33,
 },
 [34] = TColumnDesc {
 01: columnName (string) = "settlement_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 34,
 },
 [35] = TColumnDesc {
 01: columnName (string) = "summary",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 35,
 },
 [36] = TColumnDesc {
 01: columnName (string) = "comments",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 36,
 },
 [37] = TColumnDesc {
 01: columnName (string) = "refusal_reason",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 37,
 },
 [38] = TColumnDesc {
 01: columnName (string) = "sort_id",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 38,
 },
 [39] = TColumnDesc {
 01: columnName (string) = "create_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 39,
 },
 [40] = TColumnDesc {
 01: columnName (string) = "update_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 40,
 },
 [41] = TColumnDesc {
 01: columnName (string) = "src_data",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 41,
 },
 [42] = TColumnDesc {
 01: columnName (string) = "etl_dt",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry
Unknown macro: \{ 01}
,
 },
 },
 03: position (i32) = 42,
 },
 },
 },
 }
 I1010 10:35:00.151284 22869 coordinator.cc:956] Backend completed: host=node03:22000 remaining=1 query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.151316 22869 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
 I1010 10:35:00.165092 7925 coordinator.cc:789] Coordinator waiting for backends to finish, 1 remaining. query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.165601 7925 coordinator.cc:794] All backends finished successfully. query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.165618 7925 coordinator.cc:1092] Release admission control resources for query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:00.165683 32640 krpc-data-stream-mgr.cc:293] DeregisterRecvr(): fragment_instance_id=874972c15ebbfcc3:435ee5b300000000, node=1
 I1010 10:35:00.165694 32640 krpc-data-stream-recvr.cc:557] cancelled stream: fragment_instance_id=874972c15ebbfcc3:435ee5b300000000 node_id=1
 I1010 10:35:00.165719 32640 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000000 #in-flight=0 status=OK
 I1010 10:35:00.165732 32640 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=2
 I1010 10:35:00.625356 6460 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17215 size: 63
 I1010 10:35:00.625416 6460 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17215 size: 49
 I1010 10:35:00.625473 6460 impala-server.cc:1395] Catalog topic update applied with version: 17215 new min catalog object version: 2
 I1010 10:35:02.626139 6459 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17217 size: 63
 I1010 10:35:02.626185 6459 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17217 size: 49
 I1010 10:35:02.626220 6459 impala-server.cc:1395] Catalog topic update applied with version: 17217 new min catalog object version: 2
 I1010 10:35:03.570850 7925 impala-hs2-server.cc:695] CloseOperation(): query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:03.570874 7925 impala-server.cc:1011] UnregisterQuery(): query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:03.570917 7925 impala-server.cc:1098] Cancel(): query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:03.570924 7925 coordinator.cc:896] Cancel() query_id=874972c15ebbfcc3:435ee5b300000000
 I1010 10:35:03.570930 7925 coordinator.cc:906] CancelBackends() query_id=874972c15ebbfcc3:435ee5b300000000, tried to cancel 0 backends

  was:
CDH：
h2. 查询详细信息
DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
h3. 查询信息
 * 查询 ID: *94492dca691a08fd:dc057ad200000000*
 * 用户:**
 * 数据库: *ADM_DB*
 * Coordinator: [node01|http://47.106.246.104:7180/cmf/hardware/hosts/8/status]
 * 查询类型: *DDL*
 * 查询状态: *FINISHED*
 * 开始时间: *2018-10-10 9:35:01*
 * 持续时间: *2小时，22分钟*
 * DDL 类型: *DESCRIBE_TABLE*
 * Impala 版本: *impalad version 2.12.0-cdh5.15.0 RELEASE (build 23f574543323301846b41fa5433690df32efe085)*
 * Statistics Corrupt: *false*
 * 会话 ID: *a8436493f9c60748:9ba7d78b5db3f082*
 * 会话类型: *HIVESERVER2*
 * 内存不足: *false*
 * 客户端获取等待时间: *19毫秒*
 * 客户端获取等待时间百分比: *0*
 * 文件格式:**
 * 查询状态: *OK*
 * 缺少统计数据: *false*
 * 网络地址: *172.18.230.235:52018*
 * 规划等待时间: *19毫秒*
 * 规划等待时间百分比: *0*
 * 许可结果: *Unknown*
h3. Query Timeline
 # Query submitted: *0纳秒 (0纳秒)*
 # Planning finished: *19毫秒 (19毫秒)*
 # Rows available: *30毫秒 (11毫秒)*
 # First row fetched: *49毫秒 (19毫秒)*
1010 10:35:00.015696 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle {
 01: sessionId (struct) = THandleIdentifier {
 01: guid (string) = "H\a\xc6\xf9\x93dC\xa8\x82\xf0\xb3]\x8b\xd7\xa7\x9b",
 02: secret (string) = "it\xce\xe8\xe5AM+\xad\x10p;\x7f\xb20\xe6",
 },
 },
 02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
 04: runAsync (bool) = false,
}
I1010 10:35:00.015733 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle {
 01: sessionId (struct) = THandleIdentifier {
 01: guid (string) = "H\a\xc6\xf9\x93dC\xa8\x82\xf0\xb3]\x8b\xd7\xa7\x9b",
 02: secret (string) = "it\xce\xe8\xe5AM+\xad\x10p;\x7f\xb20\xe6",
 },
 },
 02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
 04: runAsync (bool) = false,
}
I1010 10:35:00.015977 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions {
 01: abort_on_error (bool) = false,
 02: max_errors (i32) = 100,
 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) = 0,
 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,
 33: replica_preference (i32) = 0,
 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,
 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,
 50: scratch_limit (i64) = -1,
 51: enable_expr_rewrites (bool) = true,
 52: decimal_v2 (bool) = false,
 53: parquet_dictionary_filtering (bool) = true,
 54: parquet_array_resolution (i32) = 2,
 55: parquet_read_statistics (bool) = true,
 56: default_join_distribution_mode (i32) = 0,
 57: disable_codegen_rows_threshold (i32) = 50000,
 58: default_spillable_buffer_size (i64) = 2097152,
 59: min_spillable_buffer_size (i64) = 65536,
 60: max_row_size (i64) = 524288,
 61: idle_session_timeout (i32) = 0,
 62: compute_stats_min_sample_size (i64) = 1073741824,
 63: exec_time_limit_s (i32) = 0,
}
I1010 10:35:00.016960 7925 Frontend.java:952] Analyzing query: DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
I1010 10:35:00.017251 7925 Frontend.java:964] Analysis finished.
I1010 10:35:00.018157 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
 01: status (struct) = TStatus {
 01: statusCode (i32) = 0,
 },
 02: operationHandle (struct) = TOperationHandle {
 01: operationId (struct) = THandleIdentifier {
 01: guid (string) = "\"\x81\xa2\r\xba-L\xfd\x00\x00\x00\x00\x13\x82\xa0\f",
 02: secret (string) = "\"\x81\xa2\r\xba-L\xfd\x00\x00\x00\x00\x13\x82\xa0\f",
 },
 02: operationType (i32) = 0,
 03: hasResultSet (bool) = true,
 },
}
I1010 10:35:00.035727 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle {
 01: sessionId (struct) = THandleIdentifier {
 01: guid (string) = "H\a\xc6\xf9\x93dC\xa8\x82\xf0\xb3]\x8b\xd7\xa7\x9b",
 02: secret (string) = "it\xce\xe8\xe5AM+\xad\x10p;\x7f\xb20\xe6",
 },
 },
 02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
 04: runAsync (bool) = false,
}
I1010 10:35:00.035758 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
 01: sessionHandle (struct) = TSessionHandle {
 01: sessionId (struct) = THandleIdentifier {
 01: guid (string) = "H\a\xc6\xf9\x93dC\xa8\x82\xf0\xb3]\x8b\xd7\xa7\x9b",
 02: secret (string) = "it\xce\xe8\xe5AM+\xad\x10p;\x7f\xb20\xe6",
 },
 },
 02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
 04: runAsync (bool) = false,
}
I1010 10:35:00.035972 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions {
 01: abort_on_error (bool) = false,
 02: max_errors (i32) = 100,
 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) = 0,
 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,
 33: replica_preference (i32) = 0,
 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,
 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,
 50: scratch_limit (i64) = -1,
 51: enable_expr_rewrites (bool) = true,
 52: decimal_v2 (bool) = false,
 53: parquet_dictionary_filtering (bool) = true,
 54: parquet_array_resolution (i32) = 2,
 55: parquet_read_statistics (bool) = true,
 56: default_join_distribution_mode (i32) = 0,
 57: disable_codegen_rows_threshold (i32) = 50000,
 58: default_spillable_buffer_size (i64) = 2097152,
 59: min_spillable_buffer_size (i64) = 65536,
 60: max_row_size (i64) = 524288,
 61: idle_session_timeout (i32) = 0,
 62: compute_stats_min_sample_size (i64) = 1073741824,
 63: exec_time_limit_s (i32) = 0,
}
I1010 10:35:00.036954 7925 Frontend.java:952] Analyzing query: select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
I1010 10:35:00.037784 7925 Frontend.java:964] Analysis finished.
I1010 10:35:00.040915 7925 admission-controller.cc:508] Schedule for id=874972c15ebbfcc3:435ee5b300000000 in pool_name=root.default cluster_mem_needed=96.00 MB PoolConfig: max_requests=-1 max_queued=200 max_mem=-1.00 B
I1010 10:35:00.040940 7925 admission-controller.cc:513] 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)
I1010 10:35:00.040946 7925 admission-controller.cc:529] Admitted query id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.040961 7925 coordinator.cc:99] Exec() query_id=874972c15ebbfcc3:435ee5b300000000 stmt=select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
I1010 10:35:00.041177 7925 coordinator.cc:357] starting execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.042062 6918 impala-internal-service.cc:44] ExecQueryFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.042078 6918 query-exec-mgr.cc:46] StartQueryFInstances() query_id=874972c15ebbfcc3:435ee5b300000000 coord=node01:22000
I1010 10:35:00.042086 6918 query-state.cc:178] Buffer pool limit for 874972c15ebbfcc3:435ee5b300000000: 1717986918
I1010 10:35:00.042158 6918 initial-reservations.cc:60] Successfully claimed initial reservations (0) for query 874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.042580 32639 query-state.cc:309] StartFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000 #instances=2
I1010 10:35:00.042834 32639 query-state.cc:322] descriptor table for query=874972c15ebbfcc3:435ee5b300000000
tuples:
Tuple(id=1 size=0 slots=[] tuple_path=[])
Tuple(id=0 size=674 slots=[Slot(id=0 type=BIGINT col_path=[1] offset=656 null=(offset=673 mask=2) slot_idx=41 field_idx=-1), Slot(id=1 type=STRING col_path=[2] offset=0 null=(offset=668 mask=1) slot_idx=0 field_idx=-1), Slot(id=2 type=STRING col_path=[3] offset=16 null=(offset=668 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[4] offset=32 null=(offset=668 mask=4) slot_idx=2 field_idx=-1), Slot(id=4 type=STRING col_path=[5] offset=48 null=(offset=668 mask=8) slot_idx=3 field_idx=-1), Slot(id=5 type=STRING col_path=[6] offset=64 null=(offset=668 mask=10) slot_idx=4 field_idx=-1), Slot(id=6 type=STRING col_path=[7] offset=80 null=(offset=668 mask=20) slot_idx=5 field_idx=-1), Slot(id=7 type=STRING col_path=[8] offset=96 null=(offset=668 mask=40) slot_idx=6 field_idx=-1), Slot(id=8 type=STRING col_path=[9] offset=112 null=(offset=668 mask=80) slot_idx=7 field_idx=-1), Slot(id=9 type=STRING col_path=[10] offset=128 null=(offset=669 mask=1) slot_idx=8 field_idx=-1), Slot(id=10 type=STRING col_path=[11] offset=144 null=(offset=669 mask=2) slot_idx=9 field_idx=-1), Slot(id=11 type=STRING col_path=[12] offset=160 null=(offset=669 mask=4) slot_idx=10 field_idx=-1), Slot(id=12 type=STRING col_path=[13] offset=176 null=(offset=669 mask=8) slot_idx=11 field_idx=-1), Slot(id=13 type=STRING col_path=[14] offset=192 null=(offset=669 mask=10) slot_idx=12 field_idx=-1), Slot(id=14 type=STRING col_path=[15] offset=208 null=(offset=669 mask=20) slot_idx=13 field_idx=-1), Slot(id=15 type=STRING col_path=[16] offset=224 null=(offset=669 mask=40) slot_idx=14 field_idx=-1), Slot(id=16 type=STRING col_path=[17] offset=240 null=(offset=669 mask=80) slot_idx=15 field_idx=-1), Slot(id=17 type=STRING col_path=[18] offset=256 null=(offset=670 mask=1) slot_idx=16 field_idx=-1), Slot(id=18 type=STRING col_path=[19] offset=272 null=(offset=670 mask=2) slot_idx=17 field_idx=-1), Slot(id=19 type=STRING col_path=[20] offset=288 null=(offset=670 mask=4) slot_idx=18 field_idx=-1), Slot(id=20 type=STRING col_path=[21] offset=304 null=(offset=670 mask=8) slot_idx=19 field_idx=-1), Slot(id=21 type=STRING col_path=[22] offset=320 null=(offset=670 mask=10) slot_idx=20 field_idx=-1), Slot(id=22 type=STRING col_path=[23] offset=336 null=(offset=670 mask=20) slot_idx=21 field_idx=-1), Slot(id=23 type=STRING col_path=[24] offset=352 null=(offset=670 mask=40) slot_idx=22 field_idx=-1), Slot(id=24 type=STRING col_path=[25] offset=368 null=(offset=670 mask=80) slot_idx=23 field_idx=-1), Slot(id=25 type=STRING col_path=[26] offset=384 null=(offset=671 mask=1) slot_idx=24 field_idx=-1), Slot(id=26 type=STRING col_path=[27] offset=400 null=(offset=671 mask=2) slot_idx=25 field_idx=-1), Slot(id=27 type=STRING col_path=[28] offset=416 null=(offset=671 mask=4) slot_idx=26 field_idx=-1), Slot(id=28 type=STRING col_path=[29] offset=432 null=(offset=671 mask=8) slot_idx=27 field_idx=-1), Slot(id=29 type=STRING col_path=[30] offset=448 null=(offset=671 mask=10) slot_idx=28 field_idx=-1), Slot(id=30 type=STRING col_path=[31] offset=464 null=(offset=671 mask=20) slot_idx=29 field_idx=-1), Slot(id=31 type=DECIMAL(20,17) col_path=[32] offset=480 null=(offset=671 mask=40) slot_idx=30 field_idx=-1), Slot(id=32 type=DECIMAL(20,17) col_path=[33] offset=496 null=(offset=671 mask=80) slot_idx=31 field_idx=-1), Slot(id=33 type=STRING col_path=[34] offset=512 null=(offset=672 mask=1) slot_idx=32 field_idx=-1), Slot(id=34 type=STRING col_path=[35] offset=528 null=(offset=672 mask=2) slot_idx=33 field_idx=-1), Slot(id=35 type=STRING col_path=[36] offset=544 null=(offset=672 mask=4) slot_idx=34 field_idx=-1), Slot(id=36 type=STRING col_path=[37] offset=560 null=(offset=672 mask=8) slot_idx=35 field_idx=-1), Slot(id=37 type=STRING col_path=[38] offset=576 null=(offset=672 mask=10) slot_idx=36 field_idx=-1), Slot(id=38 type=INT col_path=[39] offset=664 null=(offset=673 mask=4) slot_idx=42 field_idx=-1), Slot(id=39 type=STRING col_path=[40] offset=592 null=(offset=672 mask=20) slot_idx=37 field_idx=-1), Slot(id=40 type=TIMESTAMP col_path=[41] offset=608 null=(offset=672 mask=40) slot_idx=38 field_idx=-1), Slot(id=41 type=STRING col_path=[42] offset=624 null=(offset=672 mask=80) slot_idx=39 field_idx=-1), Slot(id=42 type=STRING col_path=[0] offset=640 null=(offset=673 mask=1) slot_idx=40 field_idx=-1)] tuple_path=[])
I1010 10:35:00.043081 32640 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000000 fragment_idx=0 per_fragment_instance_idx=0 coord_state_idx=0 #in-flight=1
I1010 10:35:00.043423 32642 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000003 fragment_idx=1 per_fragment_instance_idx=2 coord_state_idx=0 #in-flight=2
I1010 10:35:00.043524 32642 hdfs-scan-node.cc:160] Max row batch queue size for scan node '0' in fragment instance '874972c15ebbfcc3:435ee5b300000003': 60
I1010 10:35:00.043931 32639 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=4
I1010 10:35:00.049700 32642 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000003 #in-flight=1 status=OK
I1010 10:35:00.049711 32642 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=3
I1010 10:35:00.058981 7925 coordinator.cc:370] started execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.059780 6742 coordinator.cc:956] Backend completed: host=node02:22000 remaining=2 query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.059793 6742 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
I1010 10:35:00.060022 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
 01: status (struct) = TStatus {
 01: statusCode (i32) = 0,
 },
 02: operationHandle (struct) = TOperationHandle {
 01: operationId (struct) = THandleIdentifier {
 01: guid (string) = "\xc3\xfc\xbb^\xc1rI\x87\x00\x00\x00\x00\xb3\xe5^C",
 02: secret (string) = "\xc3\xfc\xbb^\xc1rI\x87\x00\x00\x00\x00\xb3\xe5^C",
 },
 02: operationType (i32) = 0,
 03: hasResultSet (bool) = true,
 },
}
I1010 10:35:00.063166 7925 impala-hs2-server.cc:721] GetResultSetMetadata(): query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.063527 7925 impala-hs2-server.cc:755] GetResultSetMetadata(): return_val=TGetResultSetMetadataResp {
 01: status (struct) = TStatus {
 01: statusCode (i32) = 0,
 },
 02: schema (struct) = TTableSchema {
 01: columns (list) = list<struct>[43] {
 [0] = TColumnDesc {
 01: columnName (string) = "id",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 4,
 },
 },
 },
 },
 03: position (i32) = 0,
 },
 [1] = TColumnDesc {
 01: columnName (string) = "customer_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 1,
 },
 [2] = TColumnDesc {
 01: columnName (string) = "user_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 2,
 },
 [3] = TColumnDesc {
 01: columnName (string) = "merchant_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 3,
 },
 [4] = TColumnDesc {
 01: columnName (string) = "merchant_name",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 4,
 },
 [5] = TColumnDesc {
 01: columnName (string) = "merchant_type_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 5,
 },
 [6] = TColumnDesc {
 01: columnName (string) = "merchant_type_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 6,
 },
 [7] = TColumnDesc {
 01: columnName (string) = "merchant_province_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 7,
 },
 [8] = TColumnDesc {
 01: columnName (string) = "merchant_province_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 8,
 },
 [9] = TColumnDesc {
 01: columnName (string) = "merchant_city_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 9,
 },
 [10] = TColumnDesc {
 01: columnName (string) = "merchant_city_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 10,
 },
 [11] = TColumnDesc {
 01: columnName (string) = "merchant_address_cn",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 11,
 },
 [12] = TColumnDesc {
 01: columnName (string) = "merchant_address",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 12,
 },
 [13] = TColumnDesc {
 01: columnName (string) = "merchant_telephone",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 13,
 },
 [14] = TColumnDesc {
 01: columnName (string) = "company_name",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 14,
 },
 [15] = TColumnDesc {
 01: columnName (string) = "company_type",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 15,
 },
 [16] = TColumnDesc {
 01: columnName (string) = "legal_representative",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 16,
 },
 [17] = TColumnDesc {
 01: columnName (string) = "merchant_region_cd",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 17,
 },
 [18] = TColumnDesc {
 01: columnName (string) = "merchant_region_mc",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 18,
 },
 [19] = TColumnDesc {
 01: columnName (string) = "address",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 19,
 },
 [20] = TColumnDesc {
 01: columnName (string) = "industry",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 20,
 },
 [21] = TColumnDesc {
 01: columnName (string) = "establish_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 21,
 },
 [22] = TColumnDesc {
 01: columnName (string) = "registration_number",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 22,
 },
 [23] = TColumnDesc {
 01: columnName (string) = "taxpayer_identification_number",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 23,
 },
 [24] = TColumnDesc {
 01: columnName (string) = "organization_code",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 24,
 },
 [25] = TColumnDesc {
 01: columnName (string) = "social_credit_code",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 25,
 },
 [26] = TColumnDesc {
 01: columnName (string) = "management_status",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 26,
 },
 [27] = TColumnDesc {
 01: columnName (string) = "business_limit",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 27,
 },
 [28] = TColumnDesc {
 01: columnName (string) = "registered_capital",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 28,
 },
 [29] = TColumnDesc {
 01: columnName (string) = "registration_authority",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 29,
 },
 [30] = TColumnDesc {
 01: columnName (string) = "create_source",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 30,
 },
 [31] = TColumnDesc {
 01: columnName (string) = "longitude",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 15,
 02: typeQualifiers (struct) = TTypeQualifiers {
 01: qualifiers (map) = map<string,struct>[2] {
 "precision" -> TTypeQualifierValue {
 01: i32Value (i32) = 20,
 },
 "scale" -> TTypeQualifierValue {
 01: i32Value (i32) = 17,
 },
 },
 },
 },
 },
 },
 },
 03: position (i32) = 31,
 },
 [32] = TColumnDesc {
 01: columnName (string) = "latitude",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 15,
 02: typeQualifiers (struct) = TTypeQualifiers {
 01: qualifiers (map) = map<string,struct>[2] {
 "precision" -> TTypeQualifierValue {
 01: i32Value (i32) = 20,
 },
 "scale" -> TTypeQualifierValue {
 01: i32Value (i32) = 17,
 },
 },
 },
 },
 },
 },
 },
 03: position (i32) = 32,
 },
 [33] = TColumnDesc {
 01: columnName (string) = "merchant_status",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 33,
 },
 [34] = TColumnDesc {
 01: columnName (string) = "settlement_no",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 34,
 },
 [35] = TColumnDesc {
 01: columnName (string) = "summary",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 35,
 },
 [36] = TColumnDesc {
 01: columnName (string) = "comments",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 36,
 },
 [37] = TColumnDesc {
 01: columnName (string) = "refusal_reason",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 37,
 },
 [38] = TColumnDesc {
 01: columnName (string) = "sort_id",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 3,
 },
 },
 },
 },
 03: position (i32) = 38,
 },
 [39] = TColumnDesc {
 01: columnName (string) = "create_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 39,
 },
 [40] = TColumnDesc {
 01: columnName (string) = "update_date",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 8,
 },
 },
 },
 },
 03: position (i32) = 40,
 },
 [41] = TColumnDesc {
 01: columnName (string) = "src_data",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 41,
 },
 [42] = TColumnDesc {
 01: columnName (string) = "etl_dt",
 02: typeDesc (struct) = TTypeDesc {
 01: types (list) = list<struct>[1] {
 [0] = TTypeEntry {
 01: primitiveEntry (struct) = TPrimitiveTypeEntry {
 01: type (i32) = 7,
 },
 },
 },
 },
 03: position (i32) = 42,
 },
 },
 },
}
I1010 10:35:00.151284 22869 coordinator.cc:956] Backend completed: host=node03:22000 remaining=1 query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.151316 22869 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
I1010 10:35:00.165092 7925 coordinator.cc:789] Coordinator waiting for backends to finish, 1 remaining. query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.165601 7925 coordinator.cc:794] All backends finished successfully. query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.165618 7925 coordinator.cc:1092] Release admission control resources for query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:00.165683 32640 krpc-data-stream-mgr.cc:293] DeregisterRecvr(): fragment_instance_id=874972c15ebbfcc3:435ee5b300000000, node=1
I1010 10:35:00.165694 32640 krpc-data-stream-recvr.cc:557] cancelled stream: fragment_instance_id=874972c15ebbfcc3:435ee5b300000000 node_id=1
I1010 10:35:00.165719 32640 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000000 #in-flight=0 status=OK
I1010 10:35:00.165732 32640 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=2
I1010 10:35:00.625356 6460 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17215 size: 63
I1010 10:35:00.625416 6460 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17215 size: 49
I1010 10:35:00.625473 6460 impala-server.cc:1395] Catalog topic update applied with version: 17215 new min catalog object version: 2
I1010 10:35:02.626139 6459 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17217 size: 63
I1010 10:35:02.626185 6459 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17217 size: 49
I1010 10:35:02.626220 6459 impala-server.cc:1395] Catalog topic update applied with version: 17217 new min catalog object version: 2
I1010 10:35:03.570850 7925 impala-hs2-server.cc:695] CloseOperation(): query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:03.570874 7925 impala-server.cc:1011] UnregisterQuery(): query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:03.570917 7925 impala-server.cc:1098] Cancel(): query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:03.570924 7925 coordinator.cc:896] Cancel() query_id=874972c15ebbfcc3:435ee5b300000000
I1010 10:35:03.570930 7925 coordinator.cc:906] CancelBackends() query_id=874972c15ebbfcc3:435ee5b300000000, tried to cancel 0 backends


> Connect to impala database via JDBC and the connection is not closed when the query is finished
> -----------------------------------------------------------------------------------------------
>
>                 Key: IMPALA-7685
>                 URL: https://issues.apache.org/jira/browse/IMPALA-7685
>             Project: IMPALA
>          Issue Type: Bug
>    Affects Versions: Impala 2.12.0
>            Reporter: yuxuqi
>            Priority: Major
>
> CDH：
> h2. 查询详细信息
> DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
> h3. 查询信息
>  * 查询 ID: *94492dca691a08fd:dc057ad200000000*
>  * 用户:**
>  * 数据库: *ADM_DB*
>  * Coordinator: [node01|http://47.106.246.104:7180/cmf/hardware/hosts/8/status]
>  * 查询类型: *DDL*
>  * 查询状态: *FINISHED*
>  * 开始时间: *2018-10-10 9:35:01*
>  * 持续时间: *2小时，22分钟*
>  * DDL 类型: *DESCRIBE_TABLE*
>  * Impala 版本: *impalad version 2.12.0-cdh5.15.0 RELEASE (build 23f574543323301846b41fa5433690df32efe085)*
>  * Statistics Corrupt: *false*
>  * 会话 ID: *a8436493f9c60748:9ba7d78b5db3f082*
>  * 会话类型: *HIVESERVER2*
>  * 内存不足: *false*
>  * 客户端获取等待时间: *19毫秒*
>  * 客户端获取等待时间百分比: *0*
>  * 文件格式:**
>  * 查询状态: *OK*
>  * 缺少统计数据: *false*
>  * 网络地址: *172.18.230.235:52018*
>  * 规划等待时间: *19毫秒*
>  * 规划等待时间百分比: *0*
>  * 许可结果: *Unknown*
> h3. Query Timeline
>  # Query submitted: *0纳秒 (0纳秒)*
>  # Planning finished: *19毫秒 (19毫秒)*
>  # Rows available: *30毫秒 (11毫秒)*
>  # First row fetched: *49毫秒 (19毫秒)*
>  1010 10:35:00.015696 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
>  01: sessionHandle (struct) = TSessionHandle
> Unknown macro: \{ 01}
> ,
>  02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
>  04: runAsync (bool) = false,
>  }
>  I1010 10:35:00.015733 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
>  01: sessionHandle (struct) = TSessionHandle
> Unknown macro: \{ 01}
> ,
>  02: statement (string) = "DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO",
>  04: runAsync (bool) = false,
>  }
>  I1010 10:35:00.015977 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions
> { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 100, 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) = 0, 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, 33: replica_preference (i32) = 0, 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, 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, 50: scratch_limit (i64) = -1, 51: enable_expr_rewrites (bool) = true, 52: decimal_v2 (bool) = false, 53: parquet_dictionary_filtering (bool) = true, 54: parquet_array_resolution (i32) = 2, 55: parquet_read_statistics (bool) = true, 56: default_join_distribution_mode (i32) = 0, 57: disable_codegen_rows_threshold (i32) = 50000, 58: default_spillable_buffer_size (i64) = 2097152, 59: min_spillable_buffer_size (i64) = 65536, 60: max_row_size (i64) = 524288, 61: idle_session_timeout (i32) = 0, 62: compute_stats_min_sample_size (i64) = 1073741824, 63: exec_time_limit_s (i32) = 0, }
> I1010 10:35:00.016960 7925 Frontend.java:952] Analyzing query: DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO
>  I1010 10:35:00.017251 7925 Frontend.java:964] Analysis finished.
>  I1010 10:35:00.018157 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
>  01: status (struct) = TStatus
> { 01: statusCode (i32) = 0, }
> ,
>  02: operationHandle (struct) = TOperationHandle
> Unknown macro: \{ 01}
> ,
>  }
>  I1010 10:35:00.035727 7925 impala-hs2-server.cc:418] ExecuteStatement(): request=TExecuteStatementReq {
>  01: sessionHandle (struct) = TSessionHandle
> Unknown macro: \{ 01}
> ,
>  02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
>  04: runAsync (bool) = false,
>  }
>  I1010 10:35:00.035758 7925 impala-hs2-server.cc:234] TExecuteStatementReq: TExecuteStatementReq {
>  01: sessionHandle (struct) = TSessionHandle
> Unknown macro: \{ 01}
> ,
>  02: statement (string) = "select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'",
>  04: runAsync (bool) = false,
>  }
>  I1010 10:35:00.035972 7925 impala-hs2-server.cc:271] TClientRequest.queryOptions: TQueryOptions
> { 01: abort_on_error (bool) = false, 02: max_errors (i32) = 100, 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) = 0, 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, 33: replica_preference (i32) = 0, 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, 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, 50: scratch_limit (i64) = -1, 51: enable_expr_rewrites (bool) = true, 52: decimal_v2 (bool) = false, 53: parquet_dictionary_filtering (bool) = true, 54: parquet_array_resolution (i32) = 2, 55: parquet_read_statistics (bool) = true, 56: default_join_distribution_mode (i32) = 0, 57: disable_codegen_rows_threshold (i32) = 50000, 58: default_spillable_buffer_size (i64) = 2097152, 59: min_spillable_buffer_size (i64) = 65536, 60: max_row_size (i64) = 524288, 61: idle_session_timeout (i32) = 0, 62: compute_stats_min_sample_size (i64) = 1073741824, 63: exec_time_limit_s (i32) = 0, }
> I1010 10:35:00.036954 7925 Frontend.java:952] Analyzing query: select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
>  I1010 10:35:00.037784 7925 Frontend.java:964] Analysis finished.
>  I1010 10:35:00.040915 7925 admission-controller.cc:508] Schedule for id=874972c15ebbfcc3:435ee5b300000000 in pool_name=root.default cluster_mem_needed=96.00 MB PoolConfig: max_requests=-1 max_queued=200 max_mem=-1.00 B
>  I1010 10:35:00.040940 7925 admission-controller.cc:513] 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)
>  I1010 10:35:00.040946 7925 admission-controller.cc:529] Admitted query id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.040961 7925 coordinator.cc:99] Exec() query_id=874972c15ebbfcc3:435ee5b300000000 stmt=select * from FDM_DB.F_T_MERCHANT_BASE_INFO where ETL_DT='2018-10-10'
>  I1010 10:35:00.041177 7925 coordinator.cc:357] starting execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.042062 6918 impala-internal-service.cc:44] ExecQueryFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.042078 6918 query-exec-mgr.cc:46] StartQueryFInstances() query_id=874972c15ebbfcc3:435ee5b300000000 coord=node01:22000
>  I1010 10:35:00.042086 6918 query-state.cc:178] Buffer pool limit for 874972c15ebbfcc3:435ee5b300000000: 1717986918
>  I1010 10:35:00.042158 6918 initial-reservations.cc:60] Successfully claimed initial reservations (0) for query 874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.042580 32639 query-state.cc:309] StartFInstances(): query_id=874972c15ebbfcc3:435ee5b300000000 #instances=2
>  I1010 10:35:00.042834 32639 query-state.cc:322] descriptor table for query=874972c15ebbfcc3:435ee5b300000000
>  tuples:
>  Tuple(id=1 size=0 slots=[] tuple_path=[])
>  Tuple(id=0 size=674 slots=[Slot(id=0 type=BIGINT col_path=[1] offset=656 null=(offset=673 mask=2) slot_idx=41 field_idx=-1), Slot(id=1 type=STRING col_path=[2] offset=0 null=(offset=668 mask=1) slot_idx=0 field_idx=-1), Slot(id=2 type=STRING col_path=[3] offset=16 null=(offset=668 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[4] offset=32 null=(offset=668 mask=4) slot_idx=2 field_idx=-1), Slot(id=4 type=STRING col_path=[5] offset=48 null=(offset=668 mask=8) slot_idx=3 field_idx=-1), Slot(id=5 type=STRING col_path=[6] offset=64 null=(offset=668 mask=10) slot_idx=4 field_idx=-1), Slot(id=6 type=STRING col_path=[7] offset=80 null=(offset=668 mask=20) slot_idx=5 field_idx=-1), Slot(id=7 type=STRING col_path=[8] offset=96 null=(offset=668 mask=40) slot_idx=6 field_idx=-1), Slot(id=8 type=STRING col_path=[9] offset=112 null=(offset=668 mask=80) slot_idx=7 field_idx=-1), Slot(id=9 type=STRING col_path=[10] offset=128 null=(offset=669 mask=1) slot_idx=8 field_idx=-1), Slot(id=10 type=STRING col_path=[11] offset=144 null=(offset=669 mask=2) slot_idx=9 field_idx=-1), Slot(id=11 type=STRING col_path=[12] offset=160 null=(offset=669 mask=4) slot_idx=10 field_idx=-1), Slot(id=12 type=STRING col_path=[13] offset=176 null=(offset=669 mask=8) slot_idx=11 field_idx=-1), Slot(id=13 type=STRING col_path=[14] offset=192 null=(offset=669 mask=10) slot_idx=12 field_idx=-1), Slot(id=14 type=STRING col_path=[15] offset=208 null=(offset=669 mask=20) slot_idx=13 field_idx=-1), Slot(id=15 type=STRING col_path=[16] offset=224 null=(offset=669 mask=40) slot_idx=14 field_idx=-1), Slot(id=16 type=STRING col_path=[17] offset=240 null=(offset=669 mask=80) slot_idx=15 field_idx=-1), Slot(id=17 type=STRING col_path=[18] offset=256 null=(offset=670 mask=1) slot_idx=16 field_idx=-1), Slot(id=18 type=STRING col_path=[19] offset=272 null=(offset=670 mask=2) slot_idx=17 field_idx=-1), Slot(id=19 type=STRING col_path=[20] offset=288 null=(offset=670 mask=4) slot_idx=18 field_idx=-1), Slot(id=20 type=STRING col_path=[21] offset=304 null=(offset=670 mask=8) slot_idx=19 field_idx=-1), Slot(id=21 type=STRING col_path=[22] offset=320 null=(offset=670 mask=10) slot_idx=20 field_idx=-1), Slot(id=22 type=STRING col_path=[23] offset=336 null=(offset=670 mask=20) slot_idx=21 field_idx=-1), Slot(id=23 type=STRING col_path=[24] offset=352 null=(offset=670 mask=40) slot_idx=22 field_idx=-1), Slot(id=24 type=STRING col_path=[25] offset=368 null=(offset=670 mask=80) slot_idx=23 field_idx=-1), Slot(id=25 type=STRING col_path=[26] offset=384 null=(offset=671 mask=1) slot_idx=24 field_idx=-1), Slot(id=26 type=STRING col_path=[27] offset=400 null=(offset=671 mask=2) slot_idx=25 field_idx=-1), Slot(id=27 type=STRING col_path=[28] offset=416 null=(offset=671 mask=4) slot_idx=26 field_idx=-1), Slot(id=28 type=STRING col_path=[29] offset=432 null=(offset=671 mask=8) slot_idx=27 field_idx=-1), Slot(id=29 type=STRING col_path=[30] offset=448 null=(offset=671 mask=10) slot_idx=28 field_idx=-1), Slot(id=30 type=STRING col_path=[31] offset=464 null=(offset=671 mask=20) slot_idx=29 field_idx=-1), Slot(id=31 type=DECIMAL(20,17) col_path=[32] offset=480 null=(offset=671 mask=40) slot_idx=30 field_idx=-1), Slot(id=32 type=DECIMAL(20,17) col_path=[33] offset=496 null=(offset=671 mask=80) slot_idx=31 field_idx=-1), Slot(id=33 type=STRING col_path=[34] offset=512 null=(offset=672 mask=1) slot_idx=32 field_idx=-1), Slot(id=34 type=STRING col_path=[35] offset=528 null=(offset=672 mask=2) slot_idx=33 field_idx=-1), Slot(id=35 type=STRING col_path=[36] offset=544 null=(offset=672 mask=4) slot_idx=34 field_idx=-1), Slot(id=36 type=STRING col_path=[37] offset=560 null=(offset=672 mask=8) slot_idx=35 field_idx=-1), Slot(id=37 type=STRING col_path=[38] offset=576 null=(offset=672 mask=10) slot_idx=36 field_idx=-1), Slot(id=38 type=INT col_path=[39] offset=664 null=(offset=673 mask=4) slot_idx=42 field_idx=-1), Slot(id=39 type=STRING col_path=[40] offset=592 null=(offset=672 mask=20) slot_idx=37 field_idx=-1), Slot(id=40 type=TIMESTAMP col_path=[41] offset=608 null=(offset=672 mask=40) slot_idx=38 field_idx=-1), Slot(id=41 type=STRING col_path=[42] offset=624 null=(offset=672 mask=80) slot_idx=39 field_idx=-1), Slot(id=42 type=STRING col_path=[0] offset=640 null=(offset=673 mask=1) slot_idx=40 field_idx=-1)] tuple_path=[])
>  I1010 10:35:00.043081 32640 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000000 fragment_idx=0 per_fragment_instance_idx=0 coord_state_idx=0 #in-flight=1
>  I1010 10:35:00.043423 32642 query-state.cc:404] Executing instance. instance_id=874972c15ebbfcc3:435ee5b300000003 fragment_idx=1 per_fragment_instance_idx=2 coord_state_idx=0 #in-flight=2
>  I1010 10:35:00.043524 32642 hdfs-scan-node.cc:160] Max row batch queue size for scan node '0' in fragment instance '874972c15ebbfcc3:435ee5b300000003': 60
>  I1010 10:35:00.043931 32639 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=4
>  I1010 10:35:00.049700 32642 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000003 #in-flight=1 status=OK
>  I1010 10:35:00.049711 32642 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=3
>  I1010 10:35:00.058981 7925 coordinator.cc:370] started execution on 3 backends for query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.059780 6742 coordinator.cc:956] Backend completed: host=node02:22000 remaining=2 query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.059793 6742 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
>  I1010 10:35:00.060022 7925 impala-hs2-server.cc:486] ExecuteStatement(): return_val=TExecuteStatementResp {
>  01: status (struct) = TStatus
> { 01: statusCode (i32) = 0, }
> ,
>  02: operationHandle (struct) = TOperationHandle
> Unknown macro: \{ 01}
> ,
>  }
>  I1010 10:35:00.063166 7925 impala-hs2-server.cc:721] GetResultSetMetadata(): query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.063527 7925 impala-hs2-server.cc:755] GetResultSetMetadata(): return_val=TGetResultSetMetadataResp {
>  01: status (struct) = TStatus
> { 01: statusCode (i32) = 0, }
> ,
>  02: schema (struct) = TTableSchema {
>  01: columns (list) = list<struct>[43] {
>  [0] = TColumnDesc {
>  01: columnName (string) = "id",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 0,
>  },
>  [1] = TColumnDesc {
>  01: columnName (string) = "customer_no",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 1,
>  },
>  [2] = TColumnDesc {
>  01: columnName (string) = "user_no",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 2,
>  },
>  [3] = TColumnDesc {
>  01: columnName (string) = "merchant_no",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 3,
>  },
>  [4] = TColumnDesc {
>  01: columnName (string) = "merchant_name",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 4,
>  },
>  [5] = TColumnDesc {
>  01: columnName (string) = "merchant_type_cd",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 5,
>  },
>  [6] = TColumnDesc {
>  01: columnName (string) = "merchant_type_mc",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 6,
>  },
>  [7] = TColumnDesc {
>  01: columnName (string) = "merchant_province_mc",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 7,
>  },
>  [8] = TColumnDesc {
>  01: columnName (string) = "merchant_province_cd",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 8,
>  },
>  [9] = TColumnDesc {
>  01: columnName (string) = "merchant_city_mc",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 9,
>  },
>  [10] = TColumnDesc {
>  01: columnName (string) = "merchant_city_cd",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 10,
>  },
>  [11] = TColumnDesc {
>  01: columnName (string) = "merchant_address_cn",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 11,
>  },
>  [12] = TColumnDesc {
>  01: columnName (string) = "merchant_address",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 12,
>  },
>  [13] = TColumnDesc {
>  01: columnName (string) = "merchant_telephone",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 13,
>  },
>  [14] = TColumnDesc {
>  01: columnName (string) = "company_name",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 14,
>  },
>  [15] = TColumnDesc {
>  01: columnName (string) = "company_type",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 15,
>  },
>  [16] = TColumnDesc {
>  01: columnName (string) = "legal_representative",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 16,
>  },
>  [17] = TColumnDesc {
>  01: columnName (string) = "merchant_region_cd",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 17,
>  },
>  [18] = TColumnDesc {
>  01: columnName (string) = "merchant_region_mc",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 18,
>  },
>  [19] = TColumnDesc {
>  01: columnName (string) = "address",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 19,
>  },
>  [20] = TColumnDesc {
>  01: columnName (string) = "industry",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 20,
>  },
>  [21] = TColumnDesc {
>  01: columnName (string) = "establish_date",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 21,
>  },
>  [22] = TColumnDesc {
>  01: columnName (string) = "registration_number",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 22,
>  },
>  [23] = TColumnDesc {
>  01: columnName (string) = "taxpayer_identification_number",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 23,
>  },
>  [24] = TColumnDesc {
>  01: columnName (string) = "organization_code",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 24,
>  },
>  [25] = TColumnDesc {
>  01: columnName (string) = "social_credit_code",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 25,
>  },
>  [26] = TColumnDesc {
>  01: columnName (string) = "management_status",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 26,
>  },
>  [27] = TColumnDesc {
>  01: columnName (string) = "business_limit",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 27,
>  },
>  [28] = TColumnDesc {
>  01: columnName (string) = "registered_capital",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 28,
>  },
>  [29] = TColumnDesc {
>  01: columnName (string) = "registration_authority",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 29,
>  },
>  [30] = TColumnDesc {
>  01: columnName (string) = "create_source",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 30,
>  },
>  [31] = TColumnDesc {
>  01: columnName (string) = "longitude",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry {
>  01: primitiveEntry (struct) = TPrimitiveTypeEntry {
>  01: type (i32) = 15,
>  02: typeQualifiers (struct) = TTypeQualifiers {
>  01: qualifiers (map) = map<string,struct>[2]
> Unknown macro: \{ "precision" -> TTypeQualifierValue { 01: i32Value (i32) = 20, }, "scale" -> TTypeQualifierValue \{ 01: i32Value (i32) = 17, }, }
> ,
>  },
>  },
>  },
>  },
>  },
>  03: position (i32) = 31,
>  },
>  [32] = TColumnDesc {
>  01: columnName (string) = "latitude",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry {
>  01: primitiveEntry (struct) = TPrimitiveTypeEntry {
>  01: type (i32) = 15,
>  02: typeQualifiers (struct) = TTypeQualifiers {
>  01: qualifiers (map) = map<string,struct>[2]
> Unknown macro: \{ "precision" -> TTypeQualifierValue { 01: i32Value (i32) = 20, }, "scale" -> TTypeQualifierValue \{ 01: i32Value (i32) = 17, }, }
> ,
>  },
>  },
>  },
>  },
>  },
>  03: position (i32) = 32,
>  },
>  [33] = TColumnDesc {
>  01: columnName (string) = "merchant_status",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 33,
>  },
>  [34] = TColumnDesc {
>  01: columnName (string) = "settlement_no",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 34,
>  },
>  [35] = TColumnDesc {
>  01: columnName (string) = "summary",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 35,
>  },
>  [36] = TColumnDesc {
>  01: columnName (string) = "comments",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 36,
>  },
>  [37] = TColumnDesc {
>  01: columnName (string) = "refusal_reason",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 37,
>  },
>  [38] = TColumnDesc {
>  01: columnName (string) = "sort_id",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 38,
>  },
>  [39] = TColumnDesc {
>  01: columnName (string) = "create_date",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 39,
>  },
>  [40] = TColumnDesc {
>  01: columnName (string) = "update_date",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 40,
>  },
>  [41] = TColumnDesc {
>  01: columnName (string) = "src_data",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 41,
>  },
>  [42] = TColumnDesc {
>  01: columnName (string) = "etl_dt",
>  02: typeDesc (struct) = TTypeDesc {
>  01: types (list) = list<struct>[1] {
>  [0] = TTypeEntry
> Unknown macro: \{ 01}
> ,
>  },
>  },
>  03: position (i32) = 42,
>  },
>  },
>  },
>  }
>  I1010 10:35:00.151284 22869 coordinator.cc:956] Backend completed: host=node03:22000 remaining=1 query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.151316 22869 coordinator-backend-state.cc:229] query_id=874972c15ebbfcc3:435ee5b300000000: first in-progress backend: node01:22000
>  I1010 10:35:00.165092 7925 coordinator.cc:789] Coordinator waiting for backends to finish, 1 remaining. query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.165601 7925 coordinator.cc:794] All backends finished successfully. query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.165618 7925 coordinator.cc:1092] Release admission control resources for query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:00.165683 32640 krpc-data-stream-mgr.cc:293] DeregisterRecvr(): fragment_instance_id=874972c15ebbfcc3:435ee5b300000000, node=1
>  I1010 10:35:00.165694 32640 krpc-data-stream-recvr.cc:557] cancelled stream: fragment_instance_id=874972c15ebbfcc3:435ee5b300000000 node_id=1
>  I1010 10:35:00.165719 32640 query-state.cc:412] Instance completed. instance_id=874972c15ebbfcc3:435ee5b300000000 #in-flight=0 status=OK
>  I1010 10:35:00.165732 32640 query-exec-mgr.cc:155] ReleaseQueryState(): query_id=874972c15ebbfcc3:435ee5b300000000 refcnt=2
>  I1010 10:35:00.625356 6460 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17215 size: 63
>  I1010 10:35:00.625416 6460 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17215 size: 49
>  I1010 10:35:00.625473 6460 impala-server.cc:1395] Catalog topic update applied with version: 17215 new min catalog object version: 2
>  I1010 10:35:02.626139 6459 ImpaladCatalog.java:173] Adding: TABLE:adm_db.a_t_uba_base_kpi_sum version: 17217 size: 63
>  I1010 10:35:02.626185 6459 ImpaladCatalog.java:173] Adding: CATALOG_SERVICE_ID version: 17217 size: 49
>  I1010 10:35:02.626220 6459 impala-server.cc:1395] Catalog topic update applied with version: 17217 new min catalog object version: 2
>  I1010 10:35:03.570850 7925 impala-hs2-server.cc:695] CloseOperation(): query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:03.570874 7925 impala-server.cc:1011] UnregisterQuery(): query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:03.570917 7925 impala-server.cc:1098] Cancel(): query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:03.570924 7925 coordinator.cc:896] Cancel() query_id=874972c15ebbfcc3:435ee5b300000000
>  I1010 10:35:03.570930 7925 coordinator.cc:906] CancelBackends() query_id=874972c15ebbfcc3:435ee5b300000000, tried to cancel 0 backends



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-all-unsubscribe@impala.apache.org
For additional commands, e-mail: issues-all-help@impala.apache.org