I0304 08:42:19.965014 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=16425f550233024a:bdac80bf8c8d9385 node_id=20
I0304 08:42:19.965091 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=16425f550233024a:bdac80bf8c8d9385 node_id=20
I0304 08:42:19.965169 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=16425f550233024a:bdac80bf8c8d9385 node_id=20
I0304 08:42:19.965246 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=16425f550233024a:bdac80bf8c8d9385 node_id=20
I0304 08:42:19.965324 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=16425f550233024a:bdac80bf8c8d9385 node_id=20
I0304 08:42:19.965402 59579 coordinator.cc:968] All backends finished successfully.
I0304 08:42:20.005522 59579 impala-beeswax-server.cc:349] close(): query_id=16425f550233024a:bdac80bf8c8d9384
I0304 08:42:20.005728 59579 impala-server.cc:915] UnregisterQuery(): query_id=16425f550233024a:bdac80bf8c8d9384
I0304 08:42:20.005875 59579 impala-server.cc:1001] Cancel(): query_id=16425f550233024a:bdac80bf8c8d9384
I0304 08:42:20.092430 59579 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=16425f550233024a:bdac80bf8c8d9385, node=20
I0304 08:43:02.719980 59579 impala-beeswax-server.cc:172] query(): query=select i_brand_id brand_id, i_brand brand, i_manufact_id, i_manufact,
 sum(ss_ext_sales_price) ext_price
 from date_dim, store_sales, item,customer,customer_address,store
 where d_date_sk = ss_sold_date_sk
   and ss_item_sk = i_item_sk
   and i_manager_id=7
   and d_moy=11
   and d_year=1999
   and ss_customer_sk = c_customer_sk
   and c_current_addr_sk = ca_address_sk
   and substr(ca_zip,1,5) <> substr(s_zip,1,5)
   and ss_store_sk = s_store_sk
 group by i_brand
      ,i_brand_id
      ,i_manufact_id
      ,i_manufact
 order by ext_price desc
         ,i_brand
         ,i_brand_id
         ,i_manufact_id
         ,i_manufact
limit 100
I0304 08:43:02.720509 59579 impala-beeswax-server.cc:515] query: Query {
  01: query (string) = "select i_brand_i[...](644)",
  03: configuration (list) = list<string>[2] {
    [0] = "RUNTIME_FILTER_MODE=2",
    [1] = "RUNTIME_FILTER_WAIT_TIME_MS=20000",
  },
  04: hadoop_user (string) = "mmokhtar",
}
I0304 08:43:02.766098 59579 impala-beeswax-server.cc:545] TClientRequest.queryOptions: TQueryOptions {
  01: abort_on_error (bool) = false,
  02: max_errors (i32) = 0,
  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) = 24,
  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,
  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) = 20000,
  40: disable_row_runtime_filtering (bool) = false,
  41: max_num_runtime_filters (i32) = 10,
}
I0304 08:43:02.769786 59579 Frontend.java:866] analyze query select i_brand_id brand_id, i_brand brand, i_manufact_id, i_manufact,
 sum(ss_ext_sales_price) ext_price
 from date_dim, store_sales, item,customer,customer_address,store
 where d_date_sk = ss_sold_date_sk
   and ss_item_sk = i_item_sk
   and i_manager_id=7
   and d_moy=11
   and d_year=1999
   and ss_customer_sk = c_customer_sk
   and c_current_addr_sk = ca_address_sk
   and substr(ca_zip,1,5) <> substr(s_zip,1,5)
   and ss_store_sk = s_store_sk
 group by i_brand
      ,i_brand_id
      ,i_manufact_id
      ,i_manufact
 order by ext_price desc
         ,i_brand
         ,i_brand_id
         ,i_manufact_id
         ,i_manufact
limit 100
I0304 08:43:02.773566 59579 AggregateInfo.java:181] agg info:
AggregateInfo{grouping_exprs=SlotRef{path=i_brand, type=STRING, id=1} SlotRef{path=i_brand_id, type=INT, id=0} SlotRef{path=i_manufact_id, type=INT, id=2} SlotRef{path=i_manufact, type=STRING, id=3}, aggregate_exprs=FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}, intermediate_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24})), output_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24}))}
mergeAggInfo:
AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=20} SlotRef{type=INT, id=21} SlotRef{type=INT, id=22} SlotRef{type=STRING, id=23}, aggregate_exprs=FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{type=DECIMAL(38,2), id=24}}, intermediate_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24})), output_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24}))}
I0304 08:43:02.774196 59579 SelectStmt.java:673] post-agg orderingExprs: SlotRef{type=DECIMAL(38,2), id=24} SlotRef{type=STRING, id=20} SlotRef{type=INT, id=21} SlotRef{type=INT, id=22} SlotRef{type=STRING, id=23}
I0304 08:43:02.775148 59579 SelectStmt.java:284] post-analysis AggregateInfo{grouping_exprs=SlotRef{path=i_brand, type=STRING, id=1} SlotRef{path=i_brand_id, type=INT, id=0} SlotRef{path=i_manufact_id, type=INT, id=2} SlotRef{path=i_manufact, type=STRING, id=3}, aggregate_exprs=FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}, intermediate_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}}AggregateInfo{phase=FIRST, intermediate_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24})), output_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24}))}
mergeAggInfo:
AggregateInfo{grouping_exprs=SlotRef{type=STRING, id=20} SlotRef{type=INT, id=21} SlotRef{type=INT, id=22} SlotRef{type=STRING, id=23}, aggregate_exprs=FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{type=DECIMAL(38,2), id=24}}, intermediate_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}, output_tuple=TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=0, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=false, byteSize=0, byteOffset=-1, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}}AggregateInfo{phase=FIRST_MERGE, intermediate_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24})), output_smap=smap(i_brand:i_brand (SlotRef{path=i_brand, type=STRING, id=1}:SlotRef{type=STRING, id=20}) i_brand_id:i_brand_id (SlotRef{path=i_brand_id, type=INT, id=0}:SlotRef{type=INT, id=21}) i_manufact_id:i_manufact_id (SlotRef{path=i_manufact_id, type=INT, id=2}:SlotRef{type=INT, id=22}) i_manufact:i_manufact (SlotRef{path=i_manufact, type=STRING, id=3}:SlotRef{type=STRING, id=23}) sum(ss_ext_sales_price):sum(ss_ext_sales_price) (FunctionCallExpr{name=sum, isStar=false, isDistinct=false, SlotRef{path=ss_ext_sales_price, type=DECIMAL(7,2), id=4}}:SlotRef{type=DECIMAL(38,2), id=24}))}
I0304 08:43:02.775503 59579 Frontend.java:943] create plan
I0304 08:43:02.776537 59579 HdfsScanNode.java:346] collecting partitions for table date_dim
I0304 08:43:02.776836 59579 HdfsScanNode.java:391] cardinality_=73049 sel=0.00147283231936129
I0304 08:43:02.777037 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=108
I0304 08:43:02.777264 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=1 localRanges=1 remoteRanges=0 localHostSet.size=3 clusterNodes=20
I0304 08:43:02.777457 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=1
I0304 08:43:02.781703 59579 HdfsScanNode.java:346] collecting partitions for table store_sales
I0304 08:43:02.782400 59579 HdfsScanNode.java:391] cardinality_=43202446268 sel=1.0
I0304 08:43:02.782614 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=43202446268
I0304 08:43:02.782778 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=6922 localRanges=20 remoteRanges=0 localHostSet.size=20 clusterNodes=20
I0304 08:43:02.782979 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=20
I0304 08:43:02.783310 59579 HdfsScanNode.java:346] collecting partitions for table item
I0304 08:43:02.783521 59579 HdfsScanNode.java:391] cardinality_=32000 sel=0.010101010101010102
I0304 08:43:02.783715 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=323
I0304 08:43:02.783838 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=1 localRanges=1 remoteRanges=0 localHostSet.size=3 clusterNodes=20
I0304 08:43:02.783968 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=1
I0304 08:43:02.784163 59579 HdfsScanNode.java:346] collecting partitions for table customer
I0304 08:43:02.784301 59579 HdfsScanNode.java:391] cardinality_=3850000 sel=1.0
I0304 08:43:02.784426 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=3850000
I0304 08:43:02.784555 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=20 localRanges=20 remoteRanges=0 localHostSet.size=20 clusterNodes=20
I0304 08:43:02.784672 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=20
I0304 08:43:02.784857 59579 HdfsScanNode.java:346] collecting partitions for table customer_address
I0304 08:43:02.785014 59579 HdfsScanNode.java:391] cardinality_=1925000 sel=1.0
I0304 08:43:02.785141 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=1925000
I0304 08:43:02.785269 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=20 localRanges=20 remoteRanges=0 localHostSet.size=19 clusterNodes=20
I0304 08:43:02.785384 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=19
I0304 08:43:02.785560 59579 HdfsScanNode.java:346] collecting partitions for table store
I0304 08:43:02.785687 59579 HdfsScanNode.java:391] cardinality_=62 sel=1.0
I0304 08:43:02.785811 59579 HdfsScanNode.java:398] computeStats HdfsScan: cardinality_=62
I0304 08:43:02.785938 59579 HdfsScanNode.java:454] computeNumNodes totalRanges=1 localRanges=1 remoteRanges=0 localHostSet.size=3 clusterNodes=20
I0304 08:43:02.786056 59579 HdfsScanNode.java:401] computeStats HdfsScan: #nodes=1
I0304 08:43:02.786384 59579 JoinNode.java:444] stats Join: cardinality=2495987451
I0304 08:43:02.786623 59579 JoinNode.java:444] stats Join: cardinality=436074693
I0304 08:43:02.786844 59579 JoinNode.java:444] stats Join: cardinality=43202446268
I0304 08:43:02.787050 59579 JoinNode.java:444] stats Join: cardinality=43202446268
I0304 08:43:02.787253 59579 JoinNode.java:444] stats Join: cardinality=43202446268
I0304 08:43:02.787402 59579 SingleNodePlanner.java:539] 0 chose tpcds_15000_decimal_parquet.item #lhs=43202446268 #rhs=323 #ops=43202446591
I0304 08:43:02.787609 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.787827 59579 JoinNode.java:444] stats Join: cardinality=436074693
I0304 08:43:02.788028 59579 JoinNode.java:444] stats Join: cardinality=436074693
I0304 08:43:02.788235 59579 JoinNode.java:444] stats Join: cardinality=436074693
I0304 08:43:02.788429 59579 SingleNodePlanner.java:539] 1 chose tpcds_15000_decimal_parquet.date_dim #lhs=436074693 #rhs=108 #ops=43638521392
I0304 08:43:02.788636 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.788836 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.789047 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.789196 59579 SingleNodePlanner.java:539] 2 chose tpcds_15000_decimal_parquet.customer #lhs=25193874 #rhs=3850000 #ops=43667565266
I0304 08:43:02.789402 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.789630 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.789780 59579 SingleNodePlanner.java:539] 3 chose tpcds_15000_decimal_parquet.customer_address #lhs=25193874 #rhs=1925000 #ops=43694684140
I0304 08:43:02.790069 59579 JoinNode.java:444] stats Join: cardinality=25193874
I0304 08:43:02.790307 59579 SingleNodePlanner.java:539] 4 chose tpcds_15000_decimal_parquet.store #lhs=25193874 #rhs=62 #ops=43719878076
I0304 08:43:02.790670 59579 SortNode.java:130] stats Sort: cardinality=100
I0304 08:43:02.791298 59579 DistributedPlanner.java:79] create plan fragments
I0304 08:43:02.791415 59579 DistributedPlanner.java:81] memlimit=0
I0304 08:43:02.791560 59579 DistributedPlanner.java:330] broadcast: cost=538960
I0304 08:43:02.791695 59579 DistributedPlanner.java:331] card=323 row_size=79.4302 #nodes=20
I0304 08:43:02.791834 59579 DistributedPlanner.java:362] partition: cost=1728097877668
I0304 08:43:02.791970 59579 DistributedPlanner.java:363] lhs card=43202446268 row_size=36.0
I0304 08:43:02.792096 59579 DistributedPlanner.java:365] rhs card=323 row_size=79.4302
I0304 08:43:02.792336 59579 DistributedPlanner.java:367] 02:SCAN HDFS [tpcds_15000_decimal_parquet.item, RANDOM]
   partitions=1/1 files=1 size=3.14MB
   predicates: i_manager_id = 7
   table stats: 32000 rows total
   column stats: all
   hosts=1 per-host-mem=unavailable
   tuple-ids=2 row-size=79B cardinality=323
I0304 08:43:02.792506 59579 DistributedPlanner.java:330] broadcast: cost=43200
I0304 08:43:02.792634 59579 DistributedPlanner.java:331] card=108 row_size=16.0 #nodes=20
I0304 08:43:02.792767 59579 DistributedPlanner.java:362] partition: cost=53824788152
I0304 08:43:02.792901 59579 DistributedPlanner.java:363] lhs card=436074693 row_size=115.4302
I0304 08:43:02.793026 59579 DistributedPlanner.java:365] rhs card=108 row_size=16.0
I0304 08:43:02.793226 59579 DistributedPlanner.java:367] 00:SCAN HDFS [tpcds_15000_decimal_parquet.date_dim, RANDOM]
   partitions=1/1 files=1 size=2.17MB
   predicates: d_moy = 11, d_year = 1999
   table stats: 73049 rows total
   column stats: all
   hosts=1 per-host-mem=unavailable
   tuple-ids=0 row-size=16B cardinality=108
I0304 08:43:02.793454 59579 DistributedPlanner.java:330] broadcast: cost=1540000000
I0304 08:43:02.793581 59579 DistributedPlanner.java:331] card=3850000 row_size=16.0 #nodes=20
I0304 08:43:02.793711 59579 DistributedPlanner.java:362] partition: cost=3690562545
I0304 08:43:02.793834 59579 DistributedPlanner.java:363] lhs card=25193874 row_size=131.4302
I0304 08:43:02.793962 59579 DistributedPlanner.java:365] rhs card=3850000 row_size=16.0
I0304 08:43:02.794167 59579 DistributedPlanner.java:367] 03:SCAN HDFS [tpcds_15000_decimal_parquet.customer, RANDOM]
   partitions=1/1 files=20 size=213.69MB
   runtime filters: RF001 -> c_current_addr_sk
   table stats: 3850000 rows total
   column stats: all
   hosts=20 per-host-mem=unavailable
   tuple-ids=3 row-size=16B cardinality=3850000
I0304 08:43:02.794322 59579 DistributedPlanner.java:330] broadcast: cost=1264663400
I0304 08:43:02.794445 59579 DistributedPlanner.java:331] card=1925000 row_size=28.8484 #nodes=20
I0304 08:43:02.794575 59579 DistributedPlanner.java:362] partition: cost=4180673195
I0304 08:43:02.794697 59579 DistributedPlanner.java:363] lhs card=25193874 row_size=147.4302
I0304 08:43:02.794816 59579 DistributedPlanner.java:365] rhs card=1925000 row_size=28.8484
I0304 08:43:02.795024 59579 DistributedPlanner.java:367] 04:SCAN HDFS [tpcds_15000_decimal_parquet.customer_address, RANDOM]
   partitions=1/1 files=20 size=40.15MB
   table stats: 1925000 rows total
   column stats: all
   hosts=19 per-host-mem=unavailable
   tuple-ids=4 row-size=29B cardinality=1925000
I0304 08:43:02.795209 59579 DistributedPlanner.java:330] broadcast: cost=40820
I0304 08:43:02.795336 59579 DistributedPlanner.java:331] card=62 row_size=28.9194 #nodes=20
I0304 08:43:02.795465 59579 DistributedPlanner.java:362] partition: cost=4945020616
I0304 08:43:02.795586 59579 DistributedPlanner.java:363] lhs card=25193874 row_size=176.27861
I0304 08:43:02.795704 59579 DistributedPlanner.java:365] rhs card=62 row_size=28.9194
I0304 08:43:02.795907 59579 DistributedPlanner.java:367] 05:SCAN HDFS [tpcds_15000_decimal_parquet.store, RANDOM]
   partitions=1/1 files=1 size=11.92KB
   table stats: 62 rows total
   column stats: all
   hosts=1 per-host-mem=unavailable
   tuple-ids=5 row-size=29B cardinality=62
I0304 08:43:02.796298 59579 SortNode.java:130] stats Sort: cardinality=100
I0304 08:43:02.796715 59579 Planner.java:124] desctbl: tuples:
TupleDescriptor{id=0, name=BaseTableRef tpcds_15000_decimal_parquet.date_dim, tbl=tpcds_15000_decimal_parquet.date_dim, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=5, path=tpcds_15000_decimal_parquet.date_dim.d_date_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=2, slotIdx=2, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=71277, numNulls_=-1}}, SlotDescriptor{id=10, path=tpcds_15000_decimal_parquet.date_dim.d_moy, type=INT, materialized=true, byteSize=4, byteOffset=4, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=12, numNulls_=-1}}, SlotDescriptor{id=11, path=tpcds_15000_decimal_parquet.date_dim.d_year, type=INT, materialized=true, byteSize=4, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=196, numNulls_=-1}}]}
TupleDescriptor{id=1, name=BaseTableRef tpcds_15000_decimal_parquet.store_sales, tbl=tpcds_15000_decimal_parquet.store_sales, byte_size=40, is_materialized=true, slots=[SlotDescriptor{id=4, path=tpcds_15000_decimal_parquet.store_sales.ss_ext_sales_price, type=DECIMAL(7,2), materialized=true, byteSize=4, byteOffset=4, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=748197, numNulls_=-1}}, SlotDescriptor{id=6, path=tpcds_15000_decimal_parquet.store_sales.ss_sold_date_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=1824, numNulls_=1}}, SlotDescriptor{id=7, path=tpcds_15000_decimal_parquet.store_sales.ss_item_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=2, slotIdx=2, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=31952, numNulls_=-1}}, SlotDescriptor{id=12, path=tpcds_15000_decimal_parquet.store_sales.ss_customer_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=24, nullIndicatorByte=0, nullIndicatorBit=3, slotIdx=3, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=3789273, numNulls_=-1}}, SlotDescriptor{id=18, path=tpcds_15000_decimal_parquet.store_sales.ss_store_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=32, nullIndicatorByte=0, nullIndicatorBit=4, slotIdx=4, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=32, numNulls_=-1}}]}
TupleDescriptor{id=2, name=BaseTableRef tpcds_15000_decimal_parquet.item, tbl=tpcds_15000_decimal_parquet.item, byte_size=56, is_materialized=true, slots=[SlotDescriptor{id=0, path=tpcds_15000_decimal_parquet.item.i_brand_id, type=INT, materialized=true, byteSize=4, byteOffset=4, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=1, path=tpcds_15000_decimal_parquet.item.i_brand, type=STRING, materialized=true, byteSize=16, byteOffset=24, nullIndicatorByte=0, nullIndicatorBit=4, slotIdx=4, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=2, path=tpcds_15000_decimal_parquet.item.i_manufact_id, type=INT, materialized=true, byteSize=4, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=3, path=tpcds_15000_decimal_parquet.item.i_manufact, type=STRING, materialized=true, byteSize=16, byteOffset=40, nullIndicatorByte=0, nullIndicatorBit=5, slotIdx=5, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=8, path=tpcds_15000_decimal_parquet.item.i_item_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=3, slotIdx=3, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=31952, numNulls_=-1}}, SlotDescriptor{id=9, path=tpcds_15000_decimal_parquet.item.i_manager_id, type=INT, materialized=true, byteSize=4, byteOffset=12, nullIndicatorByte=0, nullIndicatorBit=2, slotIdx=2, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=99, numNulls_=-1}}]}
TupleDescriptor{id=3, name=BaseTableRef tpcds_15000_decimal_parquet.customer, tbl=tpcds_15000_decimal_parquet.customer, byte_size=24, is_materialized=true, slots=[SlotDescriptor{id=13, path=tpcds_15000_decimal_parquet.customer.c_customer_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=3789273, numNulls_=-1}}, SlotDescriptor{id=14, path=tpcds_15000_decimal_parquet.customer.c_current_addr_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=1689533, numNulls_=-1}}]}
TupleDescriptor{id=4, name=BaseTableRef tpcds_15000_decimal_parquet.customer_address, tbl=tpcds_15000_decimal_parquet.customer_address, byte_size=32, is_materialized=true, slots=[SlotDescriptor{id=15, path=tpcds_15000_decimal_parquet.customer_address.ca_address_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=1946759, numNulls_=-1}}, SlotDescriptor{id=16, path=tpcds_15000_decimal_parquet.customer_address.ca_zip, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=20.848400115966797, maxSize_=5, numDistinct_=9357, numNulls_=-1}}]}
TupleDescriptor{id=5, name=BaseTableRef tpcds_15000_decimal_parquet.store, tbl=tpcds_15000_decimal_parquet.store, byte_size=32, is_materialized=true, slots=[SlotDescriptor{id=17, path=tpcds_15000_decimal_parquet.store.s_zip, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=20.919400215148926, maxSize_=5, numDistinct_=38, numNulls_=-1}}, SlotDescriptor{id=19, path=tpcds_15000_decimal_parquet.store.s_store_sk, type=BIGINT, materialized=true, byteSize=8, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=8.0, maxSize_=8, numDistinct_=61, numNulls_=-1}}]}
TupleDescriptor{id=6, name=agg-tuple-intermed, tbl=null, byte_size=64, is_materialized=true, slots=[SlotDescriptor{id=20, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=2, slotIdx=2, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=21, path=null, type=INT, materialized=true, byteSize=4, byteOffset=4, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=22, path=null, type=INT, materialized=true, byteSize=4, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=23, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=32, nullIndicatorByte=0, nullIndicatorBit=3, slotIdx=3, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=24, path=null, type=DECIMAL(38,2), materialized=true, byteSize=16, byteOffset=48, nullIndicatorByte=0, nullIndicatorBit=4, slotIdx=4, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}
TupleDescriptor{id=7, name=sort, tbl=null, byte_size=64, is_materialized=true, slots=[SlotDescriptor{id=25, path=null, type=INT, materialized=true, byteSize=4, byteOffset=4, nullIndicatorByte=0, nullIndicatorBit=0, slotIdx=0, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=932, numNulls_=-1}}, SlotDescriptor{id=26, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=16, nullIndicatorByte=0, nullIndicatorBit=2, slotIdx=2, stats=ColumnStats{avgSerializedSize_=32.13789939880371, maxSize_=22, numDistinct_=691, numNulls_=-1}}, SlotDescriptor{id=27, path=null, type=STRING, materialized=true, byteSize=16, byteOffset=32, nullIndicatorByte=0, nullIndicatorBit=3, slotIdx=3, stats=ColumnStats{avgSerializedSize_=27.2923002243042, maxSize_=15, numDistinct_=1032, numNulls_=-1}}, SlotDescriptor{id=28, path=null, type=INT, materialized=true, byteSize=4, byteOffset=8, nullIndicatorByte=0, nullIndicatorBit=1, slotIdx=1, stats=ColumnStats{avgSerializedSize_=4.0, maxSize_=4, numDistinct_=957, numNulls_=-1}}, SlotDescriptor{id=29, path=null, type=DECIMAL(38,2), materialized=true, byteSize=16, byteOffset=48, nullIndicatorByte=0, nullIndicatorBit=4, slotIdx=4, stats=ColumnStats{avgSerializedSize_=16.0, maxSize_=16, numDistinct_=748197, numNulls_=-1}}]}
I0304 08:43:02.796939 59579 Planner.java:125] resultexprs: SlotRef{type=INT, id=25} SlotRef{type=STRING, id=26} SlotRef{type=INT, id=28} SlotRef{type=STRING, id=27} SlotRef{type=DECIMAL(38,2), id=29}
I0304 08:43:02.797086 59579 Planner.java:126] finalize plan fragments
I0304 08:43:02.799010 59579 Frontend.java:969] get scan range locations
I0304 08:43:02.801286 59579 Planner.java:308] Estimated per-host peak memory requirement: 3154149519
I0304 08:43:02.804990 59579 Planner.java:309] Estimated per-host virtual cores requirement: 6
I0304 08:43:02.808708 59579 Frontend.java:1047] create result set metadata
I0304 08:43:02.808892 59579 JniFrontend.java:142] Estimated Per-Host Requirements: Memory=2.94GB VCores=6

20:MERGING-EXCHANGE [UNPARTITIONED]
|  order by: sum(ss_ext_sales_price) DESC, i_brand ASC, i_brand_id ASC, i_manufact_id ASC, i_manufact ASC
|  limit: 100
|  hosts=20 per-host-mem=unavailable
|  tuple-ids=7 row-size=83B cardinality=100
|
12:TOP-N [LIMIT=100]
|  order by: sum(ss_ext_sales_price) DESC, i_brand ASC, i_brand_id ASC, i_manufact_id ASC, i_manufact ASC
|  hosts=20 per-host-mem=8.15KB
|  tuple-ids=7 row-size=83B cardinality=100
|
19:AGGREGATE [FINALIZE]
|  output: sum:merge(ss_ext_sales_price)
|  group by: i_brand, i_brand_id, i_manufact_id, i_manufact
|  hosts=20 per-host-mem=328.11MB
|  tuple-ids=6 row-size=83B cardinality=25193874
|
18:EXCHANGE [HASH(i_brand,i_brand_id,i_manufact_id,i_manufact)]
|  hosts=20 per-host-mem=0B
|  tuple-ids=6 row-size=83B cardinality=25193874
|
11:AGGREGATE [STREAMING]
|  output: sum(ss_ext_sales_price)
|  group by: i_brand, i_brand_id, i_manufact_id, i_manufact
|  hosts=20 per-host-mem=2.15GB
|  tuple-ids=6 row-size=83B cardinality=25193874
|
10:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_store_sk = s_store_sk
|  other predicates: substr(ca_zip, 1, 5) != substr(s_zip, 1, 5)
|  runtime filters: RF000 <- s_store_sk
|  hosts=20 per-host-mem=1.93KB
|  tuple-ids=1,2,0,3,4,5 row-size=205B cardinality=25193874
|
|--17:EXCHANGE [BROADCAST]
|  |  hosts=1 per-host-mem=0B
|  |  tuple-ids=5 row-size=29B cardinality=62
|  |
|  05:SCAN HDFS [tpcds_15000_decimal_parquet.store, RANDOM]
|     partitions=1/1 files=1 size=11.92KB
|     table stats: 62 rows total
|     column stats: all
|     hosts=1 per-host-mem=32.00MB
|     tuple-ids=5 row-size=29B cardinality=62
|
09:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: c_current_addr_sk = ca_address_sk
|  runtime filters: RF001 <- ca_address_sk
|  hosts=20 per-host-mem=58.26MB
|  tuple-ids=1,2,0,3,4 row-size=176B cardinality=25193874
|
|--16:EXCHANGE [BROADCAST]
|  |  hosts=19 per-host-mem=0B
|  |  tuple-ids=4 row-size=29B cardinality=1925000
|  |
|  04:SCAN HDFS [tpcds_15000_decimal_parquet.customer_address, RANDOM]
|     partitions=1/1 files=20 size=40.15MB
|     table stats: 1925000 rows total
|     column stats: all
|     hosts=19 per-host-mem=32.00MB
|     tuple-ids=4 row-size=29B cardinality=1925000
|
08:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_customer_sk = c_customer_sk
|  runtime filters: RF002 <- c_customer_sk
|  hosts=20 per-host-mem=64.62MB
|  tuple-ids=1,2,0,3 row-size=147B cardinality=25193874
|
|--15:EXCHANGE [BROADCAST]
|  |  hosts=20 per-host-mem=0B
|  |  tuple-ids=3 row-size=16B cardinality=3850000
|  |
|  03:SCAN HDFS [tpcds_15000_decimal_parquet.customer, RANDOM]
|     partitions=1/1 files=20 size=213.69MB
|     runtime filters: RF001 -> c_current_addr_sk
|     table stats: 3850000 rows total
|     column stats: all
|     hosts=20 per-host-mem=48.00MB
|     tuple-ids=3 row-size=16B cardinality=3850000
|
07:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_sold_date_sk = d_date_sk
|  runtime filters: RF003 <- d_date_sk
|  hosts=20 per-host-mem=1.86KB
|  tuple-ids=1,2,0 row-size=131B cardinality=25193874
|
|--14:EXCHANGE [BROADCAST]
|  |  hosts=1 per-host-mem=0B
|  |  tuple-ids=0 row-size=16B cardinality=108
|  |
|  00:SCAN HDFS [tpcds_15000_decimal_parquet.date_dim, RANDOM]
|     partitions=1/1 files=1 size=2.17MB
|     predicates: d_moy = 11, d_year = 1999
|     table stats: 73049 rows total
|     column stats: all
|     hosts=1 per-host-mem=48.00MB
|     tuple-ids=0 row-size=16B cardinality=108
|
06:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_item_sk = i_item_sk
|  runtime filters: RF004 <- i_item_sk
|  hosts=20 per-host-mem=27.56KB
|  tuple-ids=1,2 row-size=115B cardinality=436074693
|
|--13:EXCHANGE [BROADCAST]
|  |  hosts=1 per-host-mem=0B
|  |  tuple-ids=2 row-size=79B cardinality=323
|  |
|  02:SCAN HDFS [tpcds_15000_decimal_parquet.item, RANDOM]
|     partitions=1/1 files=1 size=3.14MB
|     predicates: i_manager_id = 7
|     table stats: 32000 rows total
|     column stats: all
|     hosts=1 per-host-mem=96.00MB
|     tuple-ids=2 row-size=79B cardinality=323
|
01:SCAN HDFS [tpcds_15000_decimal_parquet.store_sales, RANDOM]
   partitions=1824/1824 files=6922 size=1.52TB
   runtime filters: RF000 -> ss_store_sk, RF002 -> ss_customer_sk, RF003 -> ss_sold_date_sk, RF004 -> ss_item_sk
   table stats: 43202446268 rows total
   column stats: all
   hosts=20 per-host-mem=352.00MB
   tuple-ids=1 row-size=36B cardinality=43202446268
I0304 08:43:02.885216 59579 coordinator.cc:382] Exec() query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:02.894253 59579 plan-fragment-executor.cc:92] Prepare(): query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211eae
I0304 08:43:02.895081 59579 plan-fragment-executor.cc:202] descriptor table for fragment=3045db9f916d3ae1:2b6258aae4211eae
tuples:
Tuple(id=0 size=24 slots=[Slot(id=5 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=10 type=INT col_path=[8] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=11 type=INT col_path=[6] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=1 size=40 slots=[Slot(id=4 type=DECIMAL(7, 2) col_path=[15] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=6 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=BIGINT col_path=[2] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=12 type=BIGINT col_path=[3] offset=24 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=18 type=BIGINT col_path=[7] offset=32 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=2 size=56 slots=[Slot(id=0 type=INT col_path=[7] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[8] offset=24 null=(offset=0 mask=10) slot_idx=4 field_idx=-1), Slot(id=2 type=INT col_path=[13] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[14] offset=40 null=(offset=0 mask=20) slot_idx=5 field_idx=-1), Slot(id=8 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=9 type=INT col_path=[20] offset=12 null=(offset=0 mask=4) slot_idx=2 field_idx=-1)] tuple_path=[])
Tuple(id=3 size=24 slots=[Slot(id=13 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=14 type=BIGINT col_path=[4] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=4 size=32 slots=[Slot(id=15 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=16 type=STRING col_path=[9] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=5 size=32 slots=[Slot(id=17 type=STRING col_path=[25] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=19 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[])
Tuple(id=6 size=64 slots=[Slot(id=20 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=21 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=22 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=23 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=24 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=7 size=64 slots=[Slot(id=25 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=26 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=27 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=28 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=29 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
I0304 08:43:02.895750 59579 coordinator.cc:532] starting 78 fragment instances for query 3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:02.899202 60079 fragment-mgr.cc:36] ExecPlanFragment() instance_id=3045db9f916d3ae1:2b6258aae4211ec1 coord=d2402.halxg.cloudera.com:22000 fragment instance#=18
I0304 08:43:02.903354 64627 plan-fragment-executor.cc:92] Prepare(): query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211ec1
I0304 08:43:02.905298 64627 plan-fragment-executor.cc:202] descriptor table for fragment=3045db9f916d3ae1:2b6258aae4211ec1
tuples:
Tuple(id=0 size=24 slots=[Slot(id=5 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=10 type=INT col_path=[8] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=11 type=INT col_path=[6] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=1 size=40 slots=[Slot(id=4 type=DECIMAL(7, 2) col_path=[15] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=6 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=BIGINT col_path=[2] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=12 type=BIGINT col_path=[3] offset=24 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=18 type=BIGINT col_path=[7] offset=32 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=2 size=56 slots=[Slot(id=0 type=INT col_path=[7] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[8] offset=24 null=(offset=0 mask=10) slot_idx=4 field_idx=-1), Slot(id=2 type=INT col_path=[13] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[14] offset=40 null=(offset=0 mask=20) slot_idx=5 field_idx=-1), Slot(id=8 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=9 type=INT col_path=[20] offset=12 null=(offset=0 mask=4) slot_idx=2 field_idx=-1)] tuple_path=[])
Tuple(id=3 size=24 slots=[Slot(id=13 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=14 type=BIGINT col_path=[4] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=4 size=32 slots=[Slot(id=15 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=16 type=STRING col_path=[9] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=5 size=32 slots=[Slot(id=17 type=STRING col_path=[25] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=19 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[])
Tuple(id=6 size=64 slots=[Slot(id=20 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=21 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=22 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=23 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=24 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=7 size=64 slots=[Slot(id=25 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=26 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=27 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=28 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=29 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
I0304 08:43:03.003422 59877 fragment-mgr.cc:36] ExecPlanFragment() instance_id=3045db9f916d3ae1:2b6258aae4211ed9 coord=d2402.halxg.cloudera.com:22000 fragment instance#=42
I0304 08:43:03.003991 64628 plan-fragment-executor.cc:92] Prepare(): query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211ed9
I0304 08:43:03.004475 64628 plan-fragment-executor.cc:202] descriptor table for fragment=3045db9f916d3ae1:2b6258aae4211ed9
tuples:
Tuple(id=0 size=24 slots=[Slot(id=5 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=10 type=INT col_path=[8] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=11 type=INT col_path=[6] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=1 size=40 slots=[Slot(id=4 type=DECIMAL(7, 2) col_path=[15] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=6 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=BIGINT col_path=[2] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=12 type=BIGINT col_path=[3] offset=24 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=18 type=BIGINT col_path=[7] offset=32 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=2 size=56 slots=[Slot(id=0 type=INT col_path=[7] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[8] offset=24 null=(offset=0 mask=10) slot_idx=4 field_idx=-1), Slot(id=2 type=INT col_path=[13] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[14] offset=40 null=(offset=0 mask=20) slot_idx=5 field_idx=-1), Slot(id=8 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=9 type=INT col_path=[20] offset=12 null=(offset=0 mask=4) slot_idx=2 field_idx=-1)] tuple_path=[])
Tuple(id=3 size=24 slots=[Slot(id=13 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=14 type=BIGINT col_path=[4] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=4 size=32 slots=[Slot(id=15 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=16 type=STRING col_path=[9] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=5 size=32 slots=[Slot(id=17 type=STRING col_path=[25] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=19 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[])
Tuple(id=6 size=64 slots=[Slot(id=20 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=21 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=22 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=23 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=24 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=7 size=64 slots=[Slot(id=25 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=26 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=27 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=28 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=29 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
I0304 08:43:03.008116 64628 plan-fragment-executor.cc:311] Open(): instance_id=3045db9f916d3ae1:2b6258aae4211ed9
I0304 08:43:03.060423 60080 fragment-mgr.cc:36] ExecPlanFragment() instance_id=3045db9f916d3ae1:2b6258aae4211ed5 coord=d2402.halxg.cloudera.com:22000 fragment instance#=38
I0304 08:43:03.069208 64653 plan-fragment-executor.cc:92] Prepare(): query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211ed5
I0304 08:43:03.081231 64653 plan-fragment-executor.cc:202] descriptor table for fragment=3045db9f916d3ae1:2b6258aae4211ed5
tuples:
Tuple(id=0 size=24 slots=[Slot(id=5 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=10 type=INT col_path=[8] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=11 type=INT col_path=[6] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=1 size=40 slots=[Slot(id=4 type=DECIMAL(7, 2) col_path=[15] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=6 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=7 type=BIGINT col_path=[2] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=12 type=BIGINT col_path=[3] offset=24 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=18 type=BIGINT col_path=[7] offset=32 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=2 size=56 slots=[Slot(id=0 type=INT col_path=[7] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=1 type=STRING col_path=[8] offset=24 null=(offset=0 mask=10) slot_idx=4 field_idx=-1), Slot(id=2 type=INT col_path=[13] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=3 type=STRING col_path=[14] offset=40 null=(offset=0 mask=20) slot_idx=5 field_idx=-1), Slot(id=8 type=BIGINT col_path=[0] offset=16 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=9 type=INT col_path=[20] offset=12 null=(offset=0 mask=4) slot_idx=2 field_idx=-1)] tuple_path=[])
Tuple(id=3 size=24 slots=[Slot(id=13 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=14 type=BIGINT col_path=[4] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=4 size=32 slots=[Slot(id=15 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=16 type=STRING col_path=[9] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1)] tuple_path=[])
Tuple(id=5 size=32 slots=[Slot(id=17 type=STRING col_path=[25] offset=16 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=19 type=BIGINT col_path=[0] offset=8 null=(offset=0 mask=1) slot_idx=0 field_idx=-1)] tuple_path=[])
Tuple(id=6 size=64 slots=[Slot(id=20 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=21 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=22 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=23 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=24 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
Tuple(id=7 size=64 slots=[Slot(id=25 type=INT col_path=[] offset=4 null=(offset=0 mask=1) slot_idx=0 field_idx=-1), Slot(id=26 type=STRING col_path=[] offset=16 null=(offset=0 mask=4) slot_idx=2 field_idx=-1), Slot(id=27 type=STRING col_path=[] offset=32 null=(offset=0 mask=8) slot_idx=3 field_idx=-1), Slot(id=28 type=INT col_path=[] offset=8 null=(offset=0 mask=2) slot_idx=1 field_idx=-1), Slot(id=29 type=DECIMAL(38, 2) col_path=[] offset=48 null=(offset=0 mask=10) slot_idx=4 field_idx=-1)] tuple_path=[])
I0304 08:43:03.083629 64654 plan-fragment-executor.cc:311] Open(): instance_id=3045db9f916d3ae1:2b6258aae4211eae
I0304 08:43:03.159940 64627 plan-fragment-executor.cc:311] Open(): instance_id=3045db9f916d3ae1:2b6258aae4211ec1
I0304 08:43:03.277513 64653 plan-fragment-executor.cc:311] Open(): instance_id=3045db9f916d3ae1:2b6258aae4211ed5
I0304 08:43:03.298032 46322 coordinator.cc:1558] Fragment instance 77(3045db9f916d3ae1:2b6258aae4211efc) on host d2403.halxg.cloudera.com:22000 completed, 77 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:03.298301 46322 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:03.299720  2519 coordinator.cc:1558] Fragment instance 76(3045db9f916d3ae1:2b6258aae4211efb) on host d2406.halxg.cloudera.com:22000 completed, 76 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:03.299829  2519 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:03.308671 29445 coordinator.cc:1558] Fragment instance 40(3045db9f916d3ae1:2b6258aae4211ed7) on host d2415.halxg.cloudera.com:22000 completed, 75 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:03.308993 29445 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.109338 45490 coordinator.cc:1558] Fragment instance 57(3045db9f916d3ae1:2b6258aae4211ee8) on host d2410.halxg.cloudera.com:22000 completed, 74 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.109669 45490 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.121709 29444 coordinator.cc:1558] Fragment instance 49(3045db9f916d3ae1:2b6258aae4211ee0) on host d2405.halxg.cloudera.com:22000 completed, 73 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.121904 29444 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.124702 60080 coordinator.cc:1558] Fragment instance 42(3045db9f916d3ae1:2b6258aae4211ed9) on host d2402.halxg.cloudera.com:22000 completed, 72 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.124932 60080 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.125041 29433 coordinator.cc:1558] Fragment instance 47(3045db9f916d3ae1:2b6258aae4211ede) on host d2409.halxg.cloudera.com:22000 completed, 71 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.125260 29433 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.128077 60812 coordinator.cc:1558] Fragment instance 41(3045db9f916d3ae1:2b6258aae4211ed8) on host d2418.halxg.cloudera.com:22000 completed, 70 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.128195 60812 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.129062 59958 coordinator.cc:1558] Fragment instance 46(3045db9f916d3ae1:2b6258aae4211edd) on host d2419.halxg.cloudera.com:22000 completed, 69 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.129221 59958 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.130450 59956 coordinator.cc:1558] Fragment instance 56(3045db9f916d3ae1:2b6258aae4211ee7) on host d2404.halxg.cloudera.com:22000 completed, 68 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.130563 59956 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.133251 59953 coordinator.cc:1558] Fragment instance 44(3045db9f916d3ae1:2b6258aae4211edb) on host d2407.halxg.cloudera.com:22000 completed, 67 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.133397 59953 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.134409 59962 coordinator.cc:1558] Fragment instance 52(3045db9f916d3ae1:2b6258aae4211ee3) on host d2406.halxg.cloudera.com:22000 completed, 66 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.134523 59962 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.136569 29438 coordinator.cc:1558] Fragment instance 48(3045db9f916d3ae1:2b6258aae4211edf) on host d2416.halxg.cloudera.com:22000 completed, 65 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.136885 29438 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.137004 63582 coordinator.cc:1558] Fragment instance 45(3045db9f916d3ae1:2b6258aae4211edc) on host d2411.halxg.cloudera.com:22000 completed, 64 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.137295 63582 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.137411 60388 coordinator.cc:1558] Fragment instance 51(3045db9f916d3ae1:2b6258aae4211ee2) on host d2413.halxg.cloudera.com:22000 completed, 63 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.137534 60388 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.140219 54350 coordinator.cc:1558] Fragment instance 55(3045db9f916d3ae1:2b6258aae4211ee6) on host d2408.halxg.cloudera.com:22000 completed, 62 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.140357 54350 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.141469 46325 coordinator.cc:1558] Fragment instance 54(3045db9f916d3ae1:2b6258aae4211ee5) on host d2403.halxg.cloudera.com:22000 completed, 61 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.141613 46325 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.142362 54375 coordinator.cc:1558] Fragment instance 53(3045db9f916d3ae1:2b6258aae4211ee4) on host d2415.halxg.cloudera.com:22000 completed, 60 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.142457 54375 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.146039 54378 coordinator.cc:1558] Fragment instance 58(3045db9f916d3ae1:2b6258aae4211ee9) on host d2420.halxg.cloudera.com:22000 completed, 59 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.146149 54378 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.178194 65351 coordinator.cc:1558] Fragment instance 50(3045db9f916d3ae1:2b6258aae4211ee1) on host d2414.halxg.cloudera.com:22000 completed, 58 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.178395 65351 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.179371 60284 coordinator.cc:1558] Fragment instance 43(3045db9f916d3ae1:2b6258aae4211eda) on host d2417.halxg.cloudera.com:22000 completed, 57 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.179548 60284 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.869339 54378 coordinator.cc:1558] Fragment instance 75(3045db9f916d3ae1:2b6258aae4211efa) on host d2420.halxg.cloudera.com:22000 completed, 56 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.869643 54378 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.902484 59953 coordinator.cc:1558] Fragment instance 59(3045db9f916d3ae1:2b6258aae4211eea) on host d2407.halxg.cloudera.com:22000 completed, 55 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.902755 59953 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.912653 29548 coordinator.cc:1558] Fragment instance 62(3045db9f916d3ae1:2b6258aae4211eed) on host d2413.halxg.cloudera.com:22000 completed, 54 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.912870 29548 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.918509 59960 coordinator.cc:1558] Fragment instance 70(3045db9f916d3ae1:2b6258aae4211ef5) on host d2403.halxg.cloudera.com:22000 completed, 53 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.918643 59960 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.920573 57185 coordinator.cc:1558] Fragment instance 64(3045db9f916d3ae1:2b6258aae4211eef) on host d2414.halxg.cloudera.com:22000 completed, 52 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.920750 57185 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.926792 59962 coordinator.cc:1558] Fragment instance 61(3045db9f916d3ae1:2b6258aae4211eec) on host d2406.halxg.cloudera.com:22000 completed, 51 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.927026 59962 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.927680 54359 coordinator.cc:1558] Fragment instance 69(3045db9f916d3ae1:2b6258aae4211ef4) on host d2408.halxg.cloudera.com:22000 completed, 50 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.927866 54359 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.928971  9623 coordinator.cc:1558] Fragment instance 63(3045db9f916d3ae1:2b6258aae4211eee) on host d2416.halxg.cloudera.com:22000 completed, 49 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.929157  9623 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.929368 65094 coordinator.cc:1558] Fragment instance 60(3045db9f916d3ae1:2b6258aae4211eeb) on host d2412.halxg.cloudera.com:22000 completed, 48 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.929602 65094 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.930686 59946 coordinator.cc:1558] Fragment instance 72(3045db9f916d3ae1:2b6258aae4211ef7) on host d2409.halxg.cloudera.com:22000 completed, 47 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.930847 59946 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.932231 63755 coordinator.cc:1558] Fragment instance 65(3045db9f916d3ae1:2b6258aae4211ef0) on host d2405.halxg.cloudera.com:22000 completed, 46 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.932415 63755 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.933053 29441 coordinator.cc:1558] Fragment instance 74(3045db9f916d3ae1:2b6258aae4211ef9) on host d2404.halxg.cloudera.com:22000 completed, 45 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.933336 29441 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.933432 54349 coordinator.cc:1558] Fragment instance 68(3045db9f916d3ae1:2b6258aae4211ef3) on host d2415.halxg.cloudera.com:22000 completed, 44 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.933536 54349 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.933691 59955 coordinator.cc:1558] Fragment instance 66(3045db9f916d3ae1:2b6258aae4211ef1) on host d2417.halxg.cloudera.com:22000 completed, 43 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.933792 59955 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:04.998131 29451 coordinator.cc:1558] Fragment instance 73(3045db9f916d3ae1:2b6258aae4211ef8) on host d2418.halxg.cloudera.com:22000 completed, 42 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:04.998384 29451 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:05.003689 63582 coordinator.cc:1558] Fragment instance 67(3045db9f916d3ae1:2b6258aae4211ef2) on host d2411.halxg.cloudera.com:22000 completed, 41 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:05.003857 63582 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:05.008291 46328 coordinator.cc:1558] Fragment instance 71(3045db9f916d3ae1:2b6258aae4211ef6) on host d2419.halxg.cloudera.com:22000 completed, 40 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:05.008476 46328 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:23.084043 64653 hdfs-scan-node.cc:209] Only following filters arrived: 0, 3, 4, waited 19s253ms
I0304 08:43:24.467447 65064 coordinator.cc:1558] Fragment instance 24(3045db9f916d3ae1:2b6258aae4211ec7) on host d2405.halxg.cloudera.com:22000 completed, 39 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.467819 65064 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.664649  3765 coordinator.cc:1558] Fragment instance 30(3045db9f916d3ae1:2b6258aae4211ecd) on host d2403.halxg.cloudera.com:22000 completed, 38 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.664862  3765 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.699779 59953 coordinator.cc:1558] Fragment instance 26(3045db9f916d3ae1:2b6258aae4211ec9) on host d2407.halxg.cloudera.com:22000 completed, 37 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.700022 59953 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.740375 57185 coordinator.cc:1558] Fragment instance 23(3045db9f916d3ae1:2b6258aae4211ec6) on host d2414.halxg.cloudera.com:22000 completed, 36 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.740525 57185 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.774204 54375 coordinator.cc:1558] Fragment instance 29(3045db9f916d3ae1:2b6258aae4211ecc) on host d2415.halxg.cloudera.com:22000 completed, 35 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.774338 54375 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.822388 64653 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ed5, node=13
I0304 08:43:24.822504 64653 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ed5 node_id=13
I0304 08:43:24.822599 64653 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ed5, node=14
I0304 08:43:24.822679 64653 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ed5 node_id=14
I0304 08:43:24.822758 64653 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ed5, node=15
I0304 08:43:24.824297 64653 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ed5 node_id=15
I0304 08:43:24.828510 64653 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ed5, node=16
I0304 08:43:24.828625 64653 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ed5 node_id=16
I0304 08:43:24.828698 64653 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ed5, node=17
I0304 08:43:24.828765 64653 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ed5 node_id=17
I0304 08:43:24.832020  2519 coordinator.cc:1558] Fragment instance 36(3045db9f916d3ae1:2b6258aae4211ed3) on host d2406.halxg.cloudera.com:22000 completed, 34 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.832139  2519 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.837862 63979 coordinator.cc:1558] Fragment instance 38(3045db9f916d3ae1:2b6258aae4211ed5) on host d2402.halxg.cloudera.com:22000 completed, 33 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.838033 63979 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.848731 54350 coordinator.cc:1558] Fragment instance 31(3045db9f916d3ae1:2b6258aae4211ece) on host d2408.halxg.cloudera.com:22000 completed, 32 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.849431 54350 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.855193 59950 coordinator.cc:1558] Fragment instance 22(3045db9f916d3ae1:2b6258aae4211ec5) on host d2418.halxg.cloudera.com:22000 completed, 31 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.855370 59950 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:24.880036 45493 coordinator.cc:1558] Fragment instance 33(3045db9f916d3ae1:2b6258aae4211ed0) on host d2410.halxg.cloudera.com:22000 completed, 30 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:24.880249 45493 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.007158  3843 coordinator.cc:1558] Fragment instance 37(3045db9f916d3ae1:2b6258aae4211ed4) on host d2413.halxg.cloudera.com:22000 completed, 29 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.011041  3843 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.026512 65394 coordinator.cc:1558] Fragment instance 20(3045db9f916d3ae1:2b6258aae4211ec3) on host d2412.halxg.cloudera.com:22000 completed, 28 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.026708 65394 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.053685  2521 coordinator.cc:1558] Fragment instance 28(3045db9f916d3ae1:2b6258aae4211ecb) on host d2409.halxg.cloudera.com:22000 completed, 27 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.053856  2521 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.187726 46328 coordinator.cc:1558] Fragment instance 27(3045db9f916d3ae1:2b6258aae4211eca) on host d2419.halxg.cloudera.com:22000 completed, 26 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.187880 46328 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.229630  1293 coordinator.cc:1558] Fragment instance 21(3045db9f916d3ae1:2b6258aae4211ec4) on host d2411.halxg.cloudera.com:22000 completed, 25 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.229789  1293 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.250634 59955 coordinator.cc:1558] Fragment instance 39(3045db9f916d3ae1:2b6258aae4211ed6) on host d2417.halxg.cloudera.com:22000 completed, 24 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.250823 59955 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.257446 29436 coordinator.cc:1558] Fragment instance 35(3045db9f916d3ae1:2b6258aae4211ed2) on host d2420.halxg.cloudera.com:22000 completed, 23 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.257657 29436 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.348786 46324 coordinator.cc:1558] Fragment instance 32(3045db9f916d3ae1:2b6258aae4211ecf) on host d2421.halxg.cloudera.com:22000 completed, 22 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.348960 46324 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.493970 29551 coordinator.cc:1558] Fragment instance 25(3045db9f916d3ae1:2b6258aae4211ec8) on host d2416.halxg.cloudera.com:22000 completed, 21 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.494159 29551 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2412.halxg.cloudera.com:22000
I0304 08:43:25.636137  3763 coordinator.cc:1558] Fragment instance 0(3045db9f916d3ae1:2b6258aae4211eaf) on host d2412.halxg.cloudera.com:22000 completed, 20 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.636353  3763 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2411.halxg.cloudera.com:22000
I0304 08:43:25.636734 65360 coordinator.cc:1558] Fragment instance 2(3045db9f916d3ae1:2b6258aae4211eb1) on host d2418.halxg.cloudera.com:22000 completed, 19 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.637181 65360 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2405.halxg.cloudera.com:22000
I0304 08:43:25.637509 63582 coordinator.cc:1558] Fragment instance 1(3045db9f916d3ae1:2b6258aae4211eb0) on host d2411.halxg.cloudera.com:22000 completed, 18 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.637713 63582 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2416.halxg.cloudera.com:22000
I0304 08:43:25.637847  8242 coordinator.cc:1558] Fragment instance 3(3045db9f916d3ae1:2b6258aae4211eb2) on host d2414.halxg.cloudera.com:22000 completed, 17 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.638392  8242 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2409.halxg.cloudera.com:22000
I0304 08:43:25.638576 65366 coordinator.cc:1558] Fragment instance 4(3045db9f916d3ae1:2b6258aae4211eb3) on host d2405.halxg.cloudera.com:22000 completed, 16 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.638960 65366 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2403.halxg.cloudera.com:22000
I0304 08:43:25.639104 18852 coordinator.cc:1558] Fragment instance 6(3045db9f916d3ae1:2b6258aae4211eb5) on host d2407.halxg.cloudera.com:22000 completed, 15 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.639371 18852 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2408.halxg.cloudera.com:22000
I0304 08:43:25.639468 29438 coordinator.cc:1558] Fragment instance 5(3045db9f916d3ae1:2b6258aae4211eb4) on host d2416.halxg.cloudera.com:22000 completed, 14 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.639575 29438 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2408.halxg.cloudera.com:22000
I0304 08:43:25.639822 54358 coordinator.cc:1558] Fragment instance 9(3045db9f916d3ae1:2b6258aae4211eb8) on host d2415.halxg.cloudera.com:22000 completed, 13 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.640169 54358 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2410.halxg.cloudera.com:22000
I0304 08:43:25.640296 46325 coordinator.cc:1558] Fragment instance 10(3045db9f916d3ae1:2b6258aae4211eb9) on host d2403.halxg.cloudera.com:22000 completed, 12 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.640446 46325 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2404.halxg.cloudera.com:22000
I0304 08:43:25.640537 63584 coordinator.cc:1558] Fragment instance 12(3045db9f916d3ae1:2b6258aae4211ebb) on host d2421.halxg.cloudera.com:22000 completed, 11 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.640643 63584 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2404.halxg.cloudera.com:22000
I0304 08:43:25.640744 54365 coordinator.cc:1558] Fragment instance 11(3045db9f916d3ae1:2b6258aae4211eba) on host d2408.halxg.cloudera.com:22000 completed, 10 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.640990 64627 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211ec1, node=18
I0304 08:43:25.641131 54365 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2420.halxg.cloudera.com:22000
I0304 08:43:25.641151 64627 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211ec1 node_id=18
I0304 08:43:25.641240 65363 coordinator.cc:1558] Fragment instance 13(3045db9f916d3ae1:2b6258aae4211ebc) on host d2410.halxg.cloudera.com:22000 completed, 9 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.642061 65363 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2420.halxg.cloudera.com:22000
I0304 08:43:25.642161 29433 coordinator.cc:1558] Fragment instance 8(3045db9f916d3ae1:2b6258aae4211eb7) on host d2409.halxg.cloudera.com:22000 completed, 8 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.642519 29433 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2420.halxg.cloudera.com:22000
I0304 08:43:25.642801 55306 coordinator.cc:1558] Fragment instance 7(3045db9f916d3ae1:2b6258aae4211eb6) on host d2419.halxg.cloudera.com:22000 completed, 7 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.642997 55306 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2417.halxg.cloudera.com:22000
I0304 08:43:25.643108 65365 coordinator.cc:1558] Fragment instance 16(3045db9f916d3ae1:2b6258aae4211ebf) on host d2406.halxg.cloudera.com:22000 completed, 6 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.643283 65365 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2404.halxg.cloudera.com:22000
I0304 08:43:25.643376 65093 coordinator.cc:1558] Fragment instance 14(3045db9f916d3ae1:2b6258aae4211ebd) on host d2404.halxg.cloudera.com:22000 completed, 5 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.643471 65093 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2404.halxg.cloudera.com:22000
I0304 08:43:25.643566 59947 coordinator.cc:1558] Fragment instance 17(3045db9f916d3ae1:2b6258aae4211ec0) on host d2413.halxg.cloudera.com:22000 completed, 4 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.643661 59947 coordinator.cc:1570] query_id=3045db9f916d3ae1:2b6258aae4211ead: first in-progress backend: d2404.halxg.cloudera.com:22000
I0304 08:43:25.644064 14078 coordinator.cc:1558] Fragment instance 19(3045db9f916d3ae1:2b6258aae4211ec2) on host d2417.halxg.cloudera.com:22000 completed, 3 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.644534  2368 coordinator.cc:1558] Fragment instance 18(3045db9f916d3ae1:2b6258aae4211ec1) on host d2402.halxg.cloudera.com:22000 completed, 2 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.644675  2523 coordinator.cc:1558] Fragment instance 34(3045db9f916d3ae1:2b6258aae4211ed1) on host d2404.halxg.cloudera.com:22000 completed, 1 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:25.647965 54360 coordinator.cc:1558] Fragment instance 15(3045db9f916d3ae1:2b6258aae4211ebe) on host d2420.halxg.cloudera.com:22000 completed, 0 remaining: query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:26.033028 59579 impala-beeswax-server.cc:307] get_results_metadata(): query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:26.034620 59579 plan-fragment-executor.cc:473] Finished executing fragment query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211eae
I0304 08:43:26.036180 59579 plan-fragment-executor.cc:473] Finished executing fragment query_id=3045db9f916d3ae1:2b6258aae4211ead instance_id=3045db9f916d3ae1:2b6258aae4211eae
I0304 08:43:26.036401 59579 data-stream-mgr.cc:252] cancelling all streams for fragment=3045db9f916d3ae1:2b6258aae4211eae
I0304 08:43:26.036540 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.036692 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.036816 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.036952 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037106 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037250 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037372 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037484 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037613 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037698 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037777 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037853 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.037940 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038103 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038231 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038329 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038414 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038492 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038570 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038648 59579 data-stream-recvr.cc:233] cancelled stream: fragment_instance_id_=3045db9f916d3ae1:2b6258aae4211eae node_id=20
I0304 08:43:26.038980 59579 coordinator.cc:968] All backends finished successfully.
I0304 08:43:26.079493 59579 impala-beeswax-server.cc:349] close(): query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:26.079669 59579 impala-server.cc:915] UnregisterQuery(): query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:26.079792 59579 impala-server.cc:1001] Cancel(): query_id=3045db9f916d3ae1:2b6258aae4211ead
I0304 08:43:26.164808 59579 data-stream-mgr.cc:220] DeregisterRecvr(): fragment_instance_id=3045db9f916d3ae1:2b6258aae4211eae, node=20