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

   ## Proposed changes
   
   "operator_id" should be invisible, but the local shuffle is a planned 
operator in the BE (Backend), without a plan node ID. We use it in profiles and 
other places, and there might be duplicates. Therefore, we switch it to a 
negative number here to distinguish it as a plan node ID.
   
   before
   ```
                     Pipeline  :  2(instance_num=8):
                         LOCAL_EXCHANGE_SINK_OPERATOR  (PASSTHROUGH)  (id=4):
                               -  CloseTime:  avg  0ns,  max  0ns,  min  0ns
                               -  ExecTime:  avg  6.64ms,  max  7.853ms,  min  
2.949ms
                               -  InputRows:  sum  12.077321M  (12077321),  avg 
 1.509665M  (1509665),  max  1.51194M  (1511940),  min  1.507361M  (1507361)
                               -  OpenTime:  avg  1.929us,  max  4.69us,  min  
1.2us
                               -  
WaitForDependency[LocalExchangeSinkDependency]Time:  avg  0ns,  max  0ns,  min  
0ns
                             OLAP_SCAN_OPERATOR  (id=370.  table  name  =  
lineorder):
   
   ```
   now
   ```
            Pipeline  :  2(instance_num=8):
                         LOCAL_EXCHANGE_SINK_OPERATOR  (PASSTHROUGH)  (id=-4):
                               -  CloseTime:  avg  0ns,  max  0ns,  min  0ns
                               -  ExecTime:  avg  2.347ms,  max  5.184ms,  min  
1.757ms
                               -  InputRows:  sum  12.077321M  (12077321),  avg 
 1.509665M  (1509665),  max  1.51194M  (1511940),  min  1.507361M  (1507361)
                               -  OpenTime:  avg  1.253us,  max  2.85us,  min  
1.10us
                               -  
WaitForDependency[LocalExchangeSinkDependency]Time:  avg  0ns,  max  0ns,  min  
0ns
                             OLAP_SCAN_OPERATOR  (id=370.  table  name  =  
lineorder):
                                   -  PlanInfo
   ```
   
   This is a temporary solution; in reality, the runtime state is at the 
pipeline task level. We don't need a fragment-level ID (as you can see in 'get 
sink state,' the ID passed is not used, as each task has only one sink).
   
   <!--Describe your changes.-->
   
   ## Further comments
   
   If this is a relatively large or complex change, kick off the discussion at 
[d...@doris.apache.org](mailto:d...@doris.apache.org) 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: commits-unsubscr...@doris.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to