[ISSUE-180][FEATURE] Disable rss.worker.closeIdleConnections by defau…

…lt (#181)
apache · Jun 28, 2022 · 5f8521e · 5f8521e
1 parent 40c89d2
commit 5f8521e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/CONFIGURATION_GUIDE.md b/CONFIGURATION_GUIDE.md
@@ -174,7 +174,7 @@ So we should set `rss.worker.flush.queue.capacity=6553` and each RSS worker has
 | `rss.worker.prometheus.metric.port` | 9096 | int | |
 | `rss.merge.push.data.threshold` | 1 MiB | String | |
 | `rss.driver.metaService.port` | 0 | int | |
-| `rss.worker.closeIdleConnections` | true | bool | |
+| `rss.worker.closeIdleConnections` | false | bool | |
 | `rss.ha.enabled` | false | bool | |
 | `rss.ha.master.hosts` | `rss.master.host` 的值 | String | |
 | `rss.ha.service.id` | | String | |

diff --git a/common/src/main/scala/com/aliyun/emr/rss/common/RssConf.scala b/common/src/main/scala/com/aliyun/emr/rss/common/RssConf.scala
@@ -654,7 +654,7 @@ object RssConf extends Logging {
   }
 
   def closeIdleConnections(conf: RssConf): Boolean = {
-    conf.getBoolean("rss.worker.closeIdleConnections", defaultValue = true)
+    conf.getBoolean("rss.worker.closeIdleConnections", defaultValue = false)
   }
 
   def replicateFastFailDurationMs(conf: RssConf): Long = {