diff options
| author | tanghao <[email protected]> | 2024-08-20 09:42:05 +0800 |
|---|---|---|
| committer | tanghao <[email protected]> | 2024-08-20 09:42:05 +0800 |
| commit | a7cc139afc07fc3eb192703e5c4c1403e5f6a0ef (patch) | |
| tree | 7d2bb360896ecc998c83cf35e0d815a2132da2ba | |
| parent | 82dbe2bbbe77bed62cccf1b7e7659574276741a1 (diff) | |
fix: 替换原有clickhouse依赖
| -rw-r--r-- | cn-admin/pom.xml | 12 | ||||
| -rw-r--r-- | cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java | 4 |
2 files changed, 6 insertions, 10 deletions
diff --git a/cn-admin/pom.xml b/cn-admin/pom.xml index da93f7d..e0d6695 100644 --- a/cn-admin/pom.xml +++ b/cn-admin/pom.xml @@ -352,14 +352,10 @@ <dependency> <groupId>com.clickhouse</groupId> - <!-- or clickhouse-grpc-client if you prefer gRPC --> - <artifactId>clickhouse-http-client</artifactId> - <version>0.6.4</version> - </dependency> - <dependency> - <groupId>org.apache.httpcomponents.client5</groupId> - <artifactId>httpclient5</artifactId> - <version>5.2.3</version> + <artifactId>clickhouse-jdbc</artifactId> + <version>0.6.0</version> + <!-- use uber jar with all dependencies included, change classifier to http for smaller jar --> + <classifier>all</classifier> </dependency> </dependencies> diff --git a/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java b/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java index 41b1b5b..ad72054 100644 --- a/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java +++ b/cn-admin/src/main/java/net/geedge/common/config/DetectionRunner.java @@ -57,7 +57,7 @@ public class DetectionRunner implements CommandLineRunner{ @Override public void run(String... args) throws Exception { - /*Map<String, Event> cache = Context.DETECTTION_EVENT_CACHE; + Map<String, Event> cache = Context.DETECTTION_EVENT_CACHE; // 查询ck获取正在进行的event事件数据 更新到缓存中 queryEventDataToCache(cache); log.info("[DetectionRunner] [Get Event Data Cache] [Count : {}]",cache.size()); @@ -182,7 +182,7 @@ public class DetectionRunner implements CommandLineRunner{ } }finally { kafkaConsumer.close(); - }*/ + } } |