[ https://issues.apache.org/jira/browse/IMPALA-7685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Balazs Jeszenszky resolved IMPALA-7685. --------------------------------------- Resolution: Not A Bug Fix Version/s: Not Applicable This is the expected behaviour, you have to close the session from the client. Impala will only close idle sessions after --idle_session_timeout, see docs for specifics. > 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 > Fix For: Not Applicable > > > 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-unsubscr...@impala.apache.org For additional commands, e-mail: issues-all-h...@impala.apache.org