This is an automated email from the ASF dual-hosted git repository.
mridulm80 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git
from 0a68ae049 [CELEBORN-1520] Minor logging fix for AppDiskUsageMetric and
Fixed UTs
add c0ca9523f [CELEBORN-1190][FOLLOWUP] Fix WARNING of error prone
No new revisions were added by this update.
Summary of changes:
.../flink/RemoteShuffleInputGateDelegation.java | 2 +-
.../celeborn/plugin/flink/ShuffleTaskInfo.java | 2 +-
.../plugin/flink/buffer/TransferBufferPool.java | 16 ++---
.../flink/readclient/CelebornBufferStream.java | 2 +-
.../celeborn/plugin/flink/utils/FlinkUtils.java | 25 +++----
.../celeborn/plugin/flink/BufferPackSuiteJ.java | 5 +-
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 2 +-
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 2 +-
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 2 +-
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 2 +-
.../flink/RemoteShuffleResultPartitionSuiteJ.java | 2 +-
.../shuffle/celeborn/SparkShuffleManager.java | 2 +-
.../shuffle/celeborn/CelebornShuffleDataIO.java | 1 +
.../shuffle/celeborn/SparkShuffleManager.java | 2 +-
.../apache/celeborn/client/ShuffleClientImpl.java | 6 ++
.../celeborn/client/read/LocalPartitionReader.java | 1 +
.../celeborn/client/ShuffleClientSuiteJ.java | 78 ++++++++--------------
.../org/apache/celeborn/common/meta/FileInfo.java | 2 +-
.../network/client/TransportClientBootstrap.java | 1 -
.../network/client/TransportResponseHandler.java | 1 +
.../celeborn/common/network/protocol/Message.java | 1 +
.../sasl/anonymous/AnonymousSaslClientFactory.java | 5 +-
.../sasl/anonymous/AnonymousSaslServerFactory.java | 2 +-
.../network/ssl/ReloadingX509TrustManager.java | 1 +
.../common/network/RpcIntegrationSuiteJ.java | 54 ---------------
.../network/SSLTransportClientFactorySuiteJ.java | 2 +
.../protocol/EncryptedMessageWithHeaderSuiteJ.java | 2 +-
.../ssl/ReloadingX509TrustManagerSuiteJ.java | 23 +------
.../common/network/ssl/SslSampleConfigs.java | 2 +-
.../clustermeta/SingleMasterMetaManager.java | 1 +
.../deploy/master/clustermeta/ha/HARaftServer.java | 2 +-
pom.xml | 42 +++++++-----
.../common/service/config/DbConfigServiceImpl.java | 6 ++
.../server/common/service/model/ClusterInfo.java | 14 ++--
.../common/service/model/ClusterSystemConfig.java | 14 ++--
.../common/service/model/ClusterTenantConfig.java | 14 ++--
.../service/store/db/DbServiceManagerImpl.java | 7 +-
.../common/service/config/ConfigServiceSuiteJ.java | 21 +++++-
.../deploy/worker/WorkerSecretRegistryImpl.java | 6 +-
.../deploy/worker/memory/MemoryManager.java | 4 +-
.../deploy/worker/storage/ChunkStreamManager.java | 8 ++-
.../deploy/worker/storage/CreditStreamManager.java | 2 +-
.../worker/storage/MapPartitionDataReader.java | 2 +-
.../worker/storage/MapPartitionDataWriter.java | 4 +-
.../worker/storage/PartitionFilesSorter.java | 2 +-
.../SSLRequestTimeoutIntegrationSuiteJ.java | 2 +
.../SSLReducePartitionDataWriterSuiteJ.java | 1 +
47 files changed, 175 insertions(+), 225 deletions(-)
