update codes

bin/start.sh

@@ -31,7 +31,7 @@ $JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
 --retryInteral 3000 \
 --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/flink-monitor/checkpoint' \
 --parallelism 12 \
---startTime '2020-03-29 14:33:00' \
+--startTime '2020-03-29 15:00:00' \
 >> /data/log/flink-monitor/flink-monitor.out 2>&1 &
 
 tail -10f /data/log/flink-monitor/flink-monitor.out

src/main/java/com/gmei/data/monitor/cache/SimpleCacheService.java

@@ -63,7 +63,7 @@ public class SimpleCacheService<K, V> extends CacheService<K, V> {
         cache = CacheBuilder
                 .newBuilder()
                 .maximumSize(maximumSize)
-                .expireAfterWrite(expireAfterWrite, TimeUnit.HOURS)
+                .expireAfterWrite(expireAfterWrite, TimeUnit.MILLISECONDS)
                 .build();
     }
 }

src/main/java/com/gmei/data/monitor/operator/RichAsyncFunctionOperator.java

@@ -15,7 +15,7 @@ import java.util.concurrent.Future;
 import static java.util.concurrent.Executors.newFixedThreadPool;
 
 public class RichAsyncFunctionOperator extends RichAsyncFunction<JSONObject, JSONObject> {
-    public static final SimpleCacheService<Integer, String> deviceCache = new SimpleCacheService<Integer, String>(2000, 24);
+    public static final SimpleCacheService<Integer, String> deviceCache = new SimpleCacheService<Integer, String>(2000, 10);
 
     public String inJdbcUrl;