修改jar包版本号

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.zdjizhi</groupId>
     <artifactId>radius-account-knowledge</artifactId>
-    <version>211116-jackson</version>
+    <version>220309-jackson</version>
 
     <name>radius-account-knowledge</name>
     <url>http://www.example.com</url>

src/main/java/com/zdjizhi/topology/RadiusKnowledgeTopology.java

@@ -22,8 +22,6 @@ public class RadiusKnowledgeTopology {
     public static void main(String[] args) {
         final StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
 
-//        environment.enableCheckpointing(5000);
-
         DataStreamSource<String> streamSource = environment.addSource(KafkaConsumer.getKafkaConsumer());
 
         DataStream<String> result = streamSource.map(new MapCompletedFunction()).name("RadiusOnOffMap")