Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

以yarn模式启动数据同步任务,能否支持指定Yarn的队列提交任务 #91

Closed
LoveXiaoQuan opened this issue Oct 13, 2019 · 2 comments

Comments

@LoveXiaoQuan
Copy link

你好:
感谢开源flinkx,使用过程遇到一些问题,望得到回复,谢谢
举例:
flink run -m yarn-cluster -yqu root.queue -c org.apache.flink.examples.java.wordcount.WordCount /app/flink-1.7.2/examples/batch/WordCount.jar
这个是命令行参数以单任务yarn模式提交任务,其中 -yqu root.queue 显示指定yarn的资源队列,flinkx能否做到这样的支持

看了ClusterClientFactory这个类的createYarnClient这个方法,发现YarnConfiguration类中的队列名称(DEFAULT_QUEUE_NAME)默认为default,好像没有参数可以修改队列的名称,这个能否支持指定yarn的某个队列来运行flinkx的任务,以做到资源隔离

@yangsishu
Copy link
Contributor

可以的

@kanata163
Copy link
Contributor

LauncherOptionParser中的queue参数就是用于指定yarn队列

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants