Wang, Fei 8a0d0d5fd4 [CELEBORN-2075] Fix OpenStreamTime metrics for PbOpenStreamList request ... ### What changes were proposed in this pull request? Fix OpenStreamTime metrics for PbOpenStreamList request ### Why are the changes needed? For `PbOpenStreamList` request, the `OpenStreamTime` metrics is not calculated. cf3c05d668/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala (L140-L160) And the `workerSource.stopTimer(WorkerSource.OPEN_STREAM_TIME, shuffleKey) ` is meaningless inside `handleReduceOpenStreamInternal`. cf3c05d668/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala (L335-L341) The `handleReduceOpenStreamInternal` is called in 1. inside `handleOpenStreamInternal`, the `OpenStreamTime` metrics is handled correctly 2. for `PbOpenStreamList, the `OpenStreamTime` metrics is not handled. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Manually testing. Closes #3376 from turboFei/buf_size. Authored-by: Wang, Fei <fwang12@ebay.com> Signed-off-by: SteNicholas <programgeek@163.com>		2025-07-22 17:52:38 +08:00
..
src	[CELEBORN-2075] Fix OpenStreamTime metrics for PbOpenStreamList request	2025-07-22 17:52:38 +08:00
pom.xml	[CELEBORN-1994] Introduce disruptor dependency to support asynchronous logging of log4j2	2025-05-13 19:45:51 +08:00