Mryange opened a new pull request, #27114:
URL: https://github.com/apache/doris/pull/27114

   ## Proposed changes
   There is a 'join,' so it is a blocking sink operation
   ```
               PipelineXTask  (index=11):
                     -  WaitBfTime:  avg  0ns,  max  0ns,  min  0ns
                     -  WaitSinkTime:  avg  1.293ms,  max  1.483ms,  min  0ns
                     -  WaitSourceTime:  avg  138.421us,  max  1.107ms,  min  
0ns
                     -  WaitWorkerTime:  avg  22.629us,  max  30.777us,  min  
15.1us
               HASH_JOIN_SINK_OPERATOR  (id=8488):
                     -  CloseTime:  avg  0ns,  max  0ns,  min  0ns
                     -  ExecTime:  avg  130.85us,  max  283.816us,  min  
93.233us
                     -  InputRows:  31
                     -  OpenTime:  avg  75.607us,  max  88.884us,  min  69.628us
               EXCHANGE_OPERATOR  (id=8485):
                     -  PlanInfo
                           -  offset:  0
                     -  BlocksReturned:  12
                     -  CloseTime:  avg  10.335us,  max  34.364us,  min  3.754us
                     -  ExecTime:  avg  42.228us,  max  143.889us,  min  
18.489us
                     -  OpenTime:  avg  15.610us,  max  21.587us,  min  13.55us
                     -  ProjectionTime:  avg  0ns,  max  0ns,  min  0ns
                     -  RowsReturned:  31
   ```
   
   There is a 'scan,' so it requires waiting for the runtime 
   ```
           PipelineXTask  (index=5):
                 -  WaitBfTime:  avg  1s37ms,  max  1s37ms,  min  1s37ms
                 -  WaitSinkTime:  avg  0ns,  max  0ns,  min  0ns
                 -  WaitSourceTime:  avg  213.810ms,  max  318.439ms,  min  
27.976ms
                 -  WaitWorkerTime:  avg  289.768us,  max  678.914us,  min  
91.868us
           DATA_STREAM_SINK_OPERATOR  (id=8421,dest_id=8421):
                 -  BlocksSent:  160
                 -  CloseTime:  avg  17.386us,  max  21.958us,  min  15.101us
                 -  ExecTime:  avg  32.292ms,  max  46.693ms,  min  22.74ms
                 -  InputRows:  433.0K  (433000)
                 -  OpenTime:  avg  55.635us,  max  74.873us,  min  38.377us
           OLAP_SCAN_OPERATOR  (id=8418):
                 -  PlanInfo
                       -  TABLE:  default_cluster:tpcds30G.customer(customer),  
PREAGGREGATION:  ON
                       -  runtime  filters:  RF007[bloom]  ->  c_customer_sk
                       -  partitions=1/1,  tablets=12/12,  
tabletList=106727,106729,106731  ...
                       -  cardinality=433000,  avgRowSize=302.01877,  numNodes=1
                       -  pushAggOp=NONE
   ```
   <!--Describe your changes.-->
   
   ## Further comments
   
   If this is a relatively large or complex change, kick off the discussion at 
[[email protected]](mailto:[email protected]) by explaining why you 
chose the solution you did and what alternatives you considered, etc...
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to