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

DCHECK for memory leak in PHJ

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • Impala 2.3.0
    • None
    • None

    Description

      Log file created at: 2015/10/05 12:21:21
      Running on machine: tarmstrong-box
      Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
      F1005 12:21:21.494573  6057 exec-node.cc:190] Check failed: mem_tracker()->consumption() == 0 (65536 vs. 0) Leaked memory.
      Fragment d8487a58dc42eab0:e23c15ddc2f16ec5: Consumption=124.00 KB
        AGGREGATION_NODE (id=31): Consumption=36.00 KB
        HASH_JOIN_NODE (id=30): Consumption=0
        HASH_JOIN_NODE (id=29): Consumption=0
        HASH_JOIN_NODE (id=28): Consumption=64.00 KB
        HDFS_SCAN_NODE (id=24): Consumption=0
        EXCHANGE_NODE (id=88): Consumption=0
        EXCHANGE_NODE (id=89): Consumption=0
        DataStreamRecvr: Consumption=0
        EXCHANGE_NODE (id=90): Consumption=0
        DataStreamRecvr: Consumption=0
        DataStreamSender: Consumption=16.00 KB
      

      I hit the crash after running these two queries in a loop for several minutes. I had two concurrent clients running the same queries.

      use tpcds_parquet;
      
      select  *
      from
       (select count(*) h8_30_to_9
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 8
           and time_dim.t_minute >= 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s1,
       (select count(*) h9_to_9_30
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 9
           and time_dim.t_minute < 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s2,
       (select count(*) h9_30_to_10
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 9
           and time_dim.t_minute >= 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s3,
       (select count(*) h10_to_10_30
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 10
           and time_dim.t_minute < 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s4,
       (select count(*) h10_30_to_11
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 10
           and time_dim.t_minute >= 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s5,
       (select count(*) h11_to_11_30
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 11
           and time_dim.t_minute < 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s6,
       (select count(*) h11_30_to_12
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 11
           and time_dim.t_minute >= 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s7,
       (select count(*) h12_to_12_30
       from store_sales, household_demographics , time_dim, store
       where ss_sold_time_sk = time_dim.t_time_sk
           and ss_hdemo_sk = household_demographics.hd_demo_sk
           and ss_store_sk = s_store_sk
           and time_dim.t_hour = 12
           and time_dim.t_minute < 30
           and ((household_demographics.hd_dep_count = 1 and household_demographics.hd_vehicle_count<=1+2) or
                (household_demographics.hd_dep_count = 0 and household_demographics.hd_vehicle_count<=0+2) or
                (household_demographics.hd_dep_count = 2 and household_demographics.hd_vehicle_count<=2+2))
           and store.s_store_name = 'ese') s8;
      
      
      
      
      
      select promotions,total,cast(promotions as decimal(15,4))/cast(total as decimal(15,4))*100
      from
        (select sum(ss_ext_sales_price) promotions
         from  store_sales
              ,store
              ,promotion
              ,date_dim
              ,customer
              ,customer_address
              ,item
         where ss_sold_date_sk = d_date_sk
         and   ss_store_sk = s_store_sk
         and   ss_promo_sk = p_promo_sk
         and   ss_customer_sk= c_customer_sk
         and   ca_address_sk = c_current_addr_sk
         and   ss_item_sk = i_item_sk
         and   ca_gmt_offset = -5
         and   i_category = 'Books'
         and   (p_channel_dmail = 'Y' or p_channel_email = 'Y' or p_channel_tv = 'Y')
         and   s_gmt_offset = -5
         and   d_year = 2000
         and   d_moy  = 11) promotional_sales,
        (select sum(ss_ext_sales_price) total
         from  store_sales
              ,store
              ,date_dim
              ,customer
              ,customer_address
              ,item
         where ss_sold_date_sk = d_date_sk
         and   ss_store_sk = s_store_sk
         and   ss_customer_sk= c_customer_sk
         and   ca_address_sk = c_current_addr_sk
         and   ss_item_sk = i_item_sk
         and   ca_gmt_offset = -5
         and   i_category = 'Books'
         and   s_gmt_offset = -5
         and   d_year = 2000
         and   d_moy  = 11) all_sales
      order by promotions, total;
      
      

      Attachments

        Activity

          People

            tarmstrong Tim Armstrong
            tarmstrong Tim Armstrong
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: