1.优化代码增加日志入库方式选择HEADmaster

1 files changed, 2 insertions, 2 deletions

diff --git a/src/main/java/com/zdjizhi/utils/arangodb/AGSink.java b/src/main/java/com/zdjizhi/utils/arangodb/AGSink.java
index db4b207..d4d05a5 100644
--- a/src/main/java/com/zdjizhi/utils/arangodb/AGSink.java
+++ b/src/main/java/com/zdjizhi/utils/arangodb/AGSink.java
@@ -24,7 +24,7 @@ public class AGSink extends RichSinkFunction<BaseEdgeDocument> {
     private static final Log logger = LogFactory.get();
 
     // ClickHouse 的集群 IP 和 数据进行绑定存储，记录数据写出的 ClickHouse IP
-    private final List<BaseEdgeDocument> ipWithDataList;
+    private final CopyOnWriteArrayList<BaseEdgeDocument> ipWithDataList;
     // 满足此时间条件写出数据
     private final long insertArangoTimeInterval = SINK_ARANGODB_BATCH_DELAY_TIME;
     // 插入的批次
@@ -82,7 +82,7 @@ public class AGSink extends RichSinkFunction<BaseEdgeDocument> {
         if (ipWithDataList.size() >= this.insertArangoBatchSize) {
             try {
                 flush(ipWithDataList);
-            } catch (SQLException e) {
+            } catch (Exception e) {
                 logger.error("ck sink invoke flush failed.", e);
             }
         }