addflink

heibaiying · Nov 5, 2019 · ad59022 · ad59022
1 parent 0d5a81b
commit ad59022
Show file tree

Hide file tree

Showing 22 changed files with 262 additions and 416 deletions.
diff --git a/code/Flink/flink-kafka-integration/src/main/java/com/heibaiying/KafkaStreamingJob.java b/code/Flink/flink-kafka-integration/src/main/java/com/heibaiying/KafkaStreamingJob.java
@@ -20,7 +20,7 @@ public static void main(String[] args) throws Exception {
 
         // 1.指定Kafka的相关配置属性
         Properties properties = new Properties();
-        properties.setProperty("bootstrap.servers", "192.168.200.0:9092");
+        properties.setProperty("bootstrap.servers", "192.168.0.229:9092");
 
         // 2.接收Kafka上的数据
         DataStream<String> stream = env

diff --git a/code/Flink/flink-time-watermark/pom.xml b/code/Flink/flink-time-watermark/pom.xml
diff --git a/code/Flink/flink-time-watermark/src/main/java/com/heibaiying/PeriodicWatermarksJob.java b/code/Flink/flink-time-watermark/src/main/java/com/heibaiying/PeriodicWatermarksJob.java
diff --git a/code/Flink/flink-time-watermark/src/main/java/com/heibaiying/PunctuatedWatermarksJob.java b/code/Flink/flink-time-watermark/src/main/java/com/heibaiying/PunctuatedWatermarksJob.java
diff --git a/code/Flink/flink-time-watermark/src/main/resources/log4j.properties b/code/Flink/flink-time-watermark/src/main/resources/log4j.properties
diff --git a/code/Flink/flink-time-watermark/src/main/resources/sample.txt b/code/Flink/flink-time-watermark/src/main/resources/sample.txt