This is an automated email from the ASF dual-hosted git repository.
roryqi pushed a change to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
from 1431c8a1b [#1631] fix(server): ShuffleTaskInfo may leak when app is
removed. (#1632)
new ac69e8460 [#1626] fix(server): Remove the meaningless
eventOfUnderStorageManagers cache (#1627)
new 54b1f5962 [#1596][FOLLOWUP] fix(netty): Send failed responses only
when the channel is writable (#1641)
new b37fa06c7 [MINOR] chore(rust): disable flaky test of
test_ticket_manager (#1637)
new 9e0cf9f80 [#1634] fix(server): remove app folder if app is expired
(#1635)
new 92d984b04 [#1629] fix(operator): Support parsing NaN float value in
metrics (#1630)
new 51a2639c5 [#1662] fix(test): Fix Netty related flaky tests (#1663)
new f4a4c8f7a [#378][FOLLOWUP] fix(server): Fix huge_partition_num metric
(#1669)
new 5a1c9fe39 [#1341] fix(mr): Fix MR Combiner
ArrayIndexOutOfBoundsException Bug. (#1666)
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/hadoop/mapred/SortWriteBuffer.java | 45 ++++++++++---
.../hadoop/mapred/SortWriteBufferManagerTest.java | 7 +-
.../apache/hadoop/mapred/SortWriteBufferTest.java | 53 +++++++++++++++
.../manager/ShuffleManagerServerFactory.java | 2 +-
.../shuffle/reader/RssShuffleDataIteratorTest.java | 2 +
.../manager/ShuffleManagerServerFactoryTest.java | 25 +++----
.../uniffle/client/impl/ShuffleReadClientImpl.java | 9 ++-
.../client/impl/ShuffleReadClientImplTest.java | 2 +
.../kubernetes/operator/pkg/webhook/util/util.go | 37 +++++++++--
.../operator/pkg/webhook/util/util_test.go | 72 ++++++++++++++++++++
.../uniffle/test/DiskErrorToleranceTest.java | 6 +-
.../test/HybridStorageFaultToleranceBase.java | 22 +++----
.../test/HybridStorageHadoopFallbackTest.java | 6 --
.../test/HybridStorageLocalFileFallbackTest.java | 6 --
.../java/org/apache/uniffle/test/QuorumTest.java | 1 +
.../apache/uniffle/test/RpcClientRetryTest.java | 1 +
.../ShuffleServerConcurrentWriteOfHadoopTest.java | 2 +
.../test/ShuffleServerFaultToleranceTest.java | 6 +-
.../apache/uniffle/test/ShuffleServerGrpcTest.java | 6 --
.../uniffle/test/ShuffleServerWithHadoopTest.java | 18 ++---
.../ShuffleServerWithKerberizedHadoopTest.java | 23 ++-----
.../ShuffleServerWithLocalOfExceptionTest.java | 1 -
.../ShuffleServerWithLocalOfLocalOrderTest.java | 6 --
.../uniffle/test/ShuffleServerWithLocalTest.java | 6 --
.../test/ShuffleServerWithMemLocalHadoopTest.java | 15 ++---
.../uniffle/test/ShuffleServerWithMemoryTest.java | 6 --
.../uniffle/test/ShuffleWithRssClientTest.java | 2 +
.../org/apache/uniffle/test/DynamicConfTest.java | 1 +
.../test/RepartitionWithLocalFileRssTest.java | 31 +++++++--
.../uniffle/test/RepartitionWithMemoryRssTest.java | 2 +-
.../apache/uniffle/test/RssShuffleManagerTest.java | 6 +-
.../uniffle/test/SparkClientWithLocalTest.java | 6 +-
.../uniffle/test/SparkIntegrationTestBase.java | 23 ++++---
.../ContinuousSelectPartitionStrategyTest.java | 15 ++++-
.../test/GetShuffleReportForMultiPartTest.java | 4 +-
.../impl/grpc/ShuffleServerGrpcNettyClient.java | 8 ++-
rust/experimental/server/src/store/mem/ticket.rs | 1 +
.../apache/uniffle/server/ShuffleServerConf.java | 7 --
.../apache/uniffle/server/ShuffleTaskManager.java | 11 +---
.../server/netty/ShuffleServerNettyHandler.java | 76 ++++++++++++----------
.../server/storage/HybridStorageManager.java | 15 +----
.../uniffle/server/ShuffleTaskManagerTest.java | 12 ++++
.../TopNShuffleDataSizeOfAppCalcTaskTest.java | 6 --
43 files changed, 383 insertions(+), 228 deletions(-)
create mode 100644 deploy/kubernetes/operator/pkg/webhook/util/util_test.go
