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
[FLINK-20356][docs] Updated Mesos documentation. #14258
Conversation
Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community Automated ChecksLast check on commit 299cc30 (Sun Nov 29 22:36:53 UTC 2020) Warnings:
Mention the bot in a comment to re-run the automated checks. Review Progress
Please see the Pull Request Review Guide for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commandsThe @flinkbot bot supports the following commands:
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I started reviewing, will continue later
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for creating this PR @XComp. I had a couple of comments. Please take a look.
You may install Flink on all of your Mesos Master and Agent nodes. You can also pull the binaries | ||
from the Flink website during deployment and apply your custom configuration before launching the | ||
application master. A more convenient and easier-to-maintain approach is to use Docker containers | ||
to manage the Flink binaries and configuration. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'd say to go with the docker image approach.
1. Another option is to create a `${FLINK_HOME}/usrlib/` directory and to put the user code jar | ||
in that directory. The user code jar will be loaded by the user code classloader after launching | ||
a Per-Job Cluster via `${FLINK_HOME}/bin/mesos-appmaster-job.sh ...`. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Have you tried it out whether it works?
{ | ||
"id": "flink", | ||
"cmd": "$FLINK_HOME/bin/mesos-appmaster.sh -Djobmanager.memory.process.size=1472m -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dtaskmanager.memory.process.size=1024m -Dtaskmanager.numberOfTaskSlots=2 -Dparallelism.default=2 -Dmesos.resourcemanager.tasks.cpus=1", | ||
"cpus": 1.0, | ||
"mem": 1024 | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this yaml is not correct. We allocate mem: 1024
but set -Djobmanager.memory.process.size=1472m
. Maybe we can put the simplest definition possible here (e.g. w/o specifying the resources and the ports, for example) or we completely remove it and refer to the documentation of Marathon.
…new deployment page style.
…o Flink on Mesos Reference. The Marathon section's example is not working, yet. I haven't found a solution for setting the RPC address in a multi-slave environment, yet.
299cc30
to
321e355
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for updating this PR @XComp. I had a couple for additional comments. Please take a look.
{% highlight javascript %} | ||
{ | ||
"id": "flink", | ||
"cmd": "/opt/flink-1.11.2/bin/mesos-appmaster.sh -Dmesos.resourcemanager.framework.user=root -Dmesos.resourcemanager.tasks.taskmanager-cmd=/opt/flink-1.11.2/bin/mesos-taskmanager.sh -Dmesos.master=master:5050 -Djobmanager.memory.process.size=1472m -Dtaskmanager.memory.process.size=3500m -Dtaskmanager.numberOfTaskSlots=2 -Dparallelism.default=2", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we have to specify all the memory configurations or can we use the default values?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Where comes master:5050
from?
…er.sh can be called from.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for updating the documentation @XComp. The changes look good to me. I had a single comment/question. Please take a look.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update @XComp. The changes look good to me. Merging this PR now.
…new deployment page style. [FLINK-20356][docs] Added missing "Mode". [FLINK-20356][docs] Added missing "is". [FLINK-20356][docs] Fixed wrong number. [FLINK-20356][docs] Reorganized Mesos page moving advanced topics into Flink on Mesos Reference. The Marathon section's example is not working, yet. I haven't found a solution for setting the RPC address in a multi-slave environment, yet. [FLINK-20356][docs] Improved wording. [FLINK-20356][docs] Fixing the description on where bin/mesos-appmaster.sh can be called from. [FLINK-20356][docs] Made Flink version dynamic. [FLINK-20356][docs] Fixed highlight block. [FLINK-20356][docs] Shortened long line. [FLINK-20356][docs] Moved Flink on Mesos Architecture section down. [FLINK-20356][docs] Added Hadoop section. [FLINK-20352][docs] Updated Chinese CLI docs to align with the English version. [FLINK-20352][docs] Reorganized Marathon section. [FLINK-20352][docs] Fixed headline. [FLINK-20352][docs] Updated code blocks. [FLINK-20352][docs] Added remark on Marathon's environment variable. [FLINK-20352][docs] Aligned placeholder labels. [FLINK-20352][docs] Added job submission command. [FLINK-20352][docs] Replaced root by <flink-user> to align it with the Getting Started section. [FLINK-20352][docs] Aligned Chinese with English version. This closes #14258.
…new deployment page style. [FLINK-20356][docs] Added missing "Mode". [FLINK-20356][docs] Added missing "is". [FLINK-20356][docs] Fixed wrong number. [FLINK-20356][docs] Reorganized Mesos page moving advanced topics into Flink on Mesos Reference. The Marathon section's example is not working, yet. I haven't found a solution for setting the RPC address in a multi-slave environment, yet. [FLINK-20356][docs] Improved wording. [FLINK-20356][docs] Fixing the description on where bin/mesos-appmaster.sh can be called from. [FLINK-20356][docs] Made Flink version dynamic. [FLINK-20356][docs] Fixed highlight block. [FLINK-20356][docs] Shortened long line. [FLINK-20356][docs] Moved Flink on Mesos Architecture section down. [FLINK-20356][docs] Added Hadoop section. [FLINK-20352][docs] Updated Chinese CLI docs to align with the English version. [FLINK-20352][docs] Reorganized Marathon section. [FLINK-20352][docs] Fixed headline. [FLINK-20352][docs] Updated code blocks. [FLINK-20352][docs] Added remark on Marathon's environment variable. [FLINK-20352][docs] Aligned placeholder labels. [FLINK-20352][docs] Added job submission command. [FLINK-20352][docs] Replaced root by <flink-user> to align it with the Getting Started section. [FLINK-20352][docs] Aligned Chinese with English version. This closes apache#14258.
First version of the Mesos page. See a screenshot of the page below...