代码提交

eagleEye-flink_kafka/src/main/java/com/flink/achieve/base/EventLogAchi.java

@@ -397,7 +397,18 @@ public class EventLogAchi implements Serializable {
 						DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS"))));
 						DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS"))));
 		Properties r8 = eventInfo.getR8();
 		Properties r8 = eventInfo.getR8();
 		row.setField(4, StringData.fromString(r8.getType()));
 		row.setField(4, StringData.fromString(r8.getType()));
-		row.setField(5, StringData.fromString(r8.getId()));
+		
+		String id = null;
+		if(r8 != null) {
+			if(StringUtils.isNotEmpty(r8.getId())) {
+				if(r8.getId().length() > 200) {
+					id = "测试异常数据:"+r8.getId().substring(0, 200);
+				}else {
+					id = r8.getId();
+				}
+			}
+		}
+		row.setField(5, StringData.fromString(id));
 		row.setField(6, StringData.fromString(userProps == null ? null : userProps.getNick()));
 		row.setField(6, StringData.fromString(userProps == null ? null : userProps.getNick()));
 		row.setField(7, StringData.fromString(event.getCreate_time()));
 		row.setField(7, StringData.fromString(event.getCreate_time()));
 		row.setField(8, StringData.fromString(event.getSend_time()));
 		row.setField(8, StringData.fromString(event.getSend_time()));

eagleEye-flink_kafka/src/main/java/com/flink/achieve/table/udf/ParseEventListUDTF.java

@@ -60,6 +60,9 @@ public class ParseEventListUDTF extends TableFunction<Row>{
                 				ip_name = null;
                 				ip_name = null;
                 				area_name = null;
                 				area_name = null;
                 			}
                 			}
+                		}else {
+                			ip_name = ip;
+            				break;
                 		}
                 		}
                     }
                     }
                 }
                 }

eagleEye-flink_kafka/src/main/java/com/flink/common/StreamEnvironmentSettings.java

@@ -112,6 +112,7 @@ public class StreamEnvironmentSettings {
 			    .build();
 			    .build();
 //		TableEnvironment tEnv = TableEnvironment.create(settings);//代码中同时创建了 TableEnvironment和 StreamTableEnvironment，但两者功能重叠，通常只需保留 StreamTableEnvironment。
 //		TableEnvironment tEnv = TableEnvironment.create(settings);//代码中同时创建了 TableEnvironment和 StreamTableEnvironment，但两者功能重叠，通常只需保留 StreamTableEnvironment。
         StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
         StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);
+        tableEnv.getConfig().set("table.display.max-column-width", "100");
         TableConfig tableConfig = tableEnv.getConfig();
         TableConfig tableConfig = tableEnv.getConfig();
         //时区与状态管理
         //时区与状态管理
         tableConfig.setLocalTimeZone(ZoneId.of("UTC"));
         tableConfig.setLocalTimeZone(ZoneId.of("UTC"));