From 49f78a2f4941b5d338da6a1001f9d8940f71aef3 Mon Sep 17 00:00:00 2001
From: qidaijie <qidaijie@mesalab.cn>
Date: Fri, 5 Nov 2021 10:07:12 +0300
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0jsonPath=E8=A7=A3=E6=9E=90?=
 =?UTF-8?q?=E5=88=A4=E6=96=AD=EF=BC=88TSG-8341=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                                     | 2 +-
 .../java/com/zdjizhi/utils/functions/MapParseFunction.java  | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/pom.xml b/pom.xml
index f437b34..dd0565f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.zdjizhi</groupId>
     <artifactId>log-olap-analysis-schema</artifactId>
-    <version>210908-security</version>
+    <version>211105-flattenSpec</version>
 
     <name>log-olap-analysis-schema</name>
     <url>http://www.example.com</url>
diff --git a/src/main/java/com/zdjizhi/utils/functions/MapParseFunction.java b/src/main/java/com/zdjizhi/utils/functions/MapParseFunction.java
index 5a5741e..7244b1d 100644
--- a/src/main/java/com/zdjizhi/utils/functions/MapParseFunction.java
+++ b/src/main/java/com/zdjizhi/utils/functions/MapParseFunction.java
@@ -139,8 +139,10 @@ public class MapParseFunction implements MapFunction<String, Tuple3<String, Stri
             if (StringUtil.isNotBlank(expr)) {
                 String operateValue = JsonParseUtil.getString(message, fieldName);
                 ArrayList<String> read = JsonPath.parse(operateValue).read(expr);
-                String flattenResult = read.get(0);
-                dimensions.put(resultKeyName, flattenResult);
+                if (read.size() >= 1) {
+                    String flattenResult = read.get(0);
+                    dimensions.put(resultKeyName, flattenResult);
+                }
             }
         } catch (ClassCastException | InvalidPathException e) {
             logger.error("设备标签解析异常，[ " + expr + " ]解析表达式错误" + e);