path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor charts/celeborn/ci/values.yaml 99 5 357 10 6 2 2024-05-16 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/serviceaccount.yaml 22 1 141 141 1 1 2024-12-18 2024-12-18 luoyedeyi@163.com luoyedeyi@163.com charts/celeborn/templates/configmap.yaml 46 16 848 10 16 7 2023-01-11 2025-04-28 52876270+zwangsheng@users.noreply.github.com github@chenyicn.net charts/celeborn/templates/rolebinding.yaml 29 1 136 136 1 1 2024-12-23 2024-12-23 luoyedeyi@163.com luoyedeyi@163.com charts/celeborn/templates/_helpers.tpl 106 6 848 36 7 4 2023-01-11 2025-04-02 52876270+zwangsheng@users.noreply.github.com github@chenyicn.net charts/celeborn/templates/worker/priorityclass.yaml 23 4 359 10 4 1 2024-05-14 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/worker/_helpers.tpl 103 2 36 10 2 1 2025-04-02 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/worker/service.yaml 28 4 359 36 4 2 2024-05-14 2025-04-02 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/worker/podmonitor.yaml 37 3 359 36 3 1 2024-05-14 2025-04-02 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/worker/statefulset.yaml 154 11 359 10 15 4 2024-05-14 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/role.yaml 23 1 136 136 1 1 2024-12-23 2024-12-23 luoyedeyi@163.com luoyedeyi@163.com charts/celeborn/templates/master/priorityclass.yaml 23 4 359 10 4 1 2024-05-14 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/master/_helpers.tpl 81 2 36 10 2 1 2025-04-02 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/master/service.yaml 63 6 359 10 6 3 2024-05-14 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/master/podmonitor.yaml 37 3 359 36 3 1 2024-05-14 2025-04-02 github@chenyicn.net github@chenyicn.net charts/celeborn/templates/master/statefulset.yaml 151 11 359 10 16 4 2024-05-14 2025-04-28 github@chenyicn.net github@chenyicn.net charts/celeborn/files/conf/log4j2.xml 57 1 38 38 1 1 2025-03-31 2025-03-31 github@chenyicn.net github@chenyicn.net charts/celeborn/values.yaml 158 26 848 10 32 13 2023-01-11 2025-04-28 52876270+zwangsheng@users.noreply.github.com github@chenyicn.net charts/celeborn/Chart.yaml 13 4 848 358 4 3 2023-01-11 2024-05-15 52876270+zwangsheng@users.noreply.github.com github@chenyicn.net client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornConcatenatedMergedKeyValuesInput.java 75 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedInputLegacy.java 56 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedMergedKVInput.java 185 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornConcatenatedMergedKeyValueInput.java 75 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornUnorderedKVInput.java 259 2 153 146 2 1 2024-12-06 2024-12-13 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedKVInput.java 263 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornScheduler.java 308 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornTezBypassWriter.java 51 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornShuffle.java 63 2 153 146 2 1 2024-12-06 2024-12-13 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornTezShuffleDataFetcher.java 183 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornFetcher.java 149 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornShuffleManager.java 427 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/writers/CelebornUnorderedPartitionedKVWriter.java 149 1 154 154 1 1 2024-12-05 2024-12-05 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornSorter.java 92 1 154 154 1 1 2024-12-05 2024-12-05 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornTezPerPartitionRecord.java 43 1 154 154 1 1 2024-12-05 2024-12-05 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornSortBasedPusher.java 289 1 156 156 1 1 2024-12-03 2024-12-03 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedPartitionedKVOutput.java 177 2 154 146 2 1 2024-12-05 2024-12-13 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornOrderedPartitionedKVOutput.java 135 2 154 146 2 1 2024-12-05 2024-12-13 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedKVOutput.java 210 2 154 146 2 1 2024-12-05 2024-12-13 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/tez/dag/app/CelebornDagAppMaster.java 394 2 167 146 2 2 2024-11-22 2024-12-13 fengmingxiao.fmx@alibaba-inc.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/celeborn/tez/plugin/util/ChecksumUtils.java 17 1 153 153 1 1 2024-12-06 2024-12-06 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/celeborn/tez/plugin/util/CelebornTezUtils.java 70 1 167 167 1 1 2024-11-22 2024-11-22 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-tez/tez/src/main/java/org/apache/celeborn/client/CelebornTezWriter.java 99 1 156 156 1 1 2024-12-03 2024-12-03 hongguangwei@bytedance.com hongguangwei@bytedance.com client-tez/tez/src/main/java/org/apache/celeborn/client/CelebornTezReader.java 62 2 156 108 2 2 2024-12-03 2025-01-20 hongguangwei@bytedance.com programgeek@163.com client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 134 3 297 31 3 2 2024-07-15 2025-04-07 mridulatgmail.com programgeek@163.com client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 60 2 297 272 2 2 2024-07-15 2024-08-09 mridulatgmail.com reswqa@163.com client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 39 4 297 31 4 2 2024-07-15 2025-04-07 mridulatgmail.com programgeek@163.com client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 32 2 297 272 2 2 2024-07-15 2024-08-09 mridulatgmail.com reswqa@163.com client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 43 3 297 128 3 3 2024-07-15 2024-12-31 mridulatgmail.com programgeek@163.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 134 4 734 31 4 2 2023-05-05 2025-04-07 ethanfeng@apache.org programgeek@163.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 60 3 734 272 3 2 2023-05-05 2024-08-09 ethanfeng@apache.org reswqa@163.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 39 5 734 31 5 2 2023-05-05 2025-04-07 ethanfeng@apache.org programgeek@163.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 32 4 734 272 4 3 2023-05-05 2024-08-09 ethanfeng@apache.org reswqa@163.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 47 6 734 128 7 5 2023-05-05 2024-12-31 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java 261 3 735 394 4 3 2023-05-04 2024-04-09 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java 132 2 128 31 2 1 2024-12-31 2025-04-07 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartition.java 175 1 128 128 1 1 2024-12-31 2024-12-31 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/Utils.java 35 1 869 869 1 1 2022-12-21 2022-12-21 chengpan@apache.org chengpan@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java 53 9 735 121 9 4 2023-05-04 2025-01-07 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java 105 5 869 185 5 5 2022-12-21 2024-11-04 chengpan@apache.org tanyuxinwork@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleDescriptor.java 56 1 735 735 1 1 2023-05-04 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java 226 7 735 125 7 7 2023-05-04 2025-01-03 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java 82 3 735 31 4 2 2023-05-04 2025-04-07 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java 197 1 128 128 1 1 2024-12-31 2024-12-31 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java 280 18 735 128 18 7 2023-05-04 2024-12-31 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/netty/NettyShuffleEnvironmentWrapper.java 63 1 128 128 1 1 2024-12-31 2024-12-31 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java 131 10 735 125 10 8 2023-05-04 2025-01-03 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java 159 4 735 136 4 4 2023-05-04 2024-12-23 ethanfeng@apache.org fwang12@ebay.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResource.java 5 1 735 735 1 1 2023-05-04 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java 618 3 125 20 3 3 2025-01-03 2025-04-18 programgeek@163.com jiangyanze.jyz@antgroup.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/CelebornBufferStream.java 288 1 125 125 1 1 2025-01-03 2025-01-03 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/FlinkResultPartitionInfo.java 51 3 735 237 3 3 2023-05-04 2024-09-13 ethanfeng@apache.org reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java 71 7 735 128 8 4 2023-05-04 2024-12-31 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java 41 3 735 674 3 3 2023-05-04 2023-07-04 ethanfeng@apache.org angers.zhu@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java 51 4 811 203 6 2 2023-02-17 2024-10-17 ethanfeng@apache.org reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/SubPartitionReadData.java 49 2 251 203 2 1 2024-08-30 2024-10-17 reswqa@163.com reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfo.java 67 2 735 287 2 2 2023-05-04 2024-07-25 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java 73 6 811 251 6 3 2023-02-17 2024-08-30 ethanfeng@apache.org reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java 40 13 811 126 14 10 2023-02-17 2025-01-02 ethanfeng@apache.org chengpan@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java 228 8 811 185 10 5 2023-02-17 2024-11-04 ethanfeng@apache.org tanyuxinwork@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java 136 15 811 203 16 7 2023-02-17 2024-10-17 ethanfeng@apache.org reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java 291 10 869 185 10 8 2022-12-21 2024-11-04 chengpan@apache.org tanyuxinwork@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java 156 4 811 287 4 3 2023-02-17 2024-07-25 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBasedDataBuffer.java 273 1 394 394 1 1 2024-04-09 2024-04-09 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferWithSubpartition.java 17 1 394 394 1 1 2024-04-09 2024-04-09 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/ReceivedNoHeaderBufferPacker.java 67 1 230 230 1 1 2024-09-20 2024-09-20 reswqa@163.com reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferHeader.java 46 2 869 230 2 2 2022-12-21 2024-09-20 chengpan@apache.org reswqa@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java 44 2 811 402 2 2 2023-02-17 2024-04-01 ethanfeng@apache.org mridulatgmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/DataBuffer.java 20 1 394 394 1 1 2024-04-09 2024-04-09 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/CreditListener.java 21 1 811 811 1 1 2023-02-17 2023-02-17 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferRecycler.java 5 1 811 811 1 1 2023-02-17 2023-02-17 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/Buffer.java 19 1 811 811 1 1 2023-02-17 2023-02-17 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/QuotaFallbackPolicy.java 29 1 162 162 1 1 2024-11-27 2024-11-27 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ForceFallbackPolicy.java 25 1 162 162 1 1 2024-11-27 2024-11-27 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/WorkersAvailableFallbackPolicy.java 27 1 162 162 1 1 2024-11-27 2024-11-27 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyFactory.java 21 1 162 162 1 1 2024-11-27 2024-11-27 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicy.java 10 1 162 162 1 1 2024-11-27 2024-11-27 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyRunner.java 31 2 162 139 2 1 2024-11-27 2024-12-20 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceDescriptor.java 37 1 735 735 1 1 2023-05-04 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java 455 10 735 125 10 7 2023-05-04 2025-01-03 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java 133 8 735 128 8 3 2023-05-04 2024-12-31 ethanfeng@apache.org programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RequestedMemoryUsageMetric.java 18 1 128 128 1 1 2024-12-31 2024-12-31 programgeek@163.com programgeek@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RemoteShuffleMetricFactory.java 41 1 128 128 1 1 2024-12-31 2024-12-31 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java 41 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java 269 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java 386 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java 90 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java 464 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java 172 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java 123 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 135 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 64 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 37 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 33 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 47 1 31 31 1 1 2025-04-07 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 135 3 414 31 3 1 2024-03-20 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 60 2 414 272 2 2 2024-03-20 2024-08-09 programgeek@163.com reswqa@163.com client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 39 4 414 31 4 1 2024-03-20 2025-04-07 programgeek@163.com programgeek@163.com client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 32 2 414 272 2 2 2024-03-20 2024-08-09 programgeek@163.com reswqa@163.com client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 47 4 414 128 4 2 2024-03-20 2024-12-31 programgeek@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java 41 1 237 237 1 1 2024-09-13 2024-09-13 reswqa@163.com reswqa@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java 269 4 203 78 4 3 2024-10-17 2025-02-19 reswqa@163.com zuosi.hx@alibaba-inc.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java 386 4 230 125 4 3 2024-09-20 2025-01-03 reswqa@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java 83 4 237 185 4 2 2024-09-13 2024-11-04 reswqa@163.com tanyuxinwork@gmail.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java 464 4 203 125 4 3 2024-10-17 2025-01-03 reswqa@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java 172 3 237 169 3 2 2024-09-13 2024-11-20 reswqa@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java 123 2 203 78 2 2 2024-10-17 2025-02-19 reswqa@163.com zuosi.hx@alibaba-inc.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 135 3 272 31 3 2 2024-08-09 2025-04-07 reswqa@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 64 1 272 272 1 1 2024-08-09 2024-08-09 reswqa@163.com reswqa@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 37 4 272 31 4 2 2024-08-09 2025-04-07 reswqa@163.com programgeek@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 33 1 272 272 1 1 2024-08-09 2024-08-09 reswqa@163.com reswqa@163.com client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 47 3 272 128 3 2 2024-08-09 2024-12-31 reswqa@163.com programgeek@163.com client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 137 4 549 31 4 2 2023-11-06 2025-04-07 sychen@ctrip.com programgeek@163.com client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 60 2 549 272 2 2 2023-11-06 2024-08-09 sychen@ctrip.com reswqa@163.com client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 39 4 549 31 4 2 2023-11-06 2025-04-07 sychen@ctrip.com programgeek@163.com client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 32 3 549 272 3 2 2023-11-06 2024-08-09 sychen@ctrip.com reswqa@163.com client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 47 5 549 128 5 3 2023-11-06 2024-12-31 sychen@ctrip.com programgeek@163.com common/src/main/scala/org/apache/celeborn/common/metrics/CelebornHistogram.scala 3 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/CelebornTimer.scala 3 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/sink/CsvSink.scala 41 2 949 407 2 2 2022-10-02 2024-03-27 zky.zhoukeyong@alibaba-inc.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/metrics/sink/GraphiteSink.scala 55 2 949 407 2 2 2022-10-02 2024-03-27 zky.zhoukeyong@alibaba-inc.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/metrics/sink/Sink.scala 6 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/metrics/source/Source.scala 12 3 949 675 3 3 2022-10-02 2023-07-03 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala 619 33 949 10 35 17 2022-10-02 2025-04-28 zky.zhoukeyong@alibaba-inc.com nfraison@yahoo.fr common/src/main/scala/org/apache/celeborn/common/metrics/source/ResourceConsumptionSource.scala 13 4 826 461 4 2 2023-02-02 2024-02-02 angers.zhu@gmail.com programgeek@163.com common/src/main/scala/org/apache/celeborn/common/metrics/source/SystemMiscSource.scala 27 1 723 723 1 1 2023-05-16 2023-05-16 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/source/JVMSource.scala 69 5 949 518 5 4 2022-10-02 2023-12-07 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/scala/org/apache/celeborn/common/metrics/source/JVMCPUSource.scala 27 3 949 675 3 3 2022-10-02 2023-07-03 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/metrics/source/ThreadPoolSource.scala 151 2 468 388 2 2 2024-01-26 2024-04-15 angers.zhu@gmail.com programgeek@163.com common/src/main/scala/org/apache/celeborn/common/metrics/source/Role.scala 6 2 211 135 2 1 2024-10-09 2024-12-24 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/metrics/ResettableSlidingWindowReservoir.scala 37 2 949 504 2 2 2022-10-02 2023-12-21 zky.zhoukeyong@alibaba-inc.com 2081248500@qq.com common/src/main/scala/org/apache/celeborn/common/metrics/MetricsUtils.scala 13 1 407 407 1 1 2024-03-27 2024-03-27 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/metrics/MetricsConfig.scala 71 5 949 674 5 3 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala 10 4 831 675 4 4 2023-01-28 2023-07-03 30563796+nafiyaix@users.noreply.github.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/quota/WorkerTrafficQuota.scala 6 1 202 202 1 1 2024-10-18 2024-10-18 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala 73 3 932 45 3 3 2022-10-19 2025-03-24 30563796+nafiyaix@users.noreply.github.com 31424839+leixm@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/quota/UserTrafficQuota.scala 4 1 202 202 1 1 2024-10-18 2024-10-18 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/quota/StorageQuota.scala 20 1 45 45 1 1 2025-03-24 2025-03-24 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/serializer/JavaSerializer.scala 132 4 949 35 4 4 2022-10-02 2025-04-03 zky.zhoukeyong@alibaba-inc.com jiaming.xie7@gmail.com common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala 266 2 949 679 2 2 2022-10-02 2023-06-29 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/serializer/Serializer.scala 70 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala 5367 241 931 10 334 53 2022-10-20 2025-04-28 angers.zhu@gmail.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/util/KeyLock.scala 33 1 37 37 1 1 2025-04-01 2025-04-01 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/util/ByteBufferOutputStream.scala 30 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/Utils.scala 990 76 949 14 85 32 2022-10-02 2025-04-24 zky.zhoukeyong@alibaba-inc.com amandeeps.28@uber.com common/src/main/scala/org/apache/celeborn/common/util/NextIterator.scala 34 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/SignalUtils.scala 62 1 426 426 1 1 2024-03-08 2024-03-08 sychen@ctrip.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala 298 14 949 56 14 8 2022-10-02 2025-03-13 zky.zhoukeyong@alibaba-inc.com programgeek@163.com common/src/main/scala/org/apache/celeborn/common/util/ByteBufferInputStream.scala 44 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/FunctionConverter.scala 16 3 883 675 3 3 2022-12-07 2023-07-03 lvshuang.xjs@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala 113 11 779 1 11 7 2023-03-21 2025-05-07 angers.zhu@gmail.com nicolas.fraison@datadoghq.com common/src/main/scala/org/apache/celeborn/common/util/IntParam.scala 10 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/CelebornExitKind.scala 6 1 653 653 1 1 2023-07-25 2023-07-25 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala 643 41 920 27 47 21 2022-10-31 2025-04-11 30563796+nafiyaix@users.noreply.github.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/util/DiskUtils.scala 21 2 547 168 2 2 2023-11-08 2024-11-21 programgeek@163.com lyh-36@163.com common/src/main/scala/org/apache/celeborn/common/client/StaticMasterEndpointResolver.scala 26 2 274 252 2 2 2024-08-07 2024-08-29 sanskarmodi97@gmail.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/client/MasterEndpointResolver.scala 27 1 274 274 1 1 2024-08-07 2024-08-07 sanskarmodi97@gmail.com sanskarmodi97@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/FileCorruptedException.scala 6 1 754 754 1 1 2023-04-15 2023-04-15 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/DriverChangedException.scala 5 1 723 723 1 1 2023-05-16 2023-05-16 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/CelebornRuntimeException.scala 5 1 729 729 1 1 2023-05-10 2023-05-10 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/CelebornException.scala 5 1 912 912 1 1 2022-11-08 2022-11-08 490081539@qq.com 490081539@qq.com common/src/main/scala/org/apache/celeborn/common/exception/PartitionUnRetryAbleException.scala 6 1 754 754 1 1 2023-04-15 2023-04-15 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/AlreadyClosedException.scala 6 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/exception/CelebornIOException.scala 10 2 806 804 2 1 2023-02-22 2023-02-24 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala 55 5 949 80 5 5 2022-10-02 2025-02-17 zky.zhoukeyong@alibaba-inc.com shuaizhentao.szt@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpoint.scala 53 5 949 395 5 5 2022-10-02 2024-04-08 zky.zhoukeyong@alibaba-inc.com singh.chandni@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointNotFoundException.scala 4 2 949 912 2 2 2022-10-02 2022-11-08 zky.zhoukeyong@alibaba-inc.com 490081539@qq.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcCallContext.scala 34 3 949 395 3 3 2022-10-02 2024-04-08 zky.zhoukeyong@alibaba-inc.com singh.chandni@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala 509 25 949 35 26 15 2022-10-02 2025-04-03 zky.zhoukeyong@alibaba-inc.com jiaming.xie7@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/Outbox.scala 186 2 949 912 2 2 2022-10-02 2022-11-08 zky.zhoukeyong@alibaba-inc.com 490081539@qq.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala 177 10 949 143 10 9 2022-10-02 2024-12-16 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/Inbox.scala 285 5 949 171 5 5 2022-10-02 2024-11-18 zky.zhoukeyong@alibaba-inc.com fmerik@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/RpcEndpointVerifier.scala 12 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnv.scala 154 16 949 80 16 11 2022-10-02 2025-02-17 zky.zhoukeyong@alibaba-inc.com shuaizhentao.szt@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcSecurityContext.scala 96 2 469 441 2 2 2024-01-25 2024-02-22 singh.chandni@gmail.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnvStoppedException.scala 3 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcMetricsTracker.scala 128 3 171 59 3 2 2024-11-18 2025-03-10 fmerik@gmail.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcSource.scala 12 3 171 135 3 3 2024-11-18 2024-12-24 fmerik@gmail.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointAddress.scala 23 4 949 441 4 4 2022-10-02 2024-02-22 zky.zhoukeyong@alibaba-inc.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcAddress.scala 21 3 949 682 3 2 2022-10-02 2023-06-26 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/rpc/RpcTimeout.scala 49 3 949 163 3 3 2022-10-02 2024-11-26 zky.zhoukeyong@alibaba-inc.com programgeek@163.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcCallContext.scala 6 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala 1212 79 949 20 93 28 2022-10-02 2025-04-18 zky.zhoukeyong@alibaba-inc.com jiangyanze.jyz@antgroup.com common/src/main/scala/org/apache/celeborn/common/tags/WorkerTagsMeta.scala 12 1 163 163 1 1 2024-11-26 2024-11-26 sanskarmodi97@gmail.com sanskarmodi97@gmail.com common/src/main/scala/org/apache/celeborn/common/network/CelebornRackResolver.scala 122 2 779 421 2 2 2023-03-21 2024-03-13 angers.zhu@gmail.com apatnam@linkedin.com common/src/main/scala/org/apache/celeborn/common/authentication/AnonymousAuthenticationProviderImpl.scala 12 4 322 274 4 1 2024-06-20 2024-08-07 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/authentication/HttpAuthSchemes.scala 5 1 322 322 1 1 2024-06-20 2024-06-20 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/authentication/Credential.scala 12 2 307 287 2 1 2024-07-05 2024-07-25 fwang12@ebay.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala 16 8 949 14 8 7 2022-10-02 2025-04-24 zky.zhoukeyong@alibaba-inc.com amandeeps.28@uber.com common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala 10 2 731 14 2 2 2023-05-08 2025-04-24 ethanfeng@apache.org amandeeps.28@uber.com common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala 9 6 949 14 6 6 2022-10-02 2025-04-24 zky.zhoukeyong@alibaba-inc.com amandeeps.28@uber.com common/src/main/scala/org/apache/celeborn/common/identity/UserIdentifier.scala 30 4 932 675 4 4 2022-10-19 2023-07-03 30563796+nafiyaix@users.noreply.github.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala 196 14 949 407 14 8 2022-10-02 2024-03-27 zky.zhoukeyong@alibaba-inc.com mridul@gmail.com common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigProvider.scala 24 5 949 674 5 3 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala 250 10 949 443 10 5 2022-10-02 2024-02-20 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigReader.scala 55 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/internal/Logging.scala 51 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/meta/ApplicationMeta.scala 2 1 428 428 1 1 2024-03-06 2024-03-06 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfo.scala 161 12 828 143 12 7 2023-01-31 2024-12-16 lvshuang.tb@gmail.com lyh-36@163.com common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala 279 35 949 11 37 18 2022-10-02 2025-04-27 zky.zhoukeyong@alibaba-inc.com akpatnam25@gmail.com common/src/main/scala/org/apache/celeborn/common/meta/TimeWindow.scala 34 1 798 798 1 1 2023-03-02 2023-03-02 zhouky@apache.org zhouky@apache.org common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala 98 12 828 55 12 8 2023-01-31 2025-03-14 lvshuang.tb@gmail.com shuaizhentao.szt@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala 265 19 949 46 19 14 2022-10-02 2025-03-23 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java 159 17 825 244 17 8 2023-02-03 2024-09-06 angers.zhu@gmail.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/write/PushRequestInfo.java 15 1 812 812 1 1 2023-02-16 2023-02-16 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/write/SimplePushStrategy.java 26 3 821 661 3 3 2023-02-07 2023-07-17 anh131@126.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/write/SlowStartPushStrategy.java 118 6 821 661 6 5 2023-02-07 2023-07-17 anh131@126.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/write/PushFailedBatch.java 53 1 78 78 1 1 2025-02-19 2025-02-19 wangshengjie3@xiaomi.com wangshengjie3@xiaomi.com common/src/main/java/org/apache/celeborn/common/write/DataBatches.java 46 1 825 825 1 1 2023-02-03 2023-02-03 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/write/PushState.java 68 10 825 78 10 8 2023-02-03 2025-02-19 angers.zhu@gmail.com wangshengjie3@xiaomi.com common/src/main/java/org/apache/celeborn/common/write/PushStrategy.java 26 2 821 707 2 2 2023-02-07 2023-06-01 anh131@126.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java 238 5 949 335 5 5 2022-10-02 2024-06-07 zky.zhoukeyong@alibaba-inc.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/util/CollectionUtils.java 17 1 547 547 1 1 2023-11-08 2023-11-08 programgeek@163.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java 351 11 800 211 11 7 2023-02-28 2024-10-09 zhouky@apache.org programgeek@163.com common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java 50 8 848 147 8 5 2023-01-11 2024-12-12 lvshuang.tb@gmail.com shuaizhentao.szt@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/ShuffleBlockInfoUtils.java 128 5 949 321 5 4 2022-10-02 2024-06-21 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java 194 11 949 202 12 7 2022-10-02 2024-10-18 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/ExceptionMaker.java 5 1 431 431 1 1 2024-03-03 2024-03-03 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/FileChannelUtils.java 14 1 617 617 1 1 2023-08-30 2023-08-30 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/WorkerStatusUtils.java 22 1 462 462 1 1 2024-02-01 2024-02-01 lvshuang.xjs@alibaba-inc.com lvshuang.xjs@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/client/MasterClient.java 188 17 679 77 17 12 2023-06-29 2025-02-20 angers.zhu@gmail.com shuaizhentao.szt@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/client/MasterNotLeaderException.java 49 5 679 365 5 4 2023-06-29 2024-05-08 angers.zhu@gmail.com lvshuang.xjs@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/PartitionType.java 13 2 949 922 2 2 2022-10-02 2022-10-29 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/StorageInfo.java 243 8 949 78 8 4 2022-10-02 2025-02-19 zky.zhoukeyong@alibaba-inc.com wangshengjie3@xiaomi.com common/src/main/java/org/apache/celeborn/common/protocol/RpcNameConstants.java 16 8 949 434 8 4 2022-10-02 2024-02-29 zky.zhoukeyong@alibaba-inc.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/CompressionCodec.java 6 2 922 678 2 2 2022-10-29 2023-06-30 angers.zhu@gmail.com xiyu.zk@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java 271 10 949 552 10 8 2022-10-02 2023-11-03 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/PartitionSplitMode.java 20 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/FallbackPolicy.java 6 1 370 370 1 1 2024-05-03 2024-05-03 xinyuwang1@xiaohongshu.com xinyuwang1@xiaohongshu.com common/src/main/java/org/apache/celeborn/common/protocol/ReviveRequest.java 29 1 681 681 1 1 2023-06-27 2023-06-27 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/ShuffleMode.java 5 1 922 922 1 1 2022-10-29 2022-10-29 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/SlotsAssignPolicy.java 5 1 922 922 1 1 2022-10-29 2022-10-29 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java 84 23 949 20 24 9 2022-10-02 2025-04-18 zky.zhoukeyong@alibaba-inc.com jiangyanze.jyz@antgroup.com common/src/main/java/org/apache/celeborn/common/protocol/TransportModuleConstants.java 13 5 949 237 5 4 2022-10-02 2024-09-13 zky.zhoukeyong@alibaba-inc.com akpatnam25@gmail.com common/src/main/java/org/apache/celeborn/common/network/ssl/ReloadingX509TrustManager.java 160 4 407 202 4 4 2024-03-27 2024-10-18 mridul@gmail.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/ssl/SSLFactory.java 334 3 395 356 3 2 2024-04-08 2024-05-17 mridulatgmail.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/ssl/SSLUtils.java 58 1 383 383 1 1 2024-04-20 2024-04-20 mridul@gmail.com mridul@gmail.com common/src/main/java/org/apache/celeborn/common/network/util/AbstractFileRegion.java 29 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java 148 18 949 70 19 11 2022-10-02 2025-02-27 zky.zhoukeyong@alibaba-inc.com minyang@linkedin.com common/src/main/java/org/apache/celeborn/common/network/util/FrameDecoder.java 5 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/util/ConflictAvoidEventExecutorChooserFactory.java 28 1 87 87 1 1 2025-02-10 2025-02-10 xinyuwang1@xiaohongshu.com xinyuwang1@xiaohongshu.com common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java 174 12 949 87 12 10 2022-10-02 2025-02-10 zky.zhoukeyong@alibaba-inc.com xinyuwang1@xiaohongshu.com common/src/main/java/org/apache/celeborn/common/network/util/ByteUnit.java 53 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/util/IOMode.java 5 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/util/NettyMemoryMetrics.java 158 6 949 126 6 5 2022-10-02 2025-01-02 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/java/org/apache/celeborn/common/network/util/NettyLogger.java 48 1 406 406 1 1 2024-03-28 2024-03-28 programgeek@163.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/util/LimitedInputStream.java 76 2 949 798 2 2 2022-10-02 2023-03-02 zky.zhoukeyong@alibaba-inc.com zhouky@apache.org common/src/main/java/org/apache/celeborn/common/network/util/ConfigProvider.java 26 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java 126 4 949 491 4 4 2022-10-02 2024-01-03 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java 397 23 949 287 24 10 2022-10-02 2024-07-25 zky.zhoukeyong@alibaba-inc.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/client/RpcResponseCallback.java 6 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java 320 26 949 146 27 16 2022-10-02 2024-12-13 zky.zhoukeyong@alibaba-inc.com shuaizhentao.szt@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/client/ChunkReceivedCallback.java 6 3 949 895 3 3 2022-10-02 2022-11-25 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java 297 28 949 70 30 18 2022-10-02 2025-02-27 zky.zhoukeyong@alibaba-inc.com minyang@linkedin.com common/src/main/java/org/apache/celeborn/common/network/client/ChunkFetchFailureException.java 10 2 949 894 2 2 2022-10-02 2022-11-26 zky.zhoukeyong@alibaba-inc.com zhouky@apache.org common/src/main/java/org/apache/celeborn/common/network/client/TransportClientBootstrap.java 4 3 526 287 3 2 2023-11-29 2024-07-25 singh.chandni@gmail.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/TransportContext.java 201 22 949 70 22 13 2022-10-02 2025-02-27 zky.zhoukeyong@alibaba-inc.com minyang@linkedin.com common/src/main/java/org/apache/celeborn/common/network/protocol/RpcRequest.java 59 2 949 534 2 2 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/RegionStart.java 90 6 900 505 6 5 2022-11-20 2023-12-20 96606293+zhongqiangczq@users.noreply.github.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/protocol/StreamHandle.java 49 3 949 534 3 3 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/Heartbeat.java 20 2 729 694 2 2 2023-05-10 2023-06-14 zhongqiang.czq@alibaba-inc.com lvshuang.tb@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/BacklogAnnouncement.java 39 2 812 591 2 2 2023-02-16 2023-09-25 ethanfeng@apache.org programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/PushData.java 84 5 949 505 5 4 2022-10-02 2023-12-20 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/protocol/RpcFailure.java 50 2 949 534 2 2 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchFailure.java 51 3 949 534 3 3 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/RpcResponse.java 62 2 949 534 2 2 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/MessageDecoder.java 22 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/EncryptedMessageWithHeader.java 100 1 402 402 1 1 2024-04-01 2024-04-01 mridulatgmail.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ReadAddCredit.java 51 2 853 591 2 2 2023-01-06 2023-09-25 ethanfeng@apache.org programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessagesHelper.java 22 1 51 51 1 1 2025-03-18 2025-03-18 programgeek@163.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/ReadData.java 41 4 853 203 4 2 2023-01-06 2024-10-17 ethanfeng@apache.org reswqa@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/TransportableError.java 49 3 797 569 3 3 2023-03-03 2023-10-17 ethanfeng@apache.org programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/StreamChunkSlice.java 78 4 949 505 4 4 2022-10-02 2023-12-20 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/protocol/RequestMessage.java 10 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/SerdeVersion.java 12 1 35 35 1 1 2025-04-03 2025-04-03 jiaming.xie7@gmail.com jiaming.xie7@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchSuccess.java 62 4 949 534 4 4 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/MessageEncoder.java 56 2 949 143 2 2 2022-10-02 2024-12-16 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/RegionFinish.java 68 5 900 505 5 4 2022-11-20 2023-12-20 96606293+zhongqiangczq@users.noreply.github.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/protocol/OneWayMessage.java 54 2 949 534 2 2 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/SubPartitionReadData.java 48 2 251 203 2 1 2024-08-30 2024-10-17 reswqa@163.com reswqa@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java 78 4 949 534 4 4 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/Encodable.java 6 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/BufferStreamEnd.java 32 3 797 577 3 3 2023-03-03 2023-10-09 ethanfeng@apache.org cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchRequest.java 44 3 949 534 3 3 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java 60 2 812 642 2 2 2023-02-16 2023-08-05 ethanfeng@apache.org fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/ResponseMessage.java 13 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java 195 13 949 251 18 8 2022-10-02 2024-08-30 zky.zhoukeyong@alibaba-inc.com reswqa@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java 128 18 949 35 18 11 2022-10-02 2025-04-03 zky.zhoukeyong@alibaba-inc.com jiaming.xie7@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/PushMergedData.java 98 4 949 534 4 3 2022-10-02 2023-11-21 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java 146 4 949 143 4 4 2022-10-02 2024-12-16 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/Encoders.java 63 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/SslMessageEncoder.java 61 1 402 402 1 1 2024-04-01 2024-04-01 mridulatgmail.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/PushDataHandShake.java 89 5 900 505 5 4 2022-11-20 2023-12-20 96606293+zhongqiangczq@users.noreply.github.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java 148 6 949 437 6 6 2022-10-02 2024-02-26 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/java/org/apache/celeborn/common/network/server/TransportRequestHandler.java 145 4 949 73 4 4 2022-10-02 2025-02-24 zky.zhoukeyong@alibaba-inc.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java 136 12 949 126 12 11 2022-10-02 2025-01-02 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/java/org/apache/celeborn/common/network/server/AbstractAuthRpcHandler.java 49 1 507 507 1 1 2023-12-18 2023-12-18 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/server/BaseMessageHandler.java 25 4 949 395 4 2 2022-10-02 2024-04-08 zky.zhoukeyong@alibaba-inc.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/server/MessageHandler.java 8 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/server/TransportServerBootstrap.java 5 1 526 526 1 1 2023-11-29 2023-11-29 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslServerBootstrap.java 17 1 507 507 1 1 2023-12-18 2023-12-18 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslRpcHandler.java 88 3 507 400 3 1 2023-12-18 2024-04-03 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslServerFactory.java 64 2 488 287 2 2 2024-01-06 2024-07-25 singh.chandni@gmail.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslClientFactory.java 70 2 488 287 2 2 2024-01-06 2024-07-25 singh.chandni@gmail.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslProvider.java 19 1 488 488 1 1 2024-01-06 2024-01-06 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SecretRegistry.java 7 2 507 471 2 1 2023-12-18 2024-01-23 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslCredentials.java 16 1 511 511 1 1 2023-12-14 2023-12-14 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslUtils.java 41 4 511 471 4 1 2023-12-14 2024-01-23 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/CelebornSaslServer.java 105 5 507 400 5 1 2023-12-18 2024-04-03 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationInfo.java 17 1 471 471 1 1 2024-01-23 2024-01-23 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationRpcHandler.java 218 2 471 400 2 1 2024-01-23 2024-04-03 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationClientBootstrap.java 213 2 471 400 2 1 2024-01-23 2024-04-03 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationServerBootstrap.java 18 1 471 471 1 1 2024-01-23 2024-01-23 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslTimeoutException.java 12 1 511 511 1 1 2023-12-14 2023-12-14 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/CelebornSaslClient.java 105 2 511 488 2 1 2023-12-14 2024-01-06 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/sasl/SecretRegistryImpl.java 29 6 507 211 6 3 2023-12-18 2024-10-09 singh.chandni@gmail.com programgeek@163.com common/src/main/java/org/apache/celeborn/common/network/sasl/SaslClientBootstrap.java 73 2 511 471 2 1 2023-12-14 2024-01-23 singh.chandni@gmail.com singh.chandni@gmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/NettyManagedBuffer.java 58 4 949 402 4 4 2022-10-02 2024-04-01 zky.zhoukeyong@alibaba-inc.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java 13 3 949 402 3 3 2022-10-02 2024-04-01 zky.zhoukeyong@alibaba-inc.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/FileSegmentManagedBuffer.java 125 4 949 402 4 4 2022-10-02 2024-04-01 zky.zhoukeyong@alibaba-inc.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/NioManagedBuffer.java 48 3 949 402 3 3 2022-10-02 2024-04-01 zky.zhoukeyong@alibaba-inc.com mridulatgmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/MemoryChunkBuffers.java 18 1 350 350 1 1 2024-05-23 2024-05-23 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/buffer/ChunkBuffers.java 32 1 350 350 1 1 2024-05-23 2024-05-23 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/buffer/FileChunkBuffers.java 19 1 350 350 1 1 2024-05-23 2024-05-23 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/read/FetchRequestInfo.java 15 1 693 693 1 1 2023-06-15 2023-06-15 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java 76 20 949 196 21 9 2022-10-02 2024-10-24 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/meta/MemoryFileInfo.java 56 3 492 196 3 1 2024-01-02 2024-10-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java 28 4 949 569 4 3 2022-10-02 2023-10-17 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com common/src/main/java/org/apache/celeborn/common/meta/WorkerStatus.java 47 1 443 443 1 1 2024-02-20 2024-02-20 fwang12@ebay.com fwang12@ebay.com common/src/main/java/org/apache/celeborn/common/meta/MapFileMeta.java 123 3 492 246 3 3 2024-01-02 2024-09-04 fengmingxiao.fmx@alibaba-inc.com reswqa@163.com common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java 121 6 492 30 6 4 2024-01-02 2025-04-08 fengmingxiao.fmx@alibaba-inc.com 897900564@qq.com common/src/main/java/org/apache/celeborn/common/meta/FileMeta.java 2 1 492 492 1 1 2024-01-02 2024-01-02 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/meta/ReduceFileMeta.java 59 2 492 350 2 1 2024-01-02 2024-05-23 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/meta/WorkerEventInfo.java 48 1 443 443 1 1 2024-02-20 2024-02-20 fwang12@ebay.com fwang12@ebay.com common/src/main/java/org/apache/celeborn/reflect/DynFields.java 225 2 922 484 2 1 2022-10-29 2024-01-10 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynClasses.java 51 2 922 484 2 1 2022-10-29 2024-01-10 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynConstructors.java 233 2 922 484 2 1 2022-10-29 2024-01-10 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynMethods.java 262 2 922 484 2 1 2022-10-29 2024-01-10 chengpan@apache.org chengpan@apache.org common/src/main/proto/TransportMessages.proto 784 107 1195 37 121 25 2022-01-29 2025-04-01 fengmingxiao.fmx@alibaba-inc.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/PasswdAuthenticationProvider.java 6 2 287 211 2 1 2024-07-25 2024-10-09 fwang12@ebay.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/Credential.java 4 1 287 287 1 1 2024-07-25 2024-07-25 fwang12@ebay.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/BasicPrincipal.java 29 1 274 274 1 1 2024-08-07 2024-08-07 fwang12@ebay.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/TokenAuthenticationProvider.java 6 2 287 211 2 1 2024-07-25 2024-10-09 fwang12@ebay.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/PasswordCredential.java 7 1 287 287 1 1 2024-07-25 2024-07-25 fwang12@ebay.com fwang12@ebay.com spi/src/main/java/org/apache/celeborn/spi/authentication/TokenCredential.java 6 1 287 287 1 1 2024-07-25 2024-07-25 fwang12@ebay.com fwang12@ebay.com project/BuildTools.scala 33 1 596 596 1 1 2023-09-20 2023-09-20 cfmcgrady@gmail.com cfmcgrady@gmail.com project/AddMetaInfLicenseFiles.scala 230 3 498 492 3 2 2023-12-27 2024-01-02 cfmcgrady@gmail.com chengpan@apache.org project/JDKTools.scala 36 1 527 527 1 1 2023-11-28 2023-11-28 programgeek@163.com programgeek@163.com project/CelebornBuild.scala 1459 99 650 11 125 24 2023-07-28 2025-04-27 cfmcgrady@gmail.com akpatnam25@gmail.com project/plugins.sbt 5 7 650 196 7 2 2023-07-28 2024-10-24 cfmcgrady@gmail.com cfmcgrady@gmail.com client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala 209 22 757 136 24 9 2023-04-12 2024-12-23 angers.zhu@gmail.com fwang12@ebay.com client/src/main/scala/org/apache/celeborn/client/CommitManager.scala 278 31 884 35 33 14 2022-12-06 2025-04-03 angers.zhu@gmail.com jiaming.xie7@gmail.com client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala 1622 125 943 10 160 30 2022-10-08 2025-04-28 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-inc.com client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala 462 39 875 14 40 15 2022-12-15 2025-04-24 lvshuang.tb@gmail.com programgeek@163.com client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala 340 24 875 35 25 10 2022-12-15 2025-04-03 lvshuang.tb@gmail.com jiaming.xie7@gmail.com client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala 192 20 875 35 20 9 2022-12-15 2025-04-03 lvshuang.tb@gmail.com jiaming.xie7@gmail.com client/src/main/scala/org/apache/celeborn/client/RequestLocationCallContext.scala 54 4 898 211 4 3 2022-11-22 2024-10-09 lvshuang.xjs@alibaba-inc.com programgeek@163.com client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala 350 33 885 136 34 14 2022-12-05 2024-12-23 angers.zhu@gmail.com fwang12@ebay.com client/src/main/scala/org/apache/celeborn/client/ClientUtils.scala 20 2 160 78 2 2 2024-11-29 2025-02-19 fwang12@ebay.com wangshengjie3@xiaomi.com client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala 142 17 891 178 17 10 2022-11-29 2024-11-11 angers.zhu@gmail.com programgeek@163.com client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala 121 10 776 136 10 7 2023-03-24 2024-12-23 lvshuang.tb@gmail.com fwang12@ebay.com client/src/main/java/org/apache/celeborn/client/compress/Compressor.java 28 8 949 674 9 4 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/ZstdDecompressor.java 50 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/ZstdCompressor.java 62 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/Lz4Decompressor.java 65 2 674 555 2 2 2023-07-04 2023-10-31 angers.zhu@gmail.com programgeek@163.com client/src/main/java/org/apache/celeborn/client/compress/Lz4Trait.java 14 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/ZstdTrait.java 13 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/Lz4Compressor.java 55 1 674 674 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/Decompressor.java 37 7 949 555 7 4 2022-10-02 2023-10-31 zky.zhoukeyong@alibaba-inc.com programgeek@163.com client/src/main/java/org/apache/celeborn/client/write/PushTask.java 27 1 949 949 1 1 2022-10-02 2022-10-02 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java 106 12 839 357 14 6 2023-01-20 2024-05-16 82567833+zy-jordan@users.noreply.github.com work4dong@163.com client/src/main/java/org/apache/celeborn/client/write/DataPusher.java 211 21 949 136 23 10 2022-10-02 2024-12-23 zky.zhoukeyong@alibaba-inc.com zhangzhao.08@bytedance.com client/src/main/java/org/apache/celeborn/client/DummyShuffleClient.java 175 2 105 78 2 2 2025-01-23 2025-02-19 fengmingxiao.fmx@alibaba-inc.com wangshengjie3@xiaomi.com client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java 1889 128 949 10 150 36 2022-10-02 2025-04-28 zky.zhoukeyong@alibaba-inc.com lvshuang.xjs@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/ReviveManager.java 95 7 681 462 7 4 2023-06-27 2024-02-01 zky.zhoukeyong@alibaba-inc.com programgeek@163.com client/src/main/java/org/apache/celeborn/client/listener/WorkerStatusListener.java 4 1 752 752 1 1 2023-04-17 2023-04-17 lvshuang.tb@gmail.com lvshuang.tb@gmail.com client/src/main/java/org/apache/celeborn/client/listener/WorkersStatus.java 11 1 752 752 1 1 2023-04-17 2023-04-17 lvshuang.tb@gmail.com lvshuang.tb@gmail.com client/src/main/java/org/apache/celeborn/client/ShuffleClient.java 211 43 949 37 46 21 2022-10-02 2025-04-01 zky.zhoukeyong@alibaba-inc.com fwang12@ebay.com client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java 780 32 674 30 33 17 2023-07-04 2025-04-08 angers.zhu@gmail.com 897900564@qq.com client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java 13 4 949 51 4 4 2022-10-02 2025-03-18 zky.zhoukeyong@alibaba-inc.com saurabhd336@uber.com client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java 249 9 617 51 9 9 2023-08-30 2025-03-18 fengmingxiao.fmx@alibaba-inc.com saurabhd336@uber.com client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java 313 23 949 30 26 15 2022-10-02 2025-04-08 zky.zhoukeyong@alibaba-inc.com 897900564@qq.com client/src/main/java/org/apache/celeborn/client/read/MetricsCallback.java 6 2 949 51 2 2 2022-10-02 2025-03-18 zky.zhoukeyong@alibaba-inc.com saurabhd336@uber.com client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java 254 21 949 51 22 14 2022-10-02 2025-03-18 zky.zhoukeyong@alibaba-inc.com saurabhd336@uber.com client/src/main/java/org/apache/celeborn/client/read/checkpoint/PartitionReaderCheckpointMetadata.java 18 1 51 51 1 1 2025-03-18 2025-03-18 saurabhd336@uber.com saurabhd336@uber.com service/src/main/scala/org/apache/celeborn/common/metrics/MetricsSystem.scala 152 2 407 211 2 1 2024-03-27 2024-10-09 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/common/metrics/sink/AbstractServlet.scala 18 1 407 407 1 1 2024-03-27 2024-03-27 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/common/metrics/sink/JsonServlet.scala 313 2 407 143 2 2 2024-03-27 2024-12-16 fwang12@ebay.com fengmingxiao.fmx@alibaba-inc.com service/src/main/scala/org/apache/celeborn/common/metrics/sink/PrometheusServlet.scala 18 1 407 407 1 1 2024-03-27 2024-03-27 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/container/DefaultContainerInfoProvider.scala 16 1 203 203 1 1 2024-10-17 2024-10-17 akpatnam25@gmail.com akpatnam25@gmail.com service/src/main/scala/org/apache/celeborn/server/common/container/ContainerInfoProvider.scala 19 1 203 203 1 1 2024-10-17 2024-10-17 akpatnam25@gmail.com akpatnam25@gmail.com service/src/main/scala/org/apache/celeborn/server/common/http/api/CelebornScalaObjectMapper.scala 10 2 407 322 2 2 2024-03-27 2024-06-20 fwang12@ebay.com programgeek@163.com service/src/main/scala/org/apache/celeborn/server/common/http/api/OpenAPIConfig.scala 18 3 407 301 3 1 2024-03-27 2024-07-11 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiRequestContext.scala 44 3 407 289 3 1 2024-03-27 2024-07-23 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiBaseResource.scala 90 5 407 105 5 2 2024-03-27 2025-01-23 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ApiV1BaseResource.scala 60 6 301 105 6 3 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ConfResource.scala 111 3 301 105 3 1 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/LoggerResource.scala 64 2 135 105 2 1 2024-12-24 2025-01-23 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ApiUtils.scala 133 6 301 71 6 2 2024-07-11 2025-02-26 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiRootResource.scala 16 2 407 301 2 1 2024-03-27 2024-07-11 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/api/CelebornOpenApiResource.scala 88 6 407 225 6 2 2024-03-27 2024-09-25 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/RestAuditLogger.scala 22 1 174 174 1 1 2024-11-15 2024-11-15 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpUtils.scala 88 8 632 386 8 4 2023-08-15 2024-04-17 angers.zhu@gmail.com programgeek@163.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/BearerAuthenticationHandler.scala 62 4 322 275 4 1 2024-06-20 2024-08-06 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/SpnegoAuthenticationHandler.scala 131 1 322 322 1 1 2024-06-20 2024-06-20 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/BasicAuthenticationHandler.scala 73 3 322 287 3 1 2024-06-20 2024-07-25 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/HttpAuthenticationFactory.scala 64 2 322 287 2 1 2024-06-20 2024-07-25 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/AuthenticationHandler.scala 35 1 322 322 1 1 2024-06-20 2024-06-20 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/authentication/AuthenticationFilter.scala 176 4 322 174 4 2 2024-06-20 2024-11-15 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpAuthUtils.scala 15 3 322 287 3 1 2024-06-20 2024-07-25 fwang12@ebay.com fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala 152 11 943 225 11 6 2022-10-08 2024-09-25 chengpan@apache.org fwang12@ebay.com service/src/main/scala/org/apache/celeborn/server/common/Service.scala 22 6 943 441 7 3 2022-10-08 2024-02-22 chengpan@apache.org angers.zhu@gmail.com service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala 289 40 943 161 47 15 2022-10-08 2024-11-28 chengpan@apache.org fwang12@ebay.com service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterInfo.java 46 2 458 287 2 2 2024-02-05 2024-07-25 lvshuang.xjs@alibaba-inc.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterTenantConfig.java 95 3 458 287 3 3 2024-02-05 2024-07-25 lvshuang.xjs@alibaba-inc.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterTag.java 46 1 167 167 1 1 2024-11-22 2024-11-22 sanskarmodi97@gmail.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterSystemConfig.java 53 2 458 287 2 2 2024-02-05 2024-07-25 lvshuang.xjs@alibaba-inc.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/utils/JsonUtils.java 28 1 458 458 1 1 2024-02-05 2024-02-05 lvshuang.xjs@alibaba-inc.com lvshuang.xjs@alibaba-inc.com service/src/main/java/org/apache/celeborn/server/common/service/config/DbConfigStoreImpl.java 11 1 258 258 1 1 2024-08-23 2024-08-23 programgeek@163.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/config/FsConfigServiceImpl.java 95 11 521 211 11 5 2023-12-04 2024-10-09 programgeek@163.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigStore.java 5 1 258 258 1 1 2024-08-23 2024-08-23 programgeek@163.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfig.java 254 8 521 45 8 4 2023-12-04 2025-03-24 programgeek@163.com 31424839+leixm@users.noreply.github.com service/src/main/java/org/apache/celeborn/server/common/service/config/DbConfigServiceImpl.java 40 7 458 167 7 4 2024-02-05 2024-11-22 lvshuang.xjs@alibaba-inc.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigService.java 31 10 521 202 10 6 2023-12-04 2024-10-18 programgeek@163.com 31424839+leixm@users.noreply.github.com service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfigServiceFactory.java 35 8 521 14 8 5 2023-12-04 2025-04-24 programgeek@163.com amandeeps.28@uber.com service/src/main/java/org/apache/celeborn/server/common/service/config/BaseConfigServiceImpl.java 85 6 458 202 6 4 2024-02-05 2024-10-18 lvshuang.xjs@alibaba-inc.com 31424839+leixm@users.noreply.github.com service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigLevel.java 6 2 521 445 2 2 2023-12-04 2024-02-18 programgeek@163.com angers.zhu@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/config/TenantConfig.java 40 3 521 445 3 3 2023-12-04 2024-02-18 programgeek@163.com angers.zhu@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/config/SystemConfig.java 53 6 521 163 6 4 2023-12-04 2024-11-26 programgeek@163.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/config/FsConfigStoreImpl.java 11 1 258 258 1 1 2024-08-23 2024-08-23 programgeek@163.com programgeek@163.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterSystemConfigMapper.java 10 1 458 458 1 1 2024-02-05 2024-02-05 lvshuang.xjs@alibaba-inc.com lvshuang.xjs@alibaba-inc.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterTagsMapper.java 10 1 167 167 1 1 2024-11-22 2024-11-22 sanskarmodi97@gmail.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterTenantConfigMapper.java 19 2 458 445 2 2 2024-02-05 2024-02-18 lvshuang.xjs@alibaba-inc.com angers.zhu@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterInfoMapper.java 13 1 458 458 1 1 2024-02-05 2024-02-05 lvshuang.xjs@alibaba-inc.com lvshuang.xjs@alibaba-inc.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/DbServiceManagerImpl.java 141 4 458 167 4 4 2024-02-05 2024-11-22 lvshuang.xjs@alibaba-inc.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/store/db/DBSessionFactory.java 68 2 458 167 2 2 2024-02-05 2024-11-22 lvshuang.xjs@alibaba-inc.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/store/IServiceManager.java 14 3 458 167 3 3 2024-02-05 2024-11-22 lvshuang.xjs@alibaba-inc.com sanskarmodi97@gmail.com service/src/main/java/org/apache/celeborn/server/common/service/mpu/MultipartUploadHandler.java 10 1 167 167 1 1 2024-11-22 2024-11-22 luoyedeyi@163.com luoyedeyi@163.com service/src/main/resources/sql/mysql/celeborn-0.5.0-mysql.sql 38 4 458 167 4 3 2024-02-05 2024-11-22 lvshuang.xjs@alibaba-inc.com sanskarmodi97@gmail.com service/src/main/resources/sql/mysql/upgrade-0.5.0-to-0.6.0-mysql.sql 3 1 167 167 1 1 2024-11-22 2024-11-22 sanskarmodi97@gmail.com sanskarmodi97@gmail.com service/src/main/resources/sql/mysql/001-CELEBORN-1618-mysql.sql 11 1 167 167 1 1 2024-11-22 2024-11-22 sanskarmodi97@gmail.com sanskarmodi97@gmail.com service/src/main/resources/sql/mysql/celeborn-0.6.0-mysql.sql 49 1 167 167 1 1 2024-11-22 2024-11-22 sanskarmodi97@gmail.com sanskarmodi97@gmail.com service/src/main/resources/org/apache/celeborn/swagger/index.html 52 2 407 406 2 2 2024-03-27 2024-03-28 fwang12@ebay.com programgeek@163.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala 740 51 943 30 57 23 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala 168 47 943 121 50 24 2022-10-08 2025-01-07 chengpan@apache.org nzhu@pinterest.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala 947 138 943 10 166 36 2022-10-08 2025-04-28 chengpan@apache.org fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/InternalRpcEndpoint.scala 24 2 434 428 2 1 2024-02-29 2024-03-06 singh.chandni@gmail.com singh.chandni@gmail.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala 576 54 943 30 56 21 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/monitor/JVMQuake.scala 143 2 527 471 2 2 2023-11-28 2024-01-23 programgeek@163.com angers.zhu@gmail.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/profiler/JVMProfiler.scala 41 1 409 409 1 1 2024-03-25 2024-03-25 programgeek@163.com programgeek@163.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/CommitInfo.scala 8 1 894 894 1 1 2022-11-26 2022-11-26 zhouky@apache.org zhouky@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/ApiWorkerResource.scala 64 5 407 105 6 3 2024-03-27 2025-01-23 fwang12@ebay.com fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ShuffleResource.scala 55 3 301 105 3 1 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApiV1WorkerResource.scala 12 1 301 301 1 1 2024-07-11 2024-07-11 fwang12@ebay.com fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/WorkerResource.scala 63 4 301 105 4 1 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApplicationResource.scala 29 5 301 105 5 2 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerStatusManager.scala 126 6 462 167 6 5 2024-02-01 2024-11-22 lvshuang.xjs@alibaba-inc.com reswqa@163.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala 76 10 943 17 10 7 2022-10-08 2025-04-21 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceObserver.scala 8 2 943 920 2 2 2022-10-08 2022-10-31 chengpan@apache.org 30563796+nafiyaix@users.noreply.github.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala 1094 90 943 30 103 34 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala 586 6 105 17 6 3 2025-01-23 2025-04-21 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala 185 26 943 30 27 13 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala 278 32 943 28 36 13 2022-10-08 2025-04-10 chengpan@apache.org programgeek@163.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala 139 7 862 259 7 6 2022-12-28 2024-08-22 30563796+nafiyaix@users.noreply.github.com sychen@ctrip.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StoragePolicy.scala 170 3 303 36 3 2 2024-07-09 2025-04-02 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandler.scala 340 2 119 36 2 1 2025-01-09 2025-04-02 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala 1404 86 943 30 103 29 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala 58 10 943 434 10 5 2022-10-08 2024-02-29 chengpan@apache.org singh.chandni@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DB.java 9 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDBProvider.java 133 4 597 344 4 2 2023-09-19 2024-05-29 sychen@ctrip.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDB.java 56 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDBIterator.java 58 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDB.java 38 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBProvider.java 25 2 597 440 2 2 2023-09-19 2024-02-23 sychen@ctrip.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/StoreVersion.java 28 2 597 423 2 2 2023-09-19 2024-03-11 sychen@ctrip.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBBackend.java 16 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDBIterator.java 61 1 597 597 1 1 2023-09-19 2023-09-19 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDBProvider.java 104 3 597 387 3 2 2023-09-19 2024-04-16 sychen@ctrip.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBIterator.java 11 2 597 505 2 1 2023-09-19 2023-12-20 sychen@ctrip.com sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/ShuffleRecoverHelper.java 16 4 943 597 4 3 2022-10-08 2023-09-19 chengpan@apache.org sychen@ctrip.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ChannelsLimiter.java 118 4 749 636 4 4 2023-04-20 2023-08-11 ethanfeng@apache.org cfmcgrady@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/RecyclableSegmentIdBuffer.java 15 2 191 167 2 2 2024-10-29 2024-11-22 reswqa@163.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/BufferQueue.java 115 2 749 744 2 1 2023-04-20 2023-04-25 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java 134 8 749 125 8 7 2023-04-20 2025-01-03 ethanfeng@apache.org 31424839+leixm@users.noreply.github.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/RecyclableBuffer.java 21 2 749 191 2 2 2023-04-20 2024-10-29 ethanfeng@apache.org reswqa@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferListener.java 6 1 749 749 1 1 2023-04-20 2023-04-20 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferRequest.java 22 1 749 749 1 1 2023-04-20 2023-04-20 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java 554 30 749 36 30 16 2023-04-20 2025-04-02 ethanfeng@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/BufferRecycler.java 12 1 749 749 1 1 2023-04-20 2023-04-20 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/UserCongestionControlContext.java 55 3 208 202 3 1 2024-10-12 2024-10-18 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java 59 5 821 561 5 3 2023-02-07 2023-10-25 anh131@126.com lyh-36@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java 95 5 821 254 5 4 2023-02-07 2024-08-27 anh131@126.com 31424839+leixm@users.noreply.github.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/UserBufferInfo.java 19 1 317 317 1 1 2024-06-25 2024-06-25 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java 275 16 821 136 16 8 2023-02-07 2024-12-23 anh131@126.com shuaizhentao.szt@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkerSecretRegistryImpl.java 75 2 423 287 2 2 2024-03-11 2024-07-25 singh.chandni@gmail.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkingPartition.java 14 2 943 492 2 2 2022-10-08 2024-01-02 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/TierWriterHelper.java 39 2 87 30 2 2 2025-02-10 2025-04-08 fengmingxiao.fmx@alibaba-inc.com 897900564@qq.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionData.java 217 5 492 113 5 4 2024-01-02 2025-01-15 fengmingxiao.fmx@alibaba-inc.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionDataReader.java 448 3 492 191 3 3 2024-01-02 2024-10-29 fengmingxiao.fmx@alibaba-inc.com reswqa@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java 866 45 943 30 50 15 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionData.java 80 2 191 182 2 1 2024-10-29 2024-11-07 reswqa@163.com reswqa@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionDataReader.java 252 2 191 167 2 2 2024-10-29 2024-11-22 reswqa@163.com programgeek@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java 324 13 749 182 13 8 2023-04-20 2024-11-07 ethanfeng@apache.org reswqa@163.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java 136 9 749 65 9 6 2023-04-20 2025-03-04 ethanfeng@apache.org sanskarmodi97@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java 221 18 492 30 19 11 2024-01-02 2025-04-08 fengmingxiao.fmx@alibaba-inc.com 897900564@qq.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriterContext.java 126 3 350 36 3 1 2024-05-23 2025-04-02 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FlushNotifier.java 20 1 943 943 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala 294 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala 43 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala 133 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala 86 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala 256 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala 67 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala 46 1 619 619 1 1 2023-08-28 2023-08-28 zhouyifan279@gmail.com zhouyifan279@gmail.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala 18 1 619 619 1 1 2023-08-28 2023-08-28 zhouyifan279@gmail.com zhouyifan279@gmail.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala 353 3 619 301 3 3 2023-08-28 2024-07-11 zhouyifan279@gmail.com programgeek@163.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala 461 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala 49 1 619 619 1 1 2023-08-28 2023-08-28 zhouyifan279@gmail.com zhouyifan279@gmail.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala 205 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala 101 2 619 535 2 2 2023-08-28 2023-11-20 zhouyifan279@gmail.com 1623735386@qq.com client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala 41 7 619 490 7 4 2023-08-28 2024-01-04 zhouyifan279@gmail.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-3-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java 129 4 619 357 4 4 2023-08-28 2024-05-16 zhouyifan279@gmail.com lyh-36@163.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala 295 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala 43 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala 133 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala 87 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala 256 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala 67 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala 46 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala 18 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala 356 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala 466 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala 49 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala 205 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala 102 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala 41 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-4-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java 129 1 135 135 1 1 2024-12-24 2024-12-24 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/QuotaFallbackPolicy.java 29 1 205 205 1 1 2024-10-15 2024-10-15 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ExecutorShuffleIdTracker.java 23 1 529 529 1 1 2023-11-26 2023-11-26 fmerik@gmail.com fmerik@gmail.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorter.java 102 3 943 59 3 1 2022-10-08 2025-03-10 chengpan@apache.org chengpan@apache.org client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ForceFallbackPolicy.java 25 2 205 162 2 1 2024-10-15 2024-11-27 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/OpenByteArrayOutputStream.java 10 1 943 943 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/WorkersAvailableFallbackPolicy.java 27 1 205 205 1 1 2024-10-15 2024-10-15 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleFallbackPolicyFactory.java 23 1 205 205 1 1 2024-10-15 2024-10-15 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SparkCommonUtils.java 56 3 251 59 3 3 2024-08-30 2025-03-10 jiangyanze.jyz@antgroup.com chengpan@apache.org client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java 399 22 943 178 25 9 2022-10-08 2024-11-11 chengpan@apache.org sychen@ctrip.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java 83 7 943 178 7 5 2022-10-08 2024-11-11 chengpan@apache.org sychen@ctrip.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleFallbackPolicy.java 10 1 205 205 1 1 2024-10-15 2024-10-15 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShufflePartitionsFallbackPolicy.java 27 1 205 205 1 1 2024-10-15 2024-10-15 programgeek@163.com programgeek@163.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/PackedRecordPointer.java 30 1 943 943 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/TaskInterruptedHelper.java 12 1 722 722 1 1 2023-05-17 2023-05-17 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/ShuffleFetchFailureReportTaskCleanListener.scala 9 1 65 65 1 1 2025-03-04 2025-03-04 chengpan@apache.org chengpan@apache.org client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala 36 10 674 65 10 5 2023-07-04 2025-03-04 angers.zhu@gmail.com chengpan@apache.org client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala 400 35 674 37 35 18 2023-07-04 2025-04-01 angers.zhu@gmail.com fwang12@ebay.com client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala 34 6 674 65 6 4 2023-07-04 2025-03-04 angers.zhu@gmail.com chengpan@apache.org client-spark/spark-3/src/main/scala/org/apache/spark/celeborn/ExceptionMakerHelper.scala 22 2 269 65 2 2 2024-08-12 2025-03-04 mridul@gmail.com chengpan@apache.org client-spark/spark-3/src/main/scala/org/apache/spark/SparkVersionUtil.scala 12 2 570 65 2 2 2023-10-16 2025-03-04 beliefer@163.com chengpan@apache.org client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java 349 28 943 51 31 12 2022-10-08 2025-03-18 chengpan@apache.org 1548069580@qq.com  client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java 344 31 943 38 34 15 2022-10-08 2025-03-31 chengpan@apache.org saurabhd336@uber.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java 393 40 678 37 47 21 2023-06-30 2025-04-01 angers.zhu@gmail.com fwang12@ebay.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java 523 20 943 11 20 11 2022-10-08 2025-04-27 chengpan@apache.org lijianfu@meituan.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/CelebornShuffleDataIO.java 38 3 609 65 3 3 2023-09-07 2025-03-04 zhouyifan279@gmail.com chengpan@apache.org client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/CelebornPartitionUtil.java 45 1 65 65 1 1 2025-03-04 2025-03-04 chengpan@apache.org chengpan@apache.org client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/ShuffleFetchFailureReportTaskCleanListener.scala 9 1 112 112 1 1 2025-01-16 2025-01-16 fwang12@ebay.com fwang12@ebay.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala 39 8 674 162 8 4 2023-07-04 2024-11-27 angers.zhu@gmail.com programgeek@163.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala 219 19 674 37 19 12 2023-07-04 2025-04-01 angers.zhu@gmail.com fwang12@ebay.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala 34 5 674 489 5 3 2023-07-04 2024-01-05 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-inc.com client-spark/spark-2/src/main/scala/org/apache/spark/celeborn/ExceptionMakerHelper.scala 21 2 269 59 2 2 2024-08-12 2025-03-10 mridul@gmail.com fwang12@ebay.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java 298 21 943 251 24 10 2022-10-08 2024-08-30 chengpan@apache.org jiangyanze.jyz@antgroup.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java 333 18 943 178 21 10 2022-10-08 2024-11-11 chengpan@apache.org sychen@ctrip.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java 243 31 678 37 35 16 2023-06-30 2025-04-01 angers.zhu@gmail.com fwang12@ebay.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java 402 12 943 11 12 7 2022-10-08 2025-04-27 chengpan@apache.org lijianfu@meituan.com client-spark/spark-3-columnar-common/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornBatchBuilder.scala 28 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3-columnar-common/src/main/java/org/apache/spark/sql/execution/columnar/CelebornColumnDictionary.java 45 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3-columnar-common/src/main/java/org/apache/spark/shuffle/celeborn/CustomShuffleDependencyUtils.java 25 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala 295 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala 43 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala 133 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala 87 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala 256 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala 67 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala 46 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala 18 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala 356 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala 463 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala 49 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala 205 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala 102 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala 41 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com client-spark/spark-3.5-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java 129 1 245 245 1 1 2024-09-05 2024-09-05 programgeek@163.com programgeek@163.com build/release/append_notice.py 27 1 861 861 1 1 2022-12-29 2022-12-29 ethanfeng@apache.org ethanfeng@apache.org build/release/asf-settings.xml 17 1 616 616 1 1 2023-08-31 2023-08-31 chengpan@apache.org chengpan@apache.org build/sbt-launch-lib.bash 151 1 650 650 1 1 2023-07-28 2023-07-28 cfmcgrady@gmail.com cfmcgrady@gmail.com dev/merge_pr.py 461 8 706 407 10 3 2023-06-02 2024-03-27 chengpan@apache.org programgeek@163.com version.sbt 1 3 650 342 3 2 2023-07-28 2024-05-31 cfmcgrady@gmail.com fengmingxiao.fmx@alibaba-inc.com cli/src/main/scala/org/apache/celeborn/cli/common/CliVersionProvider.scala 27 1 245 245 1 1 2024-09-05 2024-09-05 apatnam@linkedin.com apatnam@linkedin.com cli/src/main/scala/org/apache/celeborn/cli/common/CliLogging.scala 16 1 245 245 1 1 2024-09-05 2024-09-05 apatnam@linkedin.com apatnam@linkedin.com cli/src/main/scala/org/apache/celeborn/cli/common/CommonOptions.scala 49 2 245 199 2 2 2024-09-05 2024-10-21 apatnam@linkedin.com fengmingxiao.fmx@alibaba-inc.com cli/src/main/scala/org/apache/celeborn/cli/config/CliConfigManager.scala 59 1 245 245 1 1 2024-09-05 2024-09-05 apatnam@linkedin.com apatnam@linkedin.com cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerOptions.scala 43 4 245 161 4 3 2024-09-05 2024-11-28 apatnam@linkedin.com fwang12@ebay.com cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerSubcommand.scala 46 4 245 161 4 3 2024-09-05 2024-11-28 apatnam@linkedin.com fwang12@ebay.com cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerSubcommandImpl.scala 46 4 245 161 4 3 2024-09-05 2024-11-28 apatnam@linkedin.com fwang12@ebay.com cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommand.scala 68 6 245 161 6 5 2024-09-05 2024-11-28 apatnam@linkedin.com fwang12@ebay.com cli/src/main/scala/org/apache/celeborn/cli/master/ReviseLostShuffleOptions.scala 8 1 199 199 1 1 2024-10-21 2024-10-21 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com cli/src/main/scala/org/apache/celeborn/cli/master/MasterOptions.scala 80 8 245 70 8 5 2024-09-05 2025-02-27 apatnam@linkedin.com programgeek@163.com cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommandImpl.scala 208 9 245 70 9 5 2024-09-05 2025-02-27 apatnam@linkedin.com programgeek@163.com cli/src/main/scala/org/apache/celeborn/cli/CelebornCli.scala 28 1 245 245 1 1 2024-09-05 2024-09-05 apatnam@linkedin.com apatnam@linkedin.com master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterClusterInfo.scala 54 5 938 356 6 5 2022-10-13 2024-05-17 chengpan@apache.org mridulatgmail.com master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala 82 8 938 286 8 6 2022-10-13 2024-07-26 chengpan@apache.org mridulatgmail.com master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala 31 20 943 37 20 9 2022-10-08 2025-04-01 chengpan@apache.org fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala 353 4 441 45 4 3 2024-02-22 2025-03-24 angers.zhu@gmail.com 31424839+leixm@users.noreply.github.com master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaStatus.scala 12 1 45 45 1 1 2025-03-24 2025-03-24 31424839+leixm@users.noreply.github.com 31424839+leixm@users.noreply.github.com master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala 1315 145 943 30 176 30 2022-10-08 2025-04-08 angers.zhu@gmail.com 897900564@qq.com master/src/main/scala/org/apache/celeborn/service/deploy/master/InternalRpcEndpoint.scala 25 1 464 464 1 1 2024-01-30 2024-01-30 singh.chandni@gmail.com singh.chandni@gmail.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/ApiMasterResource.scala 117 7 407 105 8 4 2024-03-27 2025-01-23 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApiV1MasterResource.scala 16 2 301 209 2 1 2024-07-11 2024-10-11 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ShuffleResource.scala 36 3 301 105 3 2 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/MasterResource.scala 78 4 301 105 4 1 2024-07-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/WorkerResource.scala 156 12 301 71 12 4 2024-07-11 2025-02-26 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/RatisResource.scala 328 6 209 105 6 2 2024-10-11 2025-01-23 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApplicationResource.scala 72 7 301 17 7 2 2024-07-11 2025-04-21 fwang12@ebay.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/MasterHttpResourceUtils.scala 19 2 238 209 2 2 2024-09-12 2024-10-11 apatnam@linkedin.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala 93 8 223 136 8 3 2024-09-27 2024-12-23 sanskarmodi97@gmail.com fwang12@ebay.com master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala 67 13 943 439 14 6 2022-10-08 2024-02-24 chengpan@apache.org singh.chandni@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java 98 12 943 301 12 9 2022-10-08 2024-07-11 chengpan@apache.org programgeek@163.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java 278 30 943 45 31 18 2022-10-08 2025-03-24 chengpan@apache.org 31424839+leixm@users.noreply.github.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java 256 12 943 301 12 9 2022-10-08 2024-07-11 chengpan@apache.org programgeek@163.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java 397 30 943 45 31 15 2022-10-08 2025-03-24 chengpan@apache.org 31424839+leixm@users.noreply.github.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java 504 27 943 203 28 14 2022-10-08 2024-10-17 chengpan@apache.org fwang12@ebay.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java 532 54 943 30 57 24 2022-10-08 2025-04-08 chengpan@apache.org 897900564@qq.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java 136 31 943 45 32 16 2022-10-08 2025-03-24 chengpan@apache.org 31424839+leixm@users.noreply.github.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java 137 7 943 262 9 7 2022-10-08 2024-08-19 chengpan@apache.org programgeek@163.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java 62 19 943 161 20 14 2022-10-08 2024-11-28 chengpan@apache.org fwang12@ebay.com master/src/main/java/org/apache/celeborn/service/deploy/master/MasterSecretRegistryImpl.java 38 2 428 198 2 2 2024-03-06 2024-10-22 singh.chandni@gmail.com 69848459+yutingwang98@users.noreply.github.com master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java 579 21 943 11 22 16 2022-10-08 2025-04-27 chengpan@apache.org akpatnam25@gmail.com master/src/main/proto/Resource.proto 227 21 943 17 22 15 2022-10-08 2025-04-21 chengpan@apache.org luoyedeyi@163.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ConfResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerAddRequest.java 75 1 203 203 1 1 2024-10-17 2024-10-17 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RemoveWorkersUnavailableInfoRequest.java 75 2 262 226 2 1 2024-08-19 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterInfoResponse.java 137 3 281 209 3 1 2024-07-31 2024-10-11 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationsHeartbeatResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerExitRequest.java 91 3 281 226 3 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/TopologyInfo.java 94 1 71 71 1 1 2025-02-26 2025-02-26 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/PartitionLocationData.java 218 3 281 226 3 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DynamicConfig.java 141 3 281 226 3 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeer.java 84 1 203 203 1 1 2024-10-17 2024-10-17 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ShufflePartitionsResponse.java 101 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerTimestampData.java 85 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationHeartbeatData.java 84 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ConfigData.java 84 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ReviseLostShufflesRequest.java 94 1 177 177 1 1 2024-11-12 2024-11-12 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ShufflesResponse.java 74 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DynamicConfigResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerInfoResponse.java 401 3 281 157 3 1 2024-07-31 2024-12-02 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ThreadStack.java 335 4 281 181 4 2 2024-07-31 2024-11-08 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ContainerInfo.java 214 2 203 199 2 2 2024-10-17 2024-10-21 akpatnam25@gmail.com fengmingxiao.fmx@alibaba-inc.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterLeader.java 84 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerResourceConsumption.java 153 2 157 126 2 1 2024-12-02 2025-01-02 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/SendWorkerEventRequest.java 124 4 281 226 4 2 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DeleteAppsRequest.java 74 1 177 177 1 1 2024-11-12 2024-11-12 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterCommitData.java 164 3 281 209 3 1 2024-07-31 2024-10-11 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/HostnamesResponse.java 74 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java 361 4 281 71 4 1 2024-07-31 2025-02-26 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLogInfo.java 125 1 209 209 1 1 2024-10-11 2024-10-11 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerId.java 144 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ExcludeWorkerRequest.java 102 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ThreadStackResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerRemoveRequest.java 75 1 203 203 1 1 2024-10-17 2024-10-17 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/LoggerInfos.java 75 1 135 135 1 1 2024-12-24 2024-12-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventData.java 86 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLocalRaftMetaConfRequest.java 75 1 196 196 1 1 2024-10-24 2024-10-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/LoggerInfo.java 84 1 135 135 1 1 2024-12-24 2024-12-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/HandleResponse.java 84 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkersResponse.java 211 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerSetPriorityRequest.java 73 1 203 203 1 1 2024-10-17 2024-10-17 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/TopologyResponse.java 75 1 71 71 1 1 2025-02-26 2025-02-26 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLogTermIndex.java 84 1 209 209 1 1 2024-10-11 2024-10-11 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventsResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationsResponse.java 74 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventInfoData.java 84 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/UnAvailablePeersResponse.java 75 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisElectionTransferRequest.java 64 1 209 209 1 1 2024-10-11 2024-10-11 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/RFC3339DateFormat.java 37 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ApiClient.java 610 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/BaseApi.java 39 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/Pair.java 34 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ApiException.java 58 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ServerConfiguration.java 32 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/Configuration.java 12 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ServerVariable.java 13 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/StringUtil.java 40 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/JavaTimeFormatter.java 24 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/HttpBasicAuth.java 31 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/Authentication.java 7 1 281 281 1 1 2024-07-31 2024-07-31 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/HttpBearerAuth.java 34 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/ApiKeyAuth.java 52 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ApplicationApi.java 96 3 281 161 3 1 2024-07-31 2024-11-28 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ConfApi.java 139 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ShuffleApi.java 136 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/LoggerApi.java 141 1 135 135 1 1 2024-12-24 2024-12-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/DefaultApi.java 136 3 281 203 3 2 2024-07-31 2024-10-17 fwang12@ebay.com akpatnam25@gmail.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/WorkerApi.java 179 3 281 126 3 1 2024-07-31 2025-01-02 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/RFC3339DateFormat.java 37 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiClient.java 610 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/BaseApi.java 39 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/Pair.java 34 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiException.java 58 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ServerConfiguration.java 32 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/Configuration.java 12 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ServerVariable.java 13 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/StringUtil.java 40 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/JavaTimeFormatter.java 24 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/HttpBasicAuth.java 31 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/Authentication.java 7 1 281 281 1 1 2024-07-31 2024-07-31 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/HttpBearerAuth.java 34 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/ApiKeyAuth.java 52 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ApplicationApi.java 220 6 281 17 6 2 2024-07-31 2025-04-21 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ConfApi.java 139 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ShuffleApi.java 96 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/LoggerApi.java 141 1 135 135 1 1 2024-12-24 2024-12-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/MasterApi.java 96 2 281 226 2 1 2024-07-31 2024-09-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/DefaultApi.java 136 3 281 203 3 2 2024-07-31 2024-10-17 fwang12@ebay.com akpatnam25@gmail.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/WorkerApi.java 301 5 281 71 5 1 2024-07-31 2025-02-26 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/RatisApi.java 459 4 209 196 4 1 2024-10-11 2024-10-24 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/openapi3/templates/licenseInfo.mustache 16 1 281 281 1 1 2024-07-31 2024-07-31 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml 1110 17 301 17 19 4 2024-07-11 2025-04-21 fwang12@ebay.com fwang12@ebay.com openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml 687 11 301 17 11 4 2024-07-11 2025-04-21 fwang12@ebay.com fwang12@ebay.com cpp/cmake/celeborn-config.cmake.in 24 1 163 163 1 1 2024-11-26 2024-11-26 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/cmake/FindSodium.cmake 265 1 163 163 1 1 2024-11-26 2024-11-26 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/conf/BaseConf.h 173 2 136 124 2 1 2024-12-23 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/conf/CelebornConf.h 39 2 134 124 2 1 2024-12-25 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/conf/BaseConf.cpp 183 2 136 124 2 1 2024-12-23 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/conf/CelebornConf.cpp 155 2 134 124 2 1 2024-12-25 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/Exceptions.cpp 9 2 155 124 2 1 2024-12-04 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/StackTrace.h 31 2 162 124 2 1 2024-11-27 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/CelebornException.cpp 211 2 161 124 2 1 2024-11-28 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/StackTrace.cpp 145 2 162 124 2 1 2024-11-27 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/CelebornUtils.cpp 55 3 120 44 3 1 2025-01-08 2025-03-25 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/CelebornException.h 272 2 161 124 2 1 2024-11-28 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/CelebornUtils.h 71 6 136 44 6 1 2024-12-23 2025-03-25 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/ProcessBase.h 17 1 163 163 1 1 2024-11-26 2024-11-26 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/ProcessBase.cpp 52 1 163 163 1 1 2024-11-26 2024-11-26 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/Exceptions.h 330 2 155 124 2 1 2024-12-04 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/utils/flags.cpp 21 1 161 161 1 1 2024-11-28 2024-11-28 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/memory/ByteBuffer.cpp 55 2 142 124 2 1 2024-12-17 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/memory/ByteBuffer.h 128 2 142 124 2 1 2024-12-17 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/ShuffleClient.cpp 111 1 44 44 1 1 2025-03-25 2025-03-25 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/ShuffleClient.h 53 1 44 44 1 1 2025-03-25 2025-03-25 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/reader/WorkerPartitionReader.cpp 116 1 59 59 1 1 2025-03-10 2025-03-10 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/reader/CelebornInputStream.cpp 165 1 55 55 1 1 2025-03-14 2025-03-14 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/reader/CelebornInputStream.h 48 1 55 55 1 1 2025-03-14 2025-03-14 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/client/reader/WorkerPartitionReader.h 54 1 59 59 1 1 2025-03-10 2025-03-10 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/PartitionLocation.h 62 3 132 120 3 1 2024-12-27 2025-01-08 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/StatusCode.h 62 2 132 124 2 1 2024-12-27 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/ControlMessages.h 69 1 120 120 1 1 2025-01-08 2025-01-08 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/ControlMessages.cpp 150 1 120 120 1 1 2025-01-08 2025-01-08 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/TransportMessage.cpp 30 2 125 124 2 1 2025-01-03 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/PartitionLocation.cpp 97 3 132 120 3 1 2024-12-27 2025-01-08 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/protocol/TransportMessage.h 25 2 125 124 2 1 2025-01-03 2025-01-04 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/Message.cpp 126 1 110 110 1 1 2025-01-18 2025-01-18 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/MessageDispatcher.cpp 223 1 106 106 1 1 2025-01-22 2025-01-22 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/Message.h 172 3 110 73 3 1 2025-01-18 2025-02-24 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/NettyRpcEndpointRef.cpp 50 1 73 73 1 1 2025-02-24 2025-02-24 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/NettyRpcEndpointRef.h 31 1 73 73 1 1 2025-02-24 2025-02-24 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/FrameDecoder.h 45 1 118 118 1 1 2025-01-10 2025-01-10 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/TransportClient.h 92 3 82 59 3 1 2025-02-15 2025-03-10 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/TransportClient.cpp 160 1 82 82 1 1 2025-02-15 2025-02-15 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/network/MessageDispatcher.h 62 2 106 82 2 1 2025-01-22 2025-02-15 jiaming.xie7@gmail.com jiaming.xie7@gmail.com cpp/celeborn/proto/TransportMessagesCpp.proto 784 1 149 149 1 1 2024-12-10 2024-12-10 jiaming.xie7@gmail.com jiaming.xie7@gmail.com multipart-uploader/multipart-uploader-oss/src/main/java/org/apache/celeborn/OssMultipartUploadHandler.java 111 1 30 30 1 1 2025-04-08 2025-04-08 897900564@qq.com 897900564@qq.com multipart-uploader/multipart-uploader-s3/src/main/java/org/apache/celeborn/S3MultipartUploadHandler.java 160 1 55 55 1 1 2025-03-14 2025-03-14 897900564@qq.com 897900564@qq.com web/index.html 13 1 475 475 1 1 2024-01-19 2024-01-19 739955946@qq.com 739955946@qq.com web/src/views/overview/components/index.ts 12 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/components/WorkerOverview.vue 24 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/components/ClusterOverview.vue 21 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/components/ApplicationOverview.vue 23 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/components/MasterOverview.vue 21 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/components/StorageOverview.vue 27 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/overview/index.vue 53 3 472 421 3 1 2024-01-22 2024-03-13 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/detail.vue 40 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/index.ts 11 2 421 420 2 1 2024-03-13 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/WorkerTable.vue 100 2 421 420 2 1 2024-03-13 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/WorkerDetailContent.vue 41 2 420 415 3 2 2024-03-14 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/WorkerForm.vue 36 2 421 420 2 1 2024-03-13 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/WorkerDetailOverview.vue 23 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/detail/index.ts 3 2 420 415 2 1 2024-03-14 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/detail/WorkerDetailMemory.vue 29 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/components/detail/WorkerDetailStorage.vue 43 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/worker/index.vue 29 2 472 421 2 1 2024-01-22 2024-03-13 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/tenant/detail.vue 38 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/index.ts 12 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/TenantTable.vue 59 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/TenantDetailTable.vue 33 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/TenantOverview.vue 27 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/TenantDetailOverview.vue 26 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/components/TenantForm.vue 32 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/tenant/index.vue 28 2 472 415 2 2 2024-01-22 2024-03-19 idioticzhou@foxmail.com 913784771@qq.com web/src/views/application/components/index.ts 3 2 422 415 2 1 2024-03-12 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/application/components/ApplicationTable.vue 49 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/application/components/ApplicationForm.vue 45 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/views/application/index.vue 31 4 472 415 4 2 2024-01-22 2024-03-19 idioticzhou@foxmail.com 913784771@qq.com web/src/views/master/detail.vue 63 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/master/components/index.ts 10 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/master/components/MasterDetailContent.vue 42 1 415 415 2 2 2024-03-19 2024-03-19 913784771@qq.com idioticzhou@foxmail.com web/src/views/master/components/MasterTable.vue 92 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/master/components/MasterLeader.vue 24 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/master/components/MasterDetailOverview.vue 22 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/views/master/index.vue 27 2 472 415 2 1 2024-01-22 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/index.ts 6 3 429 415 3 3 2024-03-05 2024-03-19 labbomb@163.com 913784771@qq.com web/src/api/models/cluster/index.ts 6 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/cluster/types/index.ts 1 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/cluster/types/cluster.ts 4 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/worker/index.ts 13 3 426 420 3 1 2024-03-08 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/worker/types/index.ts 2 2 426 420 2 1 2024-03-08 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/worker/types/worker.ts 24 3 426 415 3 1 2024-03-08 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/worker/types/detail.ts 36 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/tenant/index.ts 13 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/api/models/tenant/types/index.ts 2 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/api/models/tenant/types/tenant.ts 9 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/api/models/tenant/types/detail.ts 5 1 415 415 1 1 2024-03-19 2024-03-19 913784771@qq.com 913784771@qq.com web/src/api/models/application/index.ts 10 2 426 422 2 2 2024-03-08 2024-03-12 idioticzhou@foxmail.com 913784771@qq.com web/src/api/models/application/types/index.ts 1 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/application/types/application.ts 26 3 426 420 3 2 2024-03-08 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/master/index.ts 13 2 426 415 2 1 2024-03-08 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/master/types/index.ts 2 2 426 415 2 1 2024-03-08 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/master/types/master.ts 14 2 426 415 2 1 2024-03-08 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/master/types/detail.ts 15 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/storage/index.ts 6 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/storage/types/index.ts 1 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/models/storage/types/storage.ts 5 1 426 426 1 1 2024-03-08 2024-03-08 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/api/request.ts 53 2 429 426 2 2 2024-03-05 2024-03-08 labbomb@163.com idioticzhou@foxmail.com web/src/api/types.ts 10 3 429 421 3 3 2024-03-05 2024-03-13 labbomb@163.com idioticzhou@foxmail.com web/src/layouts/components/menus/index.vue 23 2 472 420 2 1 2024-01-22 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/layouts/layoutPage.vue 48 2 475 472 2 2 2024-01-19 2024-01-22 739955946@qq.com idioticzhou@foxmail.com web/src/components/configuration-service/index.vue 45 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/components/log-files-service/index.vue 31 1 415 415 1 1 2024-03-19 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/utils/index.ts 1 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/utils/transform.ts 9 1 420 420 1 1 2024-03-14 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/assets/styles/index.scss 11 3 475 421 3 3 2024-01-19 2024-03-13 739955946@qq.com idioticzhou@foxmail.com web/src/assets/styles/base.scss 1 1 475 475 1 1 2024-01-19 2024-01-19 739955946@qq.com 739955946@qq.com web/src/router/modules/tenant.ts 19 2 472 415 2 2 2024-01-22 2024-03-19 idioticzhou@foxmail.com 913784771@qq.com web/src/router/modules/overview.ts 6 2 475 472 2 2 2024-01-19 2024-01-22 739955946@qq.com idioticzhou@foxmail.com web/src/router/modules/master.ts 19 2 472 415 2 1 2024-01-22 2024-03-19 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/router/modules/worker.ts 19 2 472 420 2 1 2024-01-22 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/router/modules/application.ts 6 1 472 472 1 1 2024-01-22 2024-01-22 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/router/index.ts 18 2 475 472 2 2 2024-01-19 2024-01-22 739955946@qq.com idioticzhou@foxmail.com web/src/router/routes.ts 23 2 475 472 2 2 2024-01-19 2024-01-22 739955946@qq.com idioticzhou@foxmail.com web/src/main.ts 9 1 475 475 1 1 2024-01-19 2024-01-19 739955946@qq.com 739955946@qq.com web/src/composables/index.ts 2 2 429 421 2 2 2024-03-05 2024-03-13 labbomb@163.com idioticzhou@foxmail.com web/src/composables/pagination.ts 77 4 429 420 4 3 2024-03-05 2024-03-14 labbomb@163.com idioticzhou@foxmail.com web/src/composables/form.ts 16 2 421 420 2 1 2024-03-13 2024-03-14 idioticzhou@foxmail.com idioticzhou@foxmail.com web/src/App.vue 7 2 475 472 2 2 2024-01-19 2024-01-22 739955946@qq.com idioticzhou@foxmail.com web/vite.config.ts 51 3 475 426 3 2 2024-01-19 2024-03-08 739955946@qq.com idioticzhou@foxmail.com toolkit/scripts/genConfs.py 135 8 934 674 8 3 2022-10-17 2023-07-04 fengmingxiao.fmx@alibaba-inc.com angers.zhu@gmail.com toolkit/scripts/check.py 36 1 934 934 1 1 2022-10-17 2022-10-17 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com toolkit/scripts/genSkewData.scala 40 1 934 934 1 1 2022-10-17 2022-10-17 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornSortBasedPusher.java 281 3 602 379 3 3 2023-09-14 2024-04-24 fengmingxiao.fmx@alibaba-inc.com gglifulong@163.com client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornMapOutputCollector.java 101 3 602 155 3 3 2023-09-14 2024-12-04 fengmingxiao.fmx@alibaba-inc.com sanskarmodi97@gmail.com client-mr/mr/src/main/java/org/apache/hadoop/mapreduce/task/reduce/CelebornShuffleConsumer.java 149 5 602 112 5 4 2023-09-14 2025-01-16 fengmingxiao.fmx@alibaba-inc.com fwang12@ebay.com client-mr/mr/src/main/java/org/apache/hadoop/mapreduce/task/reduce/CelebornShuffleFetcher.java 183 2 602 283 2 1 2023-09-14 2024-07-29 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-mr/mr/src/main/java/org/apache/celeborn/util/HadoopUtils.java 22 2 602 325 2 2 2023-09-14 2024-06-17 fengmingxiao.fmx@alibaba-inc.com programgeek@163.com client-mr/mr/src/main/java/org/apache/celeborn/mapreduce/v2/app/MRAppMasterWithCeleborn.java 177 8 602 203 8 4 2023-09-14 2024-10-17 fengmingxiao.fmx@alibaba-inc.com chenkovsky@qq.com