path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor codecov.yml 11 1 240 240 2 1 2022-12-15 2022-12-15 ethanfeng@apache.org ethanfeng@apache.org mkdocs.yml 75 14 337 8 18 5 2022-09-09 2023-08-04 chengpan@apache.org xiyu.zk@alibaba-inc.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java 316 13 308 26 16 7 2022-10-08 2023-07-17 chengpan@apache.org zky.zhoukeyong@alibaba-inc.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java 342 13 308 26 16 6 2022-10-08 2023-07-17 chengpan@apache.org zky.zhoukeyong@alibaba-inc.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java 100 6 308 39 6 2 2022-10-08 2023-07-04 chengpan@apache.org angers.zhu@gmail.com client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java 202 8 43 23 12 5 2023-06-30 2023-07-20 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala 13 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala 32 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala 94 3 39 24 3 3 2023-07-04 2023-07-19 angers.zhu@gmail.com chengpan@apache.org client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java 416 19 308 24 22 9 2022-10-08 2023-07-19 chengpan@apache.org lyh-36@163.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java 359 17 308 24 20 7 2022-10-08 2023-07-19 chengpan@apache.org lyh-36@163.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java 132 7 308 39 7 2 2022-10-08 2023-07-04 chengpan@apache.org angers.zhu@gmail.com client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java 287 7 43 23 12 4 2023-06-30 2023-07-20 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/java/org/apache/spark/sql/execution/columnar/CelebornColumnDictionary.java 36 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala 13 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala 38 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala 111 3 39 24 3 3 2023-07-04 2023-07-19 angers.zhu@gmail.com chengpan@apache.org client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala 18 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala 46 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala 105 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala 67 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala 299 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala 355 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala 49 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala 233 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala 271 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala 48 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala 485 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala 138 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornBatchBuilder.scala 28 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala 102 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java 80 4 308 24 4 2 2022-10-08 2023-07-19 chengpan@apache.org zky.zhoukeyong@alibaba-inc.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/TaskInterruptedHelper.java 12 1 87 87 1 1 2023-05-17 2023-05-17 angers.zhu@gmail.com angers.zhu@gmail.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorter.java 103 2 308 64 2 1 2022-10-08 2023-06-09 chengpan@apache.org chengpan@apache.org client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/PackedRecordPointer.java 30 1 308 308 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/SortBasedPusher.java 341 14 308 26 17 6 2022-10-08 2023-07-17 chengpan@apache.org zky.zhoukeyong@alibaba-inc.com client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/OpenByteArrayOutputStream.java 10 1 308 308 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org version.sbt 1 1 15 15 1 1 2023-07-28 2023-07-28 cfmcgrady@gmail.com cfmcgrady@gmail.com charts/celeborn/Chart.yaml 8 2 213 142 2 1 2023-01-11 2023-03-23 52876270+zwangsheng@users.noreply.github.com 52876270+zwangsheng@users.noreply.github.com charts/celeborn/templates/master-service.yaml 24 2 213 142 2 1 2023-01-11 2023-03-23 52876270+zwangsheng@users.noreply.github.com 52876270+zwangsheng@users.noreply.github.com charts/celeborn/templates/master-statefulset.yaml 123 11 213 57 11 5 2023-01-11 2023-06-16 52876270+zwangsheng@users.noreply.github.com 2213335496@qq.com charts/celeborn/templates/prometheus-podmonitor.yaml 53 4 213 142 4 2 2023-01-11 2023-03-23 52876270+zwangsheng@users.noreply.github.com 52876270+zwangsheng@users.noreply.github.com charts/celeborn/templates/worker-statefulset.yaml 129 11 213 57 11 4 2023-01-11 2023-06-16 52876270+zwangsheng@users.noreply.github.com 2213335496@qq.com charts/celeborn/templates/worker-service.yaml 19 2 213 142 2 1 2023-01-11 2023-03-23 52876270+zwangsheng@users.noreply.github.com 52876270+zwangsheng@users.noreply.github.com charts/celeborn/templates/configmap.yaml 102 9 213 47 9 5 2023-01-11 2023-06-26 52876270+zwangsheng@users.noreply.github.com 2213335496@qq.com charts/celeborn/templates/_helpers.tpl 70 1 213 213 1 1 2023-01-11 2023-01-11 52876270+zwangsheng@users.noreply.github.com 52876270+zwangsheng@users.noreply.github.com charts/celeborn/values.yaml 110 10 213 39 11 5 2023-01-11 2023-07-04 52876270+zwangsheng@users.noreply.github.com angers.zhu@gmail.com project/CelebornBuild.scala 588 2 15 11 3 1 2023-07-28 2023-08-01 cfmcgrady@gmail.com cfmcgrady@gmail.com project/plugins.sbt 2 1 15 15 1 1 2023-07-28 2023-07-28 cfmcgrady@gmail.com cfmcgrady@gmail.com common/src/main/proto/TransportMessages.proto 407 60 560 5 72 11 2022-01-29 2023-08-07 fengmingxiao.fmx@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/reflect/DynFields.java 225 1 287 287 1 1 2022-10-29 2022-10-29 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynMethods.java 262 1 287 287 1 1 2022-10-29 2022-10-29 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynClasses.java 51 1 287 287 1 1 2022-10-29 2022-10-29 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/reflect/DynConstructors.java 233 1 287 287 1 1 2022-10-29 2022-10-29 chengpan@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java 140 11 190 26 11 5 2023-02-03 2023-07-17 angers.zhu@gmail.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/write/PushStrategy.java 26 2 186 72 2 2 2023-02-07 2023-06-01 anh131@126.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/write/PushState.java 55 8 190 44 8 6 2023-02-03 2023-06-29 angers.zhu@gmail.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/write/SlowStartPushStrategy.java 118 6 186 26 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/PushRequestInfo.java 15 1 177 177 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/DataBatches.java 46 1 190 190 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/SimplePushStrategy.java 26 3 186 26 3 3 2023-02-07 2023-07-17 anh131@126.com zky.zhoukeyong@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/util/ShuffleBlockInfoUtils.java 64 2 314 255 2 2 2022-10-02 2022-11-30 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java 322 5 165 40 5 4 2023-02-28 2023-07-03 zhouky@apache.org chengpan@apache.org common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java 38 5 213 4 5 2 2023-01-11 2023-08-08 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java 194 6 314 24 6 4 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/read/FetchRequestInfo.java 15 1 58 58 1 1 2023-06-15 2023-06-15 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/network/util/IOMode.java 5 1 314 314 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 76 8 314 58 9 5 2022-10-02 2023-06-15 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/network/util/ByteUnit.java 53 1 314 314 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/ConfigProvider.java 26 1 314 314 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/LimitedInputStream.java 76 2 314 163 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/AbstractFileRegion.java 29 1 314 314 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 118 4 314 40 4 4 2022-10-02 2023-07-03 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java 123 5 314 65 5 4 2022-10-02 2023-06-08 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java 126 3 314 59 3 3 2022-10-02 2023-06-14 zky.zhoukeyong@alibaba-inc.com lvshuang.tb@gmail.com common/src/main/java/org/apache/celeborn/common/network/util/FrameDecoder.java 5 1 314 314 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/TransportContext.java 115 7 314 24 7 5 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/network/server/BaseMessageHandler.java 14 1 314 314 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/MessageHandler.java 8 1 314 314 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/TransportRequestHandler.java 73 1 314 314 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/TransportChannelHandler.java 141 3 314 24 3 3 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java 118 6 314 18 6 5 2022-10-02 2023-07-25 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/RegionFinish.java 65 2 265 44 2 2 2022-11-20 2023-06-29 96606293+zhongqiangczq@users.noreply.github.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java 185 10 314 7 15 5 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/RequestMessage.java 10 1 314 314 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/ChunkFetchSuccess.java 59 2 314 24 2 2 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/BacklogAnnouncement.java 35 1 177 177 1 1 2023-02-16 2023-02-16 ethanfeng@apache.org ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/protocol/MessageDecoder.java 22 1 314 314 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 27 1 162 162 1 1 2023-03-03 2023-03-03 ethanfeng@apache.org ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/protocol/TransportableError.java 44 2 162 151 2 2 2023-03-03 2023-03-14 ethanfeng@apache.org lvshuang.tb@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchRequest.java 40 1 314 314 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/TransportMessage.java 65 3 314 7 3 3 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/PushDataHandShake.java 87 2 265 44 2 2 2022-11-20 2023-06-29 96606293+zhongqiangczq@users.noreply.github.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java 75 2 314 7 2 2 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/StreamHandle.java 47 2 314 7 2 2 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/network/protocol/RegionStart.java 87 2 265 44 2 2 2022-11-20 2023-06-29 96606293+zhongqiangczq@users.noreply.github.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/ReadData.java 41 3 218 151 3 1 2023-01-06 2023-03-14 ethanfeng@apache.org ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/protocol/RpcFailure.java 48 1 314 314 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/ResponseMessage.java 13 1 314 314 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/PushData.java 82 3 314 44 3 3 2022-10-02 2023-06-29 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java 60 2 177 7 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/RpcRequest.java 54 1 314 314 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/Encodable.java 6 1 314 314 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/Encoders.java 63 1 314 314 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/StreamChunkSlice.java 63 1 314 314 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/MessageEncoder.java 51 1 314 314 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/Heartbeat.java 20 2 94 59 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/ReadAddCredit.java 50 1 218 218 1 1 2023-01-06 2023-01-06 ethanfeng@apache.org ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/protocol/RpcResponse.java 57 1 314 314 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/ChunkFetchFailure.java 48 1 314 314 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/MessageWithHeader.java 121 2 314 24 2 2 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/network/protocol/OneWayMessage.java 50 1 314 314 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/PushMergedData.java 96 2 314 44 2 2 2022-10-02 2023-06-29 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/client/ChunkFetchFailureException.java 10 2 314 259 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/RpcResponseCallback.java 6 1 314 314 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 253 13 314 7 13 8 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/client/ChunkReceivedCallback.java 6 3 314 260 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 181 13 314 7 14 8 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java 307 13 314 7 14 6 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/network/buffer/NioManagedBuffer.java 41 1 314 314 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/buffer/NettyManagedBuffer.java 51 2 314 176 2 2 2022-10-02 2023-02-17 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org common/src/main/java/org/apache/celeborn/common/network/buffer/FileSegmentManagedBuffer.java 119 2 314 165 2 2 2022-10-02 2023-02-28 zky.zhoukeyong@alibaba-inc.com zhouky@apache.org common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java 12 2 314 24 2 2 2022-10-02 2023-07-19 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java 177 12 314 38 13 7 2022-10-02 2023-07-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/meta/FileManagedBuffers.java 36 4 314 40 4 3 2022-10-02 2023-07-03 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java 28 3 314 235 3 2 2022-10-02 2022-12-20 zky.zhoukeyong@alibaba-inc.com 30563796+nafiyaix@users.noreply.github.com common/src/main/java/org/apache/celeborn/common/protocol/CompressionCodec.java 6 2 287 43 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/SlotsAssignPolicy.java 5 1 287 287 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/StorageInfo.java 110 2 314 46 2 2 2022-10-02 2023-06-27 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/java/org/apache/celeborn/common/protocol/PartitionSplitMode.java 20 1 314 314 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/PartitionType.java 13 2 314 287 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/message/StatusCode.java 59 17 314 44 17 6 2022-10-02 2023-06-29 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/RpcNameConstants.java 9 3 314 39 3 2 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/protocol/ShuffleMode.java 5 1 287 287 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/TransportModuleConstants.java 8 1 314 314 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/ReviveRequest.java 29 1 46 46 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/PartitionLocation.java 271 9 314 44 9 7 2022-10-02 2023-06-29 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java 235 2 314 269 2 2 2022-10-02 2022-11-16 zky.zhoukeyong@alibaba-inc.com gabrielleebuaa@gmail.com common/src/main/java/org/apache/celeborn/common/client/MasterNotLeaderException.java 21 1 44 44 1 1 2023-06-29 2023-06-29 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/java/org/apache/celeborn/common/client/MasterClient.java 170 3 44 24 3 2 2023-06-29 2023-07-19 angers.zhu@gmail.com lyh-36@163.com common/src/main/scala/org/apache/celeborn/common/metrics/ResettableSlidingWindowReservoir.scala 35 1 314 314 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 314 40 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/JVMCPUSource.scala 27 3 314 40 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 339 15 314 39 16 9 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/source/ResourceConsumptionSource.scala 8 1 191 191 1 1 2023-02-02 2023-02-02 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/metrics/source/JVMSource.scala 20 3 314 54 3 3 2022-10-02 2023-06-19 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/metrics/source/SystemMiscSource.scala 27 1 88 88 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/sink/CsvSink.scala 41 1 314 314 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/sink/PrometheusServlet.scala 35 3 314 40 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/sink/Sink.scala 6 1 314 314 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/sink/PrometheusSink.scala 8 1 314 314 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/sink/GraphiteSink.scala 55 1 314 314 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/MetricsConfig.scala 71 5 314 39 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/MetricsSystem.scala 134 4 314 54 4 3 2022-10-02 2023-06-19 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala 10 4 196 40 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/metrics/CelebornTimer.scala 3 1 39 39 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/CelebornHistogram.scala 3 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala 266 2 314 44 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/JavaSerializer.scala 105 2 314 296 2 2 2022-10-02 2022-10-20 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/serializer/Serializer.scala 70 1 314 314 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/identity/DefaultIdentityProvider.scala 10 3 314 96 3 3 2022-10-02 2023-05-08 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org common/src/main/scala/org/apache/celeborn/common/identity/UserIdentifier.scala 30 4 297 40 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/identity/IdentityProvider.scala 27 5 314 96 5 4 2022-10-02 2023-05-08 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala 9 1 96 96 1 1 2023-05-08 2023-05-08 ethanfeng@apache.org ethanfeng@apache.org common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala 168 3 314 54 3 3 2022-10-02 2023-06-19 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com common/src/main/scala/org/apache/celeborn/common/util/CollectionUtils.java 17 1 193 193 1 1 2023-01-31 2023-01-31 lvshuang.tb@gmail.com lvshuang.tb@gmail.com common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala 350 17 285 44 19 9 2022-10-31 2023-06-29 30563796+nafiyaix@users.noreply.github.com cfmcgrady@gmail.com common/src/main/scala/org/apache/celeborn/common/util/NextIterator.scala 34 1 314 314 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 18 18 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/ByteBufferOutputStream.scala 30 1 314 314 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/IntParam.scala 10 1 314 314 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/CelebornHadoopUtils.scala 49 3 144 38 3 2 2023-03-21 2023-07-05 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/Utils.scala 882 40 314 8 48 16 2022-10-02 2023-08-04 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/util/FunctionConverter.scala 16 3 248 40 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/ByteBufferInputStream.scala 44 1 314 314 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 314 314 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/config/ConfigReader.scala 55 1 314 314 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/config/ConfigBuilder.scala 240 9 314 39 9 5 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/ConfigEntry.scala 185 12 314 39 12 7 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/ConfigProvider.scala 24 5 314 39 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/meta/WorkerInfo.scala 219 16 314 29 18 10 2022-10-02 2023-07-14 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala 84 9 193 44 9 5 2023-01-31 2023-06-29 lvshuang.tb@gmail.com cfmcgrady@gmail.com common/src/main/scala/org/apache/celeborn/common/meta/TimeWindow.scala 34 1 163 163 1 1 2023-03-02 2023-03-02 zhouky@apache.org zhouky@apache.org common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala 142 3 228 206 3 2 2022-12-27 2023-01-18 angers.zhu@gmail.com ckj@apache.org common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala 225 10 314 37 10 7 2022-10-02 2023-07-06 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfo.scala 138 8 193 43 8 5 2023-01-31 2023-06-30 lvshuang.tb@gmail.com cfmcgrady@gmail.com common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala 842 40 314 5 52 12 2022-10-02 2023-08-07 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/quota/QuotaManager.scala 35 6 314 138 6 4 2022-10-02 2023-03-27 zky.zhoukeyong@alibaba-inc.com fwang12@ebay.com common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala 81 5 314 240 6 3 2022-10-02 2022-12-15 zky.zhoukeyong@alibaba-inc.com 30563796+nafiyaix@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala 21 1 297 297 1 1 2022-10-19 2022-10-19 30563796+nafiyaix@users.noreply.github.com 30563796+nafiyaix@users.noreply.github.com common/src/main/scala/org/apache/celeborn/common/quota/DefaultQuotaManager.scala 38 6 314 241 6 3 2022-10-02 2022-12-14 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcCallContext.scala 6 1 314 314 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/RpcEndpointAddress.scala 24 3 314 47 3 3 2022-10-02 2023-06-26 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointNotFoundException.scala 4 2 314 277 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/RpcEnvStoppedException.scala 3 1 314 314 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 60 4 314 122 4 3 2022-10-02 2023-04-12 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/netty/Outbox.scala 186 2 314 277 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/NettyRpcEnv.scala 475 8 314 52 8 5 2022-10-02 2023-06-21 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala 164 5 314 37 5 5 2022-10-02 2023-07-06 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/rpc/netty/RpcEndpointVerifier.scala 12 1 314 314 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/netty/Inbox.scala 156 2 314 277 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 33 2 314 291 2 2 2022-10-02 2022-10-25 zky.zhoukeyong@alibaba-inc.com ethan.aquarius.fmx@gmail.com common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala 19 3 314 288 3 3 2022-10-02 2022-10-28 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org common/src/main/scala/org/apache/celeborn/common/rpc/RpcAddress.scala 21 3 314 47 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/RpcEndpoint.scala 39 2 314 277 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/RpcTimeout.scala 45 2 314 296 2 2 2022-10-02 2022-10-20 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala 3090 92 296 5 148 20 2022-10-20 2023-08-07 angers.zhu@gmail.com zky.zhoukeyong@alibaba-inc.com common/src/main/scala/org/apache/celeborn/common/exception/CelebornIOException.scala 10 2 171 169 2 1 2023-02-22 2023-02-24 angers.zhu@gmail.com angers.zhu@gmail.com common/src/main/scala/org/apache/celeborn/common/exception/FileCorruptedException.scala 6 1 119 119 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/CelebornRuntimeException.scala 5 1 94 94 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/AlreadyClosedException.scala 6 1 314 314 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/DriverChangedException.scala 5 1 88 88 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/PartitionUnRetryAbleException.scala 6 1 119 119 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/CelebornException.scala 5 1 277 277 1 1 2022-11-08 2022-11-08 490081539@qq.com 490081539@qq.com master/src/main/proto/Resource.proto 146 5 308 29 5 5 2022-10-08 2023-07-14 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com master/src/main/java/org/apache/ratis/statemachine/impl/SimpleStateMachineStorageUtil.java 13 1 86 86 1 1 2023-05-18 2023-05-18 ckj@apache.org ckj@apache.org master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java 267 26 308 16 28 9 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java 44 5 308 16 6 4 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java 91 6 308 44 6 4 2022-10-08 2023-06-29 chengpan@apache.org angers.zhu@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java 257 13 308 16 14 6 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java 334 7 308 24 7 6 2022-10-08 2023-07-19 chengpan@apache.org lyh-36@163.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java 394 13 308 24 14 6 2022-10-08 2023-07-19 chengpan@apache.org lyh-36@163.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java 213 10 308 29 11 6 2022-10-08 2023-07-14 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java 98 10 308 16 11 4 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java 93 3 308 163 4 3 2022-10-08 2023-03-02 chengpan@apache.org zhouky@apache.org master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java 411 7 308 9 8 5 2022-10-08 2023-08-03 chengpan@apache.org 2213335496@qq.com master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala 69 4 303 54 4 3 2022-10-13 2023-06-19 chengpan@apache.org sychen@ctrip.com master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterClusterInfo.scala 50 3 303 115 4 3 2022-10-13 2023-04-19 chengpan@apache.org cfmcgrady@gmail.com master/src/main/scala/org/apache/celeborn/service/deploy/master/network/CelebornRackResolver.scala 64 3 86 44 3 2 2023-05-18 2023-06-29 angers.zhu@gmail.com cfmcgrady@gmail.com master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala 57 9 308 47 10 4 2022-10-08 2023-06-26 chengpan@apache.org chengpan@apache.org master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala 783 55 308 5 72 11 2022-10-08 2023-08-07 angers.zhu@gmail.com zky.zhoukeyong@alibaba-inc.com master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala 21 6 308 40 6 2 2022-10-08 2023-07-03 chengpan@apache.org chengpan@apache.org dev/merge_pr.py 406 1 71 71 1 1 2023-06-02 2023-06-02 chengpan@apache.org chengpan@apache.org build/release/append_notice.py 27 1 226 226 1 1 2022-12-29 2022-12-29 ethanfeng@apache.org ethanfeng@apache.org build/sbt-launch-lib.bash 151 1 15 15 1 1 2023-07-28 2023-07-28 cfmcgrady@gmail.com cfmcgrady@gmail.com service/src/main/scala/org/apache/celeborn/server/common/Service.scala 20 5 308 18 6 3 2022-10-08 2023-07-25 chengpan@apache.org angers.zhu@gmail.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala 64 3 308 18 3 3 2022-10-08 2023-07-25 chengpan@apache.org angers.zhu@gmail.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala 73 8 308 16 12 3 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com service/src/main/scala/org/apache/celeborn/server/common/http/HttpServerInitializer.scala 13 1 308 308 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala 73 16 308 16 23 6 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkingPartition.java 13 1 308 308 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/ShuffleRecoverHelper.java 15 3 308 303 3 2 2022-10-08 2022-10-13 chengpan@apache.org 30563796+nafiyaix@users.noreply.github.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java 87 2 114 86 2 1 2023-04-20 2023-05-18 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferListener.java 6 1 114 114 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/ChannelsLimiter.java 114 3 114 33 3 3 2023-04-20 2023-07-10 ethanfeng@apache.org chengpan@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferRequest.java 22 1 114 114 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/BufferRecycler.java 12 1 114 114 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/RecyclableBuffer.java 13 1 114 114 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/BufferQueue.java 115 2 114 109 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/MemoryManager.java 340 6 114 33 6 5 2023-04-20 2023-07-10 ethanfeng@apache.org chengpan@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java 608 22 308 16 24 7 2022-10-08 2023-07-27 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartition.java 217 2 114 109 2 2 2023-04-20 2023-04-25 ethanfeng@apache.org lvshuang.tb@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java 364 24 308 8 28 10 2022-10-08 2023-08-04 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java 119 1 114 114 1 1 2023-04-20 2023-04-20 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileChannelUtils.java 14 1 109 109 1 1 2023-04-25 2023-04-25 lvshuang.tb@gmail.com lvshuang.tb@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FlushNotifier.java 20 1 308 308 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionFileWriter.java 246 9 247 109 9 6 2022-12-08 2023-04-25 96606293+zhongqiangczq@users.noreply.github.com lvshuang.tb@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java 380 4 114 4 4 3 2023-04-20 2023-08-08 ethanfeng@apache.org lvshuang.tb@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java 260 1 114 114 1 1 2023-04-20 2023-04-20 ethanfeng@apache.org ethanfeng@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ReducePartitionFileWriter.java 76 4 247 65 4 4 2022-12-08 2023-06-08 96606293+zhongqiangczq@users.noreply.github.com zhongqiang.czq@alibaba-inc.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java 53 4 186 33 4 2 2023-02-07 2023-07-10 anh131@126.com angers.zhu@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java 190 8 186 40 8 5 2023-02-07 2023-07-03 anh131@126.com chengpan@apache.org worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java 87 3 186 35 3 2 2023-02-07 2023-07-08 anh131@126.com angers.zhu@gmail.com worker/src/main/java/org/apache/celeborn/service/deploy/worker/LevelDBProvider.java 110 1 308 308 1 1 2022-10-08 2022-10-08 chengpan@apache.org chengpan@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala 319 26 308 4 27 9 2022-10-08 2023-08-08 chengpan@apache.org lvshuang.tb@gmail.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala 953 47 308 11 60 15 2022-10-08 2023-08-01 chengpan@apache.org caojiaqing@bilibili.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/CommitInfo.scala 8 1 259 259 1 1 2022-11-26 2022-11-26 zhouky@apache.org zhouky@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala 51 9 308 46 9 4 2022-10-08 2023-06-27 chengpan@apache.org chengpan@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala 587 28 308 40 33 12 2022-10-08 2023-07-03 chengpan@apache.org chengpan@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala 32 4 308 46 4 4 2022-10-08 2023-06-27 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala 713 47 308 8 56 19 2022-10-08 2023-08-04 chengpan@apache.org fengmingxiao.fmx@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceObserver.scala 8 2 308 285 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/ObservedDevice.scala 139 5 227 40 5 5 2022-12-28 2023-07-03 30563796+nafiyaix@users.noreply.github.com chengpan@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala 248 17 308 40 21 6 2022-10-08 2023-07-03 chengpan@apache.org chengpan@apache.org worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala 163 14 308 30 15 8 2022-10-08 2023-07-13 chengpan@apache.org zky.zhoukeyong@alibaba-inc.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala 83 18 308 11 20 10 2022-10-08 2023-08-01 chengpan@apache.org caojiaqing@bilibili.com worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala 595 62 308 16 81 18 2022-10-08 2023-07-27 chengpan@apache.org angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java 108 10 204 26 12 4 2023-01-20 2023-07-17 82567833+zy-jordan@users.noreply.github.com zky.zhoukeyong@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/write/PushTask.java 27 1 314 314 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/DataPusher.java 193 14 314 12 16 6 2022-10-02 2023-07-31 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com client/src/main/java/org/apache/celeborn/client/compress/Lz4Decompressor.java 48 1 39 39 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/Compressor.java 28 8 314 39 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/Lz4Trait.java 14 1 39 39 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 39 39 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 39 39 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/ZstdDecompressor.java 50 1 39 39 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 35 6 314 39 6 3 2022-10-02 2023-07-04 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/compress/Lz4Compressor.java 55 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/listener/WorkersStatus.java 11 1 117 117 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/WorkerStatusListener.java 4 1 117 117 1 1 2023-04-17 2023-04-17 lvshuang.tb@gmail.com lvshuang.tb@gmail.com client/src/main/java/org/apache/celeborn/client/ReviveManager.java 92 3 46 18 3 2 2023-06-27 2023-07-25 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com client/src/main/java/org/apache/celeborn/client/ShuffleClient.java 103 26 314 12 29 13 2022-10-02 2023-07-31 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java 10 3 314 87 3 3 2022-10-02 2023-05-17 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/read/MetricsCallback.java 5 1 314 314 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/read/CelebornInputStream.java 497 1 39 39 1 1 2023-07-04 2023-07-04 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java 228 10 314 7 11 6 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java 166 13 314 7 14 8 2022-10-02 2023-08-05 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java 1513 73 314 18 95 20 2022-10-02 2023-07-25 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala 386 20 240 44 20 8 2022-12-15 2023-06-29 lvshuang.tb@gmail.com cfmcgrady@gmail.com client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala 236 14 240 44 15 6 2022-12-15 2023-06-29 lvshuang.tb@gmail.com cfmcgrady@gmail.com client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala 172 14 240 44 14 5 2022-12-15 2023-06-29 lvshuang.tb@gmail.com cfmcgrady@gmail.com client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala 77 6 256 44 6 4 2022-11-29 2023-06-29 angers.zhu@gmail.com angers.zhu@gmail.com client/src/main/scala/org/apache/celeborn/client/ShuffleClientHelper.scala 45 6 314 46 6 4 2022-10-02 2023-06-27 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala 267 19 250 4 20 6 2022-12-05 2023-08-08 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-inc.com client/src/main/scala/org/apache/celeborn/client/CommitManager.scala 265 18 249 24 20 10 2022-12-06 2023-07-19 angers.zhu@gmail.com lyh-36@163.com client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala 124 6 141 39 6 6 2023-03-24 2023-07-04 lvshuang.tb@gmail.com angers.zhu@gmail.com client/src/main/scala/org/apache/celeborn/client/RequestLocationCallContext.scala 53 3 263 46 3 2 2022-11-22 2023-06-27 lvshuang.xjs@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala 188 14 122 24 16 5 2023-04-12 2023-07-19 angers.zhu@gmail.com lyh-36@163.com client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala 884 71 308 4 100 14 2022-10-08 2023-08-08 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-inc.com toolkit/scripts/check.py 36 1 299 299 1 1 2022-10-17 2022-10-17 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com toolkit/scripts/genConfs.py 135 8 299 39 8 3 2022-10-17 2023-07-04 fengmingxiao.fmx@alibaba-inc.com angers.zhu@gmail.com toolkit/scripts/genSkewData.scala 40 1 299 299 1 1 2022-10-17 2022-10-17 fengmingxiao.fmx@alibaba-inc.com fengmingxiao.fmx@alibaba-inc.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 169 2 99 46 3 2 2023-05-05 2023-06-27 ethanfeng@apache.org lvshuang.tb@gmail.com client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 219 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 29 2 99 68 2 1 2023-05-05 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java 44 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java 8 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 54 2 99 68 2 1 2023-05-05 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 38 2 99 68 2 1 2023-05-05 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java 445 5 100 39 5 4 2023-05-04 2023-07-04 ethanfeng@apache.org angers.zhu@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java 159 2 100 44 2 2 2023-05-04 2023-06-29 ethanfeng@apache.org cfmcgrady@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java 154 2 39 4 2 2 2023-07-04 2023-08-08 angers.zhu@gmail.com lvshuang.tb@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java 485 21 176 4 22 11 2023-02-17 2023-08-08 ethanfeng@apache.org fengmingxiao.fmx@alibaba-inc.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ResultPartitionAdapter.java 5 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java 176 4 100 39 4 4 2023-05-04 2023-07-04 ethanfeng@apache.org angers.zhu@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java 182 6 176 115 8 3 2023-02-17 2023-04-19 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java 59 6 176 135 7 3 2023-02-17 2023-03-30 ethanfeng@apache.org lvshuang.tb@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java 101 9 176 121 10 3 2023-02-17 2023-04-13 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java 65 4 176 94 4 2 2023-02-17 2023-05-10 ethanfeng@apache.org zhongqiang.czq@alibaba-inc.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java 78 3 100 68 3 1 2023-05-04 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java 41 3 100 39 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/utils/Utils.java 35 1 234 234 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/BufferUtils.java 80 2 234 211 2 2 2022-12-21 2023-01-13 chengpan@apache.org 96606293+zhongqiangczq@users.noreply.github.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java 49 6 100 39 6 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/utils/ThreadUtils.java 26 1 100 100 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/protocol/ReadData.java 51 3 176 151 5 1 2023-02-17 2023-03-14 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleDescriptor.java 56 1 100 100 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/RemoteShuffleMaster.java 191 9 100 24 9 4 2023-05-04 2023-07-19 ethanfeng@apache.org angers.zhu@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResource.java 5 1 100 100 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/FlinkResultPartitionInfo.java 39 1 100 100 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/ShuffleResourceDescriptor.java 37 1 100 100 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/AbstractRemoteShuffleResultPartitionFactory.java 145 4 100 68 4 1 2023-05-04 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java 261 2 100 46 3 2 2023-05-04 2023-06-27 ethanfeng@apache.org lvshuang.tb@gmail.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfo.java 67 1 100 100 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/AbstractRemoteShuffleServiceFactory.java 67 1 100 100 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/AbstractRemoteShuffleEnvironment.java 132 1 100 100 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/buffer/SortBuffer.java 32 4 234 24 4 4 2022-12-21 2023-07-19 chengpan@apache.org lyh-36@163.com client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferRecycler.java 5 1 176 176 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/FlinkNettyManagedBuffer.java 39 1 176 176 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/TransferBufferPool.java 154 1 176 176 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/PartitionSortedBuffer.java 272 2 234 149 2 2 2022-12-21 2023-03-16 chengpan@apache.org zhouky@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferHeader.java 39 1 234 234 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/buffer/BufferPacker.java 254 6 234 100 6 5 2022-12-21 2023-05-04 chengpan@apache.org ethanfeng@apache.org client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/Buffer.java 19 1 176 176 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/CreditListener.java 21 1 176 176 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/RemoteBufferStreamReader.java 118 4 100 4 4 4 2023-05-04 2023-08-08 ethanfeng@apache.org lvshuang.tb@gmail.com client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 156 4 234 46 4 4 2022-12-21 2023-06-27 96606293+zhongqiangczq@users.noreply.github.com lvshuang.tb@gmail.com client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 197 8 176 100 8 3 2023-02-17 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 29 6 176 68 6 3 2023-02-17 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java 44 3 211 100 3 2 2023-01-13 2023-05-04 96606293+zhongqiangczq@users.noreply.github.com ethanfeng@apache.org client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java 8 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 54 5 211 68 5 3 2023-01-13 2023-06-05 96606293+zhongqiangczq@users.noreply.github.com ethanfeng@apache.org client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 34 7 248 68 7 4 2022-12-07 2023-06-05 lvshuang.xjs@alibaba-inc.com ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java 157 2 100 46 3 2 2023-05-04 2023-06-27 ethanfeng@apache.org lvshuang.tb@gmail.com client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java 212 1 100 100 1 1 2023-05-04 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java 29 2 100 68 2 1 2023-05-04 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java 44 1 100 100 1 1 2023-05-04 2023-05-04 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java 8 1 99 99 1 1 2023-05-05 2023-05-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java 54 3 100 68 3 1 2023-05-04 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java 34 3 100 68 3 1 2023-05-04 2023-06-05 ethanfeng@apache.org ethanfeng@apache.org