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 15:00:00' \
+--startTime '2020-03-29 15:08: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.MILLISECONDS)
+                .expireAfterWrite(expireAfterWrite, TimeUnit.SECONDS)
                 .build();
     }
 }