modify quene sise

2025-12-13 08:11:15 +00:00 · 2024-12-01 23:15:01 +08:00 · 2024-12-01 23:15:01 +08:00 · f03c94ab0d
commit f03c94ab0d
parent f3ad69c616
1 changed files with 1 additions and 1 deletions
--- a/builder/runner/local/src/main/java/com/antgroup/openspg/builder/runner/local/physical/sink/impl/Neo4jSinkWriter.java
+++ b/builder/runner/local/src/main/java/com/antgroup/openspg/builder/runner/local/physical/sink/impl/Neo4jSinkWriter.java
@ -69,7 +69,7 @@ public class Neo4jSinkWriter extends BaseSinkWriter<Neo4jSinkNodeConfig> {
          NUM_THREADS,
            2 * 60L,
          TimeUnit.SECONDS,
-            new LinkedBlockingQueue<>(5000),
+            new LinkedBlockingQueue<>(100),
  handler);

  public Neo4jSinkWriter(String id, String name, Neo4jSinkNodeConfig config) {