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