diff options
| author | qidaijie <[email protected]> | 2022-08-15 11:52:02 +0800 |
|---|---|---|
| committer | qidaijie <[email protected]> | 2022-08-15 11:52:02 +0800 |
| commit | 198a74fdf539c03b856aca3f69f220df575d90a8 (patch) | |
| tree | 88c02a16c0398eea26eea9bb9e5f09332cb41ae3 | |
| parent | 0a13d028f4148fcdc9c377a972000501ae4d0704 (diff) | |
修改Flink依赖配置
| -rw-r--r-- | pom.xml | 6 | ||||
| -rw-r--r-- | src/main/java/com/zdjizhi/utils/functions/MapCompletedFunction.java | 2 |
2 files changed, 4 insertions, 4 deletions
@@ -40,8 +40,8 @@ <hbase.version>2.2.3</hbase.version> <hutool.version>5.7.17</hutool.version> <jsonpath.version>2.4.0</jsonpath.version> - <!--<scope.type>provided</scope.type>--> - <scope.type>compile</scope.type> + <scope.type>provided</scope.type> + <!--<scope.type>compile</scope.type>--> </properties> <build> @@ -161,7 +161,7 @@ <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.12</artifactId> <version>${flink.version}</version> - <scope>${scope.type}</scope> + <!--<scope>${scope.type}</scope>--> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-java --> diff --git a/src/main/java/com/zdjizhi/utils/functions/MapCompletedFunction.java b/src/main/java/com/zdjizhi/utils/functions/MapCompletedFunction.java index 7131c08..735f868 100644 --- a/src/main/java/com/zdjizhi/utils/functions/MapCompletedFunction.java +++ b/src/main/java/com/zdjizhi/utils/functions/MapCompletedFunction.java @@ -66,7 +66,7 @@ public class MapCompletedFunction implements MapFunction<String, String> { if (jsonMap.containsKey("radius_acct_multi_session_id")) { knowledge.set("acct_session_id", jsonMap.getStr("radius_acct_multi_session_id")); } else { - knowledge.set("acct_session_id", jsonMap.get("radius_acct_session_id")); + knowledge.set("acct_session_id", jsonMap.getStr("radius_acct_session_id")); } //用户的在线时长，以秒为单位,下线用户无此属性，默认为0 |