clickhouse-cargo - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

lib/bulk.js

@@ -105,2 +105,9 @@ // Generated by CoffeeScript 2.5.1
       assert(statement, "missing insert statment");
+      // FIXME: quick fix for cluster mode conflicats
+      if (!fs.existsSync(this.pathToFile)) {
+        debuglog(`${this} [commit] FIXME cache file already removed.`, this.pathToFile);
+        this._committed = true;
+        this.outputStream.destroy();
+        return;
+      }
       this._committing = true; //lock
@@ -107,0 +114,0 @@ debuglog(`${this} [commit] go committing, count:${this.count}, pathToFile:${this.pathToFile}`);

package.json

 {
   "name": "clickhouse-cargo",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "description": "Accumulates insert queries and commit them to clickhouse in batch jobs with retries on failure. 这个模块将向 Clickhouse 数据库的高频写入改为低频的批量插入。",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

No alert changes

Improved metrics

Total package byte prevSize

68353

increased by0.76%

Lines of code

877

increased by0.8%

No dependency changes