yuxuqi created IMPALA-7685:
------------------------------
Summary: 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
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
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
