Skip to content

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

update codes

parent 583a026e
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
bin/start.sh
View file @ f18f645a
...@@ -7,13 +7,13 @@ export JAVA_OPTS="-Xms1024m -Xmx8192m -XX:-UseGCOverheadLimit -XX:+UseConcMarkSw ...@@ -7,13 +7,13 @@ export JAVA_OPTS="-Xms1024m -Xmx8192m -XX:-UseGCOverheadLimit -XX:+UseConcMarkSw
$FLINK_HOME/bin/flink run \ $FLINK_HOME/bin/flink run \
-m yarn-cluster \ -m yarn-cluster \
-yn 3 \
-ynm portrait_monitor \ -ynm portrait_monitor \
-yqu flink \ -yqu flink \
-p 6 \ -yn 2 \
-ys 2 \
-p 4 \
-yjm 1024 \ -yjm 1024 \
-ytm 2048 \ -ytm 2048 \
-ys 2 \
$JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \ $JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
--inBrokers '172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092' \ --inBrokers '172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092' \
--batchSize 1000 \ --batchSize 1000 \
......
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