Uploaded image for project: 'IMPALA'
  1. IMPALA
  2. IMPALA-7685

Connect to impala database via JDBC and the connection is not closed when the query is finished

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Not A Bug
    • Affects Version/s: Impala 2.12.0
    • Fix Version/s: Not Applicable
    • Component/s: None
    • Labels:
      None
    • Epic Color:
      ghx-label-7

      Description

      CDH:

      查询详细信息

      DESCRIBE FDM_DB.F_T_MERCHANT_BASE_INFO

      查询信息

      • 查询 ID: 94492dca691a08fd:dc057ad200000000
      • 用户:**
      • 数据库: ADM_DB
      • Coordinator: node01
      • 查询类型: 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

        Query Timeline

      1. Query submitted: 0纳秒 (0纳秒)
      2. Planning finished: 19毫秒 (19毫秒)
      3. Rows available: 30毫秒 (11毫秒)
      4. 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

        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

        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

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 0,
        },
        [1] = TColumnDesc {
        01: columnName (string) = "customer_no",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 1,
        },
        [2] = TColumnDesc {
        01: columnName (string) = "user_no",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 2,
        },
        [3] = TColumnDesc {
        01: columnName (string) = "merchant_no",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 3,
        },
        [4] = TColumnDesc {
        01: columnName (string) = "merchant_name",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 4,
        },
        [5] = TColumnDesc {
        01: columnName (string) = "merchant_type_cd",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 5,
        },
        [6] = TColumnDesc {
        01: columnName (string) = "merchant_type_mc",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 6,
        },
        [7] = TColumnDesc {
        01: columnName (string) = "merchant_province_mc",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 7,
        },
        [8] = TColumnDesc {
        01: columnName (string) = "merchant_province_cd",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 8,
        },
        [9] = TColumnDesc {
        01: columnName (string) = "merchant_city_mc",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 9,
        },
        [10] = TColumnDesc {
        01: columnName (string) = "merchant_city_cd",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 10,
        },
        [11] = TColumnDesc {
        01: columnName (string) = "merchant_address_cn",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 11,
        },
        [12] = TColumnDesc {
        01: columnName (string) = "merchant_address",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 12,
        },
        [13] = TColumnDesc {
        01: columnName (string) = "merchant_telephone",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 13,
        },
        [14] = TColumnDesc {
        01: columnName (string) = "company_name",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 14,
        },
        [15] = TColumnDesc {
        01: columnName (string) = "company_type",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 15,
        },
        [16] = TColumnDesc {
        01: columnName (string) = "legal_representative",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 16,
        },
        [17] = TColumnDesc {
        01: columnName (string) = "merchant_region_cd",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 17,
        },
        [18] = TColumnDesc {
        01: columnName (string) = "merchant_region_mc",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 18,
        },
        [19] = TColumnDesc {
        01: columnName (string) = "address",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 19,
        },
        [20] = TColumnDesc {
        01: columnName (string) = "industry",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 20,
        },
        [21] = TColumnDesc {
        01: columnName (string) = "establish_date",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 21,
        },
        [22] = TColumnDesc {
        01: columnName (string) = "registration_number",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 22,
        },
        [23] = TColumnDesc {
        01: columnName (string) = "taxpayer_identification_number",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 23,
        },
        [24] = TColumnDesc {
        01: columnName (string) = "organization_code",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 24,
        },
        [25] = TColumnDesc {
        01: columnName (string) = "social_credit_code",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 25,
        },
        [26] = TColumnDesc {
        01: columnName (string) = "management_status",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 26,
        },
        [27] = TColumnDesc {
        01: columnName (string) = "business_limit",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 27,
        },
        [28] = TColumnDesc {
        01: columnName (string) = "registered_capital",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 28,
        },
        [29] = TColumnDesc {
        01: columnName (string) = "registration_authority",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 29,
        },
        [30] = TColumnDesc {
        01: columnName (string) = "create_source",
        02: typeDesc (struct) = TTypeDesc

        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

        Unknown macro: { 01}

        , }
        ,
        },
        },
        },
        },
        },
        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

        Unknown macro: { 01}

        , }
        ,
        },
        },
        },
        },
        },
        03: position (i32) = 32,
        },
        [33] = TColumnDesc {
        01: columnName (string) = "merchant_status",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 33,
        },
        [34] = TColumnDesc {
        01: columnName (string) = "settlement_no",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 34,
        },
        [35] = TColumnDesc {
        01: columnName (string) = "summary",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 35,
        },
        [36] = TColumnDesc {
        01: columnName (string) = "comments",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 36,
        },
        [37] = TColumnDesc {
        01: columnName (string) = "refusal_reason",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 37,
        },
        [38] = TColumnDesc {
        01: columnName (string) = "sort_id",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 38,
        },
        [39] = TColumnDesc {
        01: columnName (string) = "create_date",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 39,
        },
        [40] = TColumnDesc {
        01: columnName (string) = "update_date",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 40,
        },
        [41] = TColumnDesc {
        01: columnName (string) = "src_data",
        02: typeDesc (struct) = TTypeDesc

        Unknown macro: { 01}

        ,
        },
        03: position (i32) = 41,
        },
        [42] = TColumnDesc {
        01: columnName (string) = "etl_dt",
        02: typeDesc (struct) = TTypeDesc

        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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              lucky_yu yuxuqi
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: