[incubator-celeborn] branch main updated: [CELEBORN-307] fix ArrayComparisonFailure while running lz4 ut (#1241)

[et...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ethanfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 2c508dae [CELEBORN-307] fix ArrayComparisonFailure while running lz4 ut (#1241)
2c508dae is described below

commit 2c508dae0fe22ba7ef1a651662193d17e1a19252
Author: zhongqiangchen <zh...@alibaba-inc.com>
AuthorDate: Thu Feb 16 13:41:17 2023 +0800

    [CELEBORN-307] fix ArrayComparisonFailure while running lz4 ut (#1241)
---
 .../org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala b/worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala
index 50816a2e..fda225e1 100644
--- a/worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala
+++ b/worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala
@@ -59,6 +59,7 @@ trait ReadWriteTestBase extends AnyFunSuite
       .set("celeborn.shuffle.compression.codec", codec.name)
       .set("celeborn.push.replicate.enabled", "true")
       .set("celeborn.push.buffer.size", "256K")
+      .set("celeborn.data.io.numConnectionsPerPeer", "1")
     val lifecycleManager = new LifecycleManager(APP, clientConf)
     val shuffleClient = new ShuffleClientImpl(clientConf, UserIdentifier("mock", "mock"))
     shuffleClient.setupMetaServiceRef(lifecycleManager.self)