栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink基础系列6-flink run参数

Flink基础系列6-flink run参数

执行 flink run 后参数:

参数说明
Action "run" compiles and runs a program.
Syntax: run [OPTIONS]  

"run" action options:
 -c,--class                          Class with the program entry
                                                point ("main" method or
                                                "getPlan()" method. only
                                                needed if the JAR file does
                                                not specify the class in its
                                                manifest.
 -C,--classpath                            Adds a URL to each user code
                                                classloader  on all nodes in
                                                the cluster. The paths must
                                                specify a protocol (e.g.
                                                file://) and be accessible
                                                on all nodes (e.g. by means
                                                of a NFS share). You can use
                                                this option multiple times
                                                for specifying more than one
                                                URL. The protocol must be
                                                supported by the {@link
                                                java.net.URLClassLoader}.
 -d,--detached                                  If present, runs the job in
                                                detached mode
 -m,--jobmanager                     Address of the JobManager
                                                (master) to which to
                                                connect. Use this flag to
                                                connect to a different
                                                JobManager than the one
                                                specified in the
                                                configuration.
 -p,--parallelism                  The parallelism with which
                                                to run the program. Optional
                                                flag to override the default
                                                value specified in the
                                                configuration.
 -q,--sysoutLogging                             If present, suppress logging
                                                output to standard out.
 -s,--fromSavepoint              Path to a savepoint to reset
                                                the job back to (for example
                                                file:///flink/savepoint-1537
                                                ).
 -z,--zookeeperNamespace    Namespace to create the
                                                Zookeeper sub-paths for high
                                                availability mode
Options for yarn-cluster mode:
 -yD                             Dynamic properties
 -yd,--yarndetached                   Start detached
 -yid,--yarnapplicationId        Attach to running YARN session
 -yj,--yarnjar                   Path to Flink jar file
 -yjm,--yarnjobManagerMemory     Memory for JobManager Container [in
                                      MB]
 -yn,--yarncontainer             Number of YARN container to allocate
                                      (=Number of Task Managers)
 -ynm,--yarnname                 Set a custom name for the application
                                      on YARN
 -yq,--yarnquery                      Display available YARN resources
                                      (memory, cores)
 -yqu,--yarnqueue                Specify YARN queue.
 -ys,--yarnslots                 Number of slots per TaskManager
 -yst,--yarnstreaming                 Start Flink in streaming mode
 -yt,--yarnship                  Ship files in the specified directory
                                      (t for transfer)
 -ytm,--yarntaskManagerMemory    Memory per TaskManager Container [in
                                      MB]
 -yz,--yarnzookeeperNamespace    Namespace to create the Zookeeper
                                      sub-paths for high availability mode

-n 10 一共启动10个TaskManager节点

-jm 1024 JobManager的内存大小为1024M
 
-tm 2048 TaskManager的内存大小为2048M
-d 使用detached模式进行部署(部署完成后本地命令行可以退出)
-qu default 部署到YARN的default队列中

参考:
  1. https://blog.csdn.net/jerome520zl/article/details/103637811
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/327164.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号