path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor src/main/java/com/uber/rss/metrics/WriteClientMetrics.java 49 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/NettyServerSideMetricsKey.java 28 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/M3DummyScopeBuilder.java 40 4 1323 1276 4 2 2020-08-20 2020-10-06 boy@uber.com boy-uber@users.noreply.github.com src/main/java/com/uber/rss/metrics/ReadClientMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/WriteClientMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/NettyServerSideMetricGroupContainer.java 14 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/MetadataClientMetricsKey.java 41 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/NotifyServerMetricsContainer.java 19 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ExceptionMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ClientConnectMetrics.java 28 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ExceptionMetricGroupContainer.java 12 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ApplicationMetrics.java 22 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetrics.java 27 2 1323 1322 3 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ScheduledMetricCollector.java 97 4 1323 1282 6 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ReadClientMetrics.java 44 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/MetricGroup.java 15 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/MetadataClientMetricsContainer.java 12 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/NotifyClientMetrics.java 22 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/NotifyClientMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/M3Stats.java 106 4 1323 1023 6 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metrics/M3DummyScope.java 92 4 1323 1276 4 2 2020-08-20 2020-10-06 boy@uber.com boy-uber@users.noreply.github.com src/main/java/com/uber/rss/metrics/ApplicationJobStatusMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/MetricGroupContainer.java 19 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ExceptionMetrics.java 29 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ApplicationMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/MetadataClientMetrics.java 39 4 1323 1021 4 3 2020-08-20 2021-06-18 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metrics/ShuffleClientStageMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ServerHandlerMetrics.java 35 4 1323 1023 6 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metrics/ClientConnectMetricsKey.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metrics/ShuffleClientStageMetrics.java 34 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClient.java 16 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/EofRecordKeyValuePair.java 6 6 1323 1023 6 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/ServerReplicationGroupUtil.java 55 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/RetriableSocketReadClient.java 92 7 1323 1273 10 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/StreamDecoderBase.java 117 4 1323 1024 4 2 2020-08-20 2021-06-15 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java 332 6 1323 1273 9 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ServerConnectionCacheUpdateRefresher.java 39 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ServerConnectionRefresher.java 5 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ReplicatedReadClient.java 365 7 1323 1273 10 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/BlockingSingleServerReadClient.java 5 2 1024 1023 2 1 2021-06-15 2021-06-16 mabansal@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/PooledWriteClientFactory.java 253 4 1323 1273 6 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/MultiServerHeartbeatClient.java 115 1 1282 1282 3 2 2020-09-30 2020-09-30 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/BusyStatusSocketClient.java 32 2 1269 1253 4 3 2020-10-13 2020-10-29 boy-uber@users.noreply.github.com mabansal@uber.com src/main/java/com/uber/rss/clients/LazyWriteClient.java 70 2 990 986 2 2 2021-07-19 2021-07-23 mayurb@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/SingleServerReadClient.java 5 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/DataBlockSocketReadClient.java 299 10 1323 1252 16 2 2020-08-20 2020-10-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleDataReader.java 6 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/RecordSocketReadClient.java 83 9 1323 1023 12 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/TaskByteArrayDataBlock.java 48 4 1277 1023 4 3 2020-10-05 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/ClientRetryOptions.java 28 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/SingleServerWriteClient.java 5 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/NotifyClient.java 62 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleDataSyncWriteClientBase.java 86 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/ServerIdAwareSyncWriteClient.java 127 5 1323 1273 8 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ServerIdAwareSocketReadClient.java 69 7 1323 1273 10 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/PlainShuffleDataSocketReadClient.java 18 2 1273 1256 4 2 2020-10-09 2020-10-26 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleDataSocketReadClient.java 83 2 1273 1256 4 2 2020-10-09 2020-10-26 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/BlockingShuffleDataReader.java 6 2 1024 1023 2 1 2021-06-15 2021-06-16 mabansal@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/DataBlockSyncWriteClient.java 142 7 1323 1252 9 2 2020-08-20 2020-10-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleDataWriter.java 10 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/MultiServerReadClient.java 4 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/BlockingQueueReadClient.java 84 6 1323 1023 6 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/ServerConnectionStringCache.java 28 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ReplicatedWriteClient.java 153 5 1323 1273 8 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/RegistryClient.java 47 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/WriteClientFactory.java 4 4 1323 1273 6 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/PooledShuffleDataSyncWriteClient.java 113 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/MultiServerWriteClient.java 4 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ClientConstants.java 4 3 1323 1260 4 2 2020-08-20 2020-10-22 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/ServerConnectionStringResolver.java 5 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ServerBusyRetriableWriteClient.java 106 6 1323 1024 8 3 2020-08-20 2021-06-15 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/TaskDataBlock.java 48 1 1273 1273 2 2 2020-10-09 2020-10-09 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/PlainShuffleDataSyncWriteClient.java 26 2 1273 1256 4 2 2020-10-09 2020-10-26 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/MultiServerSocketReadClient.java 149 7 1323 1273 10 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ReadClientDataOptions.java 31 5 1323 1275 6 2 2020-08-20 2020-10-07 boy@uber.com boy-uber@users.noreply.github.com src/main/java/com/uber/rss/clients/ClientBase.java 268 3 1323 1310 3 1 2020-08-20 2020-09-02 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java 160 5 1323 1273 8 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/clients/ShuffleWriteConfig.java 31 4 1323 1276 4 2 2020-08-20 2020-10-06 boy@uber.com boy-uber@users.noreply.github.com src/main/java/com/uber/rss/clients/HeartbeatSocketClient.java 34 2 1282 1252 4 2 2020-09-30 2020-10-30 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/clients/FailedFetchRecordKeyValuePair.java 11 6 1323 1023 6 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/clients/UnpooledWriteClientFactory.java 23 4 1323 1273 6 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/TestUtils.java 48 3 1323 1277 4 2 2020-08-20 2020-10-05 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/StreamReadClientVerify.java 156 7 1323 1273 10 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/StreamServerStressToolLongRun.java 118 5 1323 1266 6 2 2020-08-20 2020-10-16 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/PartitionFileChecker.java 98 4 1323 429 4 3 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/tools/StreamServerStressToolWrite64GB.java 29 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/FileDescriptorStressTest.java 68 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/StreamServerStressTool.java 615 13 1323 1023 24 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/tools/FsyncPerfTest.java 131 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/tools/SerializerBenchmark.java 164 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/AppDeletionStateItem.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java 85 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/BaseMessage.java 4 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/StageCorruptionStateItem.java 36 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectUploadRequest.java 46 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ShuffleDataWrapper.java 31 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectRegistryRequest.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetDataAvailabilityResponse.java 47 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetDataAvailabilityRequestMessage.java 21 2 1027 1024 3 1 2021-06-12 2021-06-15 mabansal@uber.com mabansal@uber.com src/main/java/com/uber/rss/messages/ServerResponseMessage.java 13 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java 89 2 1027 1024 2 1 2021-06-12 2021-06-15 mabansal@uber.com mabansal@uber.com src/main/java/com/uber/rss/messages/FinishApplicationAttemptRequestMessage.java 38 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/FinishUploadMessage.java 47 4 1323 1273 5 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/RegisterServerResponseMessage.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetDataAvailabilityRequest.java 21 3 1323 1273 4 2 2020-08-20 2020-10-09 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectUploadResponse.java 46 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/HeartbeatMessage.java 54 1 1282 1282 2 2 2020-09-30 2020-09-30 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/messages/ShuffleStageStatus.java 59 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectNotifyResponse.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetBusyStatusResponse.java 60 1 1269 1269 2 2 2020-10-13 2020-10-13 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectNotifyRequest.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectDownloadResponse.java 81 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/FinishApplicationJobRequestMessage.java 70 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/RegisterServerRequestMessage.java 62 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetServersRequestMessage.java 46 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetServersResponseMessage.java 44 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/StageInfoStateItem.java 72 5 1323 1268 6 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/MessageConstants.java 46 11 1323 1024 17 3 2020-08-20 2021-06-15 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/messages/SerializableMessage.java 5 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ConnectRegistryResponse.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/TaskAttemptCommitStateItem.java 78 3 1323 1268 4 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/ControlMessage.java 3 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/StartUploadMessage.java 78 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/messages/GetBusyStatusRequest.java 30 1 1269 1269 2 2 2020-10-13 2020-10-13 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/util/SystemUtils.java 14 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/StringUtils.java 95 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/StreamUtils.java 37 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/AsyncSocketCompletionHandler.java 39 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/NetworkUtils.java 57 6 1323 1269 9 2 2020-08-20 2020-10-13 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/RateCounter.java 40 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/MovingAverageCalculator.java 33 1 1269 1269 2 2 2020-10-13 2020-10-13 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/util/ObjectWrapper.java 30 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/CountedOutputStream.java 31 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/AsyncSocketState.java 32 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/RetryUtils.java 96 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/FileUtils.java 119 2 1323 1322 3 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/MonitorUtils.java 20 4 1323 1315 5 1 2020-08-20 2020-08-28 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/ExceptionUtils.java 43 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/SocketAsyncWriteCallback.java 3 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/NettyUtils.java 14 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/ServerHostAndPort.java 57 1 1282 1282 3 2 2020-09-30 2020-09-30 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/util/ThreadUtils.java 15 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/ByteBufUtils.java 77 3 1323 1317 3 1 2020-08-20 2020-08-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/JsonUtils.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/SocketUtils.java 78 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/HttpUtils.java 29 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/util/LogUtils.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/StreamServer.java 303 12 1323 1259 17 3 2020-08-20 2020-10-23 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/StreamServerConfig.java 283 11 1323 1259 15 3 2020-08-20 2020-10-23 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/exceptions/RssInvalidServerIdException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssTooMuchDataException.java 8 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssAggregateException.java 24 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssUnsupportedCompressionException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssDiskSpaceException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssInvalidMapStatusException.java 8 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssNetworkException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssShuffleDataNotAvailableException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/ExceptionWrapper.java 16 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssFileCorruptedException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssInconsistentReplicaException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssServerResolveException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssInvalidServerVersionException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssStaleTaskAttemptException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssQueueNotReadyException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssNoActiveReadClientException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssDuplicateAppTaskAttemptException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssInvalidStateException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssMissingShuffleWriteConfigException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssOperationQueueFullException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssNonRecoverableException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssFinishUploadException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssRetryTimeoutException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssInvalidDataException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssServerBusyException.java 8 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssNoServerAvailableException.java 8 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssMaxConnectionsException.java 29 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssEndOfStreamException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssStreamReadException.java 17 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssWriteRecordException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssUberEnvironmentException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssShuffleCorruptedException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssServerDownException.java 8 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssRetryableSparkTaskException.java 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/exceptions/RssShuffleStageNotStartedException.java 9 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/storage/ShuffleFileUtils.java 23 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/storage/ShuffleStorage.java 14 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/storage/ShuffleFileStorage.java 82 4 1323 1276 4 2 2020-08-20 2020-10-06 boy@uber.com boy-uber@users.noreply.github.com src/main/java/com/uber/rss/storage/ShuffleOutputStream.java 7 3 1323 1266 4 2 2020-08-20 2020-10-16 boy@uber.com boy@uber.com src/main/java/com/uber/rss/storage/ShuffleFileOutputStream.java 71 7 1323 1023 10 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/common/DataBlockHeader.java 35 3 1323 1317 3 1 2020-08-20 2020-08-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/FilePathAndLength.java 35 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ServerReplicationGroup.java 18 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/MapTaskRssInfo.java 62 2 1304 1282 3 2 2020-09-08 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ServerList.java 55 3 1323 1304 3 1 2020-08-20 2020-09-08 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/AppMapId.java 55 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/MemoryMonitor.java 70 5 1323 1023 8 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/common/ServerDetailCollection.java 56 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/AppTaskAttemptId.java 71 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ServerCandidate.java 28 3 1269 1253 6 3 2020-10-13 2020-10-29 boy-uber@users.noreply.github.com mabansal@uber.com src/main/java/com/uber/rss/common/PartitionFilePathAndLength.java 42 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/Compression.java 56 4 1323 429 4 3 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/common/LowMemoryListener.java 4 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/AppShuffleId.java 42 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/MapTaskCommitStatus.java 64 7 1323 1268 9 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ServerDetail.java 65 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ServerRole.java 6 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/FixedLengthInputStream.java 86 1 1282 1282 3 2 2020-09-30 2020-09-30 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/common/DownloadServerVerboseInfo.java 32 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/AppShufflePartitionId.java 62 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/DataBlock.java 21 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/common/ShuffleMapTaskAttemptId.java 42 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/ShuffleExecutor.java 547 13 1323 1256 20 3 2020-08-20 2020-10-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/StateStoreLoadResult.java 52 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/ExecutorShuffleStageState.java 229 7 1323 1266 10 2 2020-08-20 2020-10-16 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/ShuffleDataWrapper.java 36 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/ShufflePartitionWriter.java 147 7 1323 1266 10 2 2020-08-20 2020-10-16 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/StagePersistentInfo.java 35 3 1323 1268 4 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/TaskAttemptCollection.java 23 3 1323 1268 4 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/StateStore.java 15 3 1323 1268 4 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/LocalFileStateStore.java 204 4 1323 1253 6 2 2020-08-20 2020-10-29 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/LocalFileStateStoreIterator.java 173 3 1323 1253 4 2 2020-08-20 2020-10-29 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/ExecutorAppState.java 33 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/execution/TaskAttemptIdAndState.java 40 3 1323 1268 4 2 2020-08-20 2020-10-14 boy@uber.com boy@uber.com src/main/java/com/uber/rss/decoders/StreamServerMessageDecoder.java 347 11 1323 1023 17 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/decoders/StreamServerVersionDecoder.java 113 6 1323 1256 8 3 2020-08-20 2020-10-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/RssBuildInfo.java 24 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metadata/ZooKeeperFaultTolerantServiceRegistry.java 63 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metadata/ServiceRegistryUtils.java 151 8 1323 1023 12 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metadata/ZooKeeperServiceRegistry.java 191 4 1323 988 4 3 2020-08-20 2021-07-21 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metadata/ServiceRegistry.java 21 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metadata/InMemoryServiceRegistry.java 62 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metadata/StandaloneServiceRegistryClient.java 53 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/metadata/ServiceRegistryWrapper.java 93 4 1323 1021 4 3 2020-08-20 2021-06-18 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/metadata/ZooKeeperServerNodeData.java 24 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/ChannelIdleCheck.java 52 1 1256 1256 2 2 2020-10-26 2020-10-26 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/handlers/DownloadChannelInboundHandler.java 159 13 1323 1252 20 3 2020-08-20 2020-10-30 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/NotifyChannelInboundHandler.java 54 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/ResponseStatusAndMessage.java 22 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/UploadChannelInboundHandler.java 184 17 1323 1023 27 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/handlers/NotifyServerHandler.java 49 3 1323 1318 4 1 2020-08-20 2020-08-25 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/DownloadServerHandler.java 155 11 1323 1023 17 3 2020-08-20 2021-06-16 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/handlers/UploadChannelManager.java 37 5 1323 1260 7 3 2020-08-20 2020-10-22 boy@uber.com mabansal@uber.com src/main/java/com/uber/rss/handlers/ChannelFutureCloseListener.java 17 1 1256 1256 2 2 2020-10-26 2020-10-26 boy-uber@users.noreply.github.com boy@uber.com src/main/java/com/uber/rss/handlers/RegistryServerHandler.java 46 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/HttpChannelInboundHandler.java 76 3 1323 1317 4 1 2020-08-20 2020-08-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/RegistryChannelInboundHandler.java 55 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/UploadServerHandler.java 103 10 1323 1256 15 3 2020-08-20 2020-10-26 boy@uber.com boy@uber.com src/main/java/com/uber/rss/handlers/HandlerUtil.java 47 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleManager.scala 364 16 1323 429 21 7 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/RssEmptyShuffleReader.scala 19 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleReader.scala 90 10 1323 429 11 5 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/RssOpts.scala 175 17 1323 429 23 6 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationImpl.scala 99 2 1023 1022 2 2 2021-06-16 2021-06-17 mayurdb31@gmail.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/WriterBufferManager.scala 105 4 1282 1022 7 4 2020-09-30 2021-06-17 boy-uber@users.noreply.github.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/MapOutputRssInfo.scala 9 7 1323 1275 8 2 2020-08-20 2020-10-07 boy@uber.com boy-uber@users.noreply.github.com src/main/scala/org/apache/spark/shuffle/rss/EmptyRecordIterator.scala 11 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/rss/WriterAggregationManager.scala 32 2 1023 1022 2 2 2021-06-16 2021-06-17 mayurdb31@gmail.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRangeRecordIterator.scala 175 14 1323 429 16 5 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/RssUtils.scala 82 10 1323 1267 11 3 2020-08-20 2020-10-15 boy@uber.com boy-uber@users.noreply.github.com src/main/scala/org/apache/spark/shuffle/rss/WriterNoAggregationManager.scala 14 2 1023 1022 2 2 2021-06-16 2021-06-17 mayurdb31@gmail.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/RssStressTool.scala 348 14 1282 429 21 7 2020-09-30 2023-01-31 boy-uber@users.noreply.github.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/BlockDownloaderPartitionRecordIterator.scala 174 9 1323 429 11 4 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/rss/RssSparkListener.scala 111 3 1323 1282 4 2 2020-08-20 2020-09-30 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssServiceRegistry.scala 63 2 1022 1021 2 2 2021-06-17 2021-06-18 harshvardhan5795@gmail.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleServerHandle.scala 7 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleHandle.scala 19 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/MockTaskContext.scala 50 1 1282 1282 2 2 2020-09-30 2020-09-30 boy-uber@users.noreply.github.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleWriter.scala 181 14 1323 429 19 7 2020-08-20 2023-01-31 boy@uber.com mabansal@uber.com src/main/scala/org/apache/spark/shuffle/RssServerSelectionResult.scala 3 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com src/main/scala/org/apache/spark/shuffle/RssShuffleBlockResolver.scala 10 2 1323 1322 2 1 2020-08-20 2020-08-21 boy@uber.com boy@uber.com