From 40e76754d040ff4d1e2aa2532725c791e19a98f3 Mon Sep 17 00:00:00 2001
From: wanglihui <949764788@qq.com>
Date: Tue, 25 Aug 2020 14:52:45 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=87=E6=BB=A4schema=E4=B8=BABASE=E7=9A=84?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala
index 952c30c..48bbd9a 100644
--- a/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala
+++ b/ip-learning-spark/src/main/scala/cn/ac/iie/dao/BaseClickhouseData.scala
@@ -31,7 +31,7 @@ object BaseClickhouseData {
   }
 
   def loadConnectionDataFromCk(): Unit ={
-    val where = "common_recv_time >= " + timeLimit._2 + " AND common_recv_time < " + timeLimit._1
+    val where = "common_recv_time >= " + timeLimit._2 + " AND common_recv_time < " + timeLimit._1 + " AND common_schema_type != 'BASE'"
     val sql =
       s"""
         |(SELECT