Skip to content

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

update codes

parent 5b2fd98b
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
bin/start_shd.sh
View file @ 2eb3b0c5
......@@ -14,7 +14,7 @@ nohup $FLINK_HOME/bin/flink run \
-p 4 \
-yjm 1024 \
-ytm 2048 \
-c 'com.gmei.data.monitor.PortraitMonitorMainShd'
-c com.gmei.data.monitor.PortraitMonitorMainShd
$JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
--inBrokers '172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092' \
--batchSize 1000 \
......@@ -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-25 17:50:00' \
--startTime '2020-03-25 17:57:00' \
>> /data/log/flink-monitor/flink-monitor.out 2>&1 &
tail -10f /data/log/flink-monitor/flink-monitor.out
......
bin/start_suc.sh
View file @ 2eb3b0c5
......@@ -14,7 +14,7 @@ nohup $FLINK_HOME/bin/flink run \
-p 4 \
-yjm 1024 \
-ytm 2048 \
-c 'com.gmei.data.monitor.PortraitMonitorMainSuc'
-c com.gmei.data.monitor.PortraitMonitorMainSuc
$JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
--inBrokers '172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092' \
--batchSize 1000 \
......@@ -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-25 17:50:00' \
--startTime '2020-03-25 17:57:00' \
>> /data/log/flink-monitor/flink-monitor.out 2>&1 &
tail -10f /data/log/flink-monitor/flink-monitor.out
......
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