From 84ad855669d486f9148ba7f3c26f0d0c3c440336 Mon Sep 17 00:00:00 2001
From: dingjiawen <745518019@qq.com>
Date: Thu, 8 Sep 2022 09:06:31 +0800
Subject: [PATCH] =?UTF-8?q?flink=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Big_data_example/Flink/pom.xml                   | 16 +++++++++++-----
 .../Flink/src/main/java/day08/Example10.java     |  2 +-
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git a/Big_data_example/Flink/pom.xml b/Big_data_example/Flink/pom.xml
index 6cd64ca..704c0f1 100644
--- a/Big_data_example/Flink/pom.xml
+++ b/Big_data_example/Flink/pom.xml
@@ -91,9 +91,6 @@
             <version>${flink.verison}</version>
         </dependency>
 
-
-
-
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-log4j12</artifactId>
@@ -127,15 +124,24 @@
             <version>${flink.verison}</version>
         </dependency>
 
+
+<!--        <dependency>-->
+<!--            <groupId>org.apache.bahir</groupId>-->
+<!--            <artifactId>flink-connector-redis_2.11</artifactId>-->
+<!--            <version>1.0</version>-->
+<!--        </dependency>-->
+
+        <!-- https://mvnrepository.com/artifact/org.apache.bahir/flink-connector-redis -->
         <dependency>
             <groupId>org.apache.bahir</groupId>
-            <artifactId>flink-connector-redis_2.11</artifactId>
-            <version>1.0</version>
+            <artifactId>flink-connector-redis_2.12</artifactId>
+            <version>1.1.0</version>
         </dependency>
 
 
 
 
+
     </dependencies>
 
 
diff --git a/Big_data_example/Flink/src/main/java/day08/Example10.java b/Big_data_example/Flink/src/main/java/day08/Example10.java
index dce1421..27a988b 100644
--- a/Big_data_example/Flink/src/main/java/day08/Example10.java
+++ b/Big_data_example/Flink/src/main/java/day08/Example10.java
@@ -28,7 +28,7 @@ public class Example10 {
         env.setParallelism(1);
 
         SingleOutputStreamOperator<UserBehavior> stream = env
-                .readTextFile("E:\\Big_data_example\\Flink\\src\\main\\resources\\UserBehavior.csv")
+                .readTextFile("D:\\example\\self_example\\Big_data_example\\Flink\\src\\main\\resources\\UserBehavior.csv")
                 .map(
                         new MapFunction<String, UserBehavior>() {
                             @Override