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 @@ ${flink.verison} - - - org.slf4j slf4j-log4j12 @@ -127,15 +124,24 @@ ${flink.verison} + + + + + + + + org.apache.bahir - flink-connector-redis_2.11 - 1.0 + flink-connector-redis_2.12 + 1.1.0 + 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 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() { @Override