Home Explore Help
Register Sign In
root
/
DbSyncer
mirror of https://gitee.com/ghi/dbsyncer.git
1
0
Fork 0
Files Issues 0 Wiki
Browse Source

fix

Signed-off-by: AE86 <836391306@qq.com>
AE86 1 year ago
parent
d220db7209
commit
287df4630e
1 changed files with 1 additions and 1 deletions
Split View Show Diff Stats
  1. 1 1
      dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/StorageBufferActuator.java

+ 1 - 1
dbsyncer-parser/src/main/java/org/dbsyncer/parser/flush/impl/StorageBufferActuator.java
View File 

@@ -50,7 +50,7 @@ public final class StorageBufferActuator extends AbstractBufferActuator<StorageR
 
 
     @Override
 
     protected void pull(StorageResponse response) {
 
-        storageExecutor.execute(() -> storageService.addBatch(StorageEnum.DATA, response.getMetaId(), response.getDataList()));
 
+        storageService.addBatch(StorageEnum.DATA, response.getMetaId(), response.getDataList());
 
     }
 
 
     @Override