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 <[email protected]>
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)
