Remove limit for sockets per connection to fix "Premature close" erro…

…r + prepare patch release (#217) * Remove limit for sockets per connection to fix "Premature close" error Signed-off-by: Levko Kravets <levko.ne@gmail.com> * Prepare release 1.7.1 (patch) Signed-off-by: Levko Kravets <levko.ne@gmail.com> --------- Signed-off-by: Levko Kravets <levko.ne@gmail.com>
databricks · Jan 16, 2024 · c85629b · c85629b
1 parent a86f828
commit c85629b
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,10 @@
 # Release History
 
+## 1.7.1
+
+- Fix "Premature close" error which happened due to socket limit when intensively using library
+  (databricks/databricks-sql-nodejs#217)
+
 ## 1.7.0
 
 - Fixed behavior of `maxRows` option of `IOperation.fetchChunk()`. Now it will return chunks

diff --git a/lib/connection/connections/HttpConnection.ts b/lib/connection/connections/HttpConnection.ts
@@ -49,12 +49,10 @@ export default class HttpConnection implements IConnectionProvider {
   private getAgentDefaultOptions(): http.AgentOptions {
     const clientConfig = this.context.getConfig();
 
-    const cloudFetchExtraSocketsCount = clientConfig.useCloudFetch ? clientConfig.cloudFetchConcurrentDownloads : 0;
-
     return {
       keepAlive: true,
-      maxSockets: 5 + cloudFetchExtraSocketsCount,
       keepAliveMsecs: 10000,
+      maxSockets: Infinity, // no limit
       timeout: this.options.socketTimeout ?? clientConfig.socketTimeout,
     };
   }

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@databricks/sql",
-  "version": "1.7.0",
+  "version": "1.7.1",
   "description": "Driver for connection to Databricks SQL via Thrift API.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",