Skip to content

F
flink-monitor
Commit f5fcaa44 authored by 赵建伟's avatar 赵建伟
Browse files
Options

update codes

parent 461fd43c
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
bin/start.sh
View file @ f5fcaa44
...@@ -31,7 +31,7 @@ $JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \ ...@@ -31,7 +31,7 @@ $JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
--retryInteral 3000 \ --retryInteral 3000 \
--checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/flink-monitor/checkpoint' \ --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/flink-monitor/checkpoint' \
--parallelism 12 \ --parallelism 12 \
--startTime '2020-03-26 15:05:00' \ --startTime '2020-03-26 15:10:00' \
>> /data/log/flink-monitor/flink-monitor.out 2>&1 & >> /data/log/flink-monitor/flink-monitor.out 2>&1 &
tail -10f /data/log/flink-monitor/flink-monitor.out tail -10f /data/log/flink-monitor/flink-monitor.out
......
src/main/java/com/gmei/data/monitor/operator/PortraitMonitorShdOperator.java
View file @ f5fcaa44
...@@ -44,7 +44,7 @@ public class PortraitMonitorShdOperator implements BaseOperator{ ...@@ -44,7 +44,7 @@ public class PortraitMonitorShdOperator implements BaseOperator{
private int maxRetry; private int maxRetry;
private long retryInteral; private long retryInteral;
private int parallelism; private int parallelism;
private static SimpleCacheService<Integer, DeviceInfo> deviceCallableSimpleCacheService private SimpleCacheService<Integer, DeviceInfo> deviceCallableSimpleCacheService
= deviceCallableSimpleCacheService = new SimpleCacheService<>(2000, 24); = deviceCallableSimpleCacheService = new SimpleCacheService<>(2000, 24);
public static final DateTimeFormatter dateTimeFormat = ISODateTimeFormat.dateTime(); public static final DateTimeFormatter dateTimeFormat = ISODateTimeFormat.dateTime();
public static final DateTimeFormatter dateTimeNoMillisFormat = ISODateTimeFormat.dateTimeNoMillis(); public static final DateTimeFormatter dateTimeNoMillisFormat = ISODateTimeFormat.dateTimeNoMillis();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment