[incubator-celeborn] branch branch-0.3 updated: [CELEBORN-806] Correct the conf key `celeborn.data.io.threads` within the class `ShuffleClientImpl`

[zhouky]

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

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


The following commit(s) were added to refs/heads/branch-0.3 by this push:
     new 39399c3ae [CELEBORN-806] Correct the conf key 
`celeborn.data.io.threads` within the class `ShuffleClientImpl`
39399c3ae is described below

commit 39399c3ae048d0ffde160d1ea99944087271d784
Author: Fu Chen <cfmcgr...@gmail.com>
AuthorDate: Tue Jul 18 17:54:49 2023 +0800

    [CELEBORN-806] Correct the conf key `celeborn.data.io.threads` within the 
class `ShuffleClientImpl`
    
    ### What changes were proposed in this pull request?
    
    As title
    
    ### Why are the changes needed?
    
    The configuration key `celeborn.data.io.threads` underwent an inadvertent 
modification in https://github.com/apache/incubator-celeborn/pull/1077
    
    ### Does this PR introduce _any_ user-facing change?
    
    Bug fix
    
    ### How was this patch tested?
    
    Pass GA
    
    Closes #1729 from cfmcgrady/fix-conf-key.
    
    Authored-by: Fu Chen <cfmcgr...@gmail.com>
    Signed-off-by: zky.zhoukeyong <zky.zhoukey...@alibaba-inc.com>
    (cherry picked from commit 8b7a761859fc0a3a9f688aac681c3876aca38030)
    Signed-off-by: zky.zhoukeyong <zky.zhoukey...@alibaba-inc.com>
---
 client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java 
b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
index 9e9620cac..db4eb4f94 100644
--- a/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
+++ b/client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java
@@ -177,7 +177,7 @@ public class ShuffleClientImpl extends ShuffleClient {
 
     String module = TransportModuleConstants.DATA_MODULE;
     TransportConf dataTransportConf =
-        Utils.fromCelebornConf(conf, module, conf.getInt("celeborn" + module + 
".io.threads", 8));
+        Utils.fromCelebornConf(conf, module, conf.getInt("celeborn." + module 
+ ".io.threads", 8));
     TransportContext context =
         new TransportContext(
             dataTransportConf, new BaseMessageHandler(), 
conf.clientCloseIdleConnections());