Flink1.6 Confirm that flink supports the plan function?

[wangziyu]

Dear Friend:
              Now ,I am a learn flink for 20 days.I would to trouble friends
to help solve two problems.
Questions are as follows：
              1. If I have some jobs,How can I merge the some jobs to One
that convenient for me to manage?
I have look for some restful api in
"https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html"。I
see "/jars/:jarid/plan" it seem say "Returns the dataflow plan of a job
contained in a jar previously uploaded via '/jars/upload'."I think it is not
my purpose.
              2.When I run a job,I need pass in several  parameters.For
example "./flink run -d -c streaming.Kafka010NumCountConsumer
/ziyu/flink/kafkaFlink-1.0-SNAPSHOT.jar h1 /ziyu/h1.txt" .Now If I have know
JobId,Can I get the job pass in several  parameters by java.I think it is
has some interface can use,But I can't get it.
             That is all.Can you help me that give me some
information.Thanks so mach.






--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Till Rohrmann]

Hi,

1) you currently cannot merge multiple jobs into one after they have been submitted. What you can do though, is to combine multiple jobs in your Flink program before you submit it.

2) you can pass program arguments when you submit your job. After it has been submitted, it is no longer possible to change the command line arguments.

Cheers,

Till

On Mon, Oct 15, 2018 at 9:11 AM wangziyu <[hidden email]> wrote:

Dear Friend:
              Now ,I am a learn flink for 20 days.I would to trouble friends
to help solve two problems.
Questions are as follows：
              1. If I have some jobs,How can I merge the some jobs to One
that convenient for me to manage?
I have look for some restful api in
"https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html"。I
see "/jars/:jarid/plan" it seem say "Returns the dataflow plan of a job
contained in a jar previously uploaded via '/jars/upload'."I think it is not
my purpose.
              2.When I run a job,I need pass in several  parameters.For
example "./flink run -d -c streaming.Kafka010NumCountConsumer
/ziyu/flink/kafkaFlink-1.0-SNAPSHOT.jar h1 /ziyu/h1.txt" .Now If I have know
JobId,Can I get the job pass in several  parameters by java.I think it is
has some interface can use,But I can't get it.
             That is all.Can you help me that give me some
information.Thanks so mach.






--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Amit Jain]

Hi,

2) You may also want to look into ParameterTool[1] class to parse and read passed properties file [2].

--

Thanks,

Amit

[1] https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/api/java/utils/ParameterTool.html

[2] https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/best_practices.html#getting-your-configuration-values-into-the-parametertool

On Mon, Oct 15, 2018 at 1:28 PM Till Rohrmann <[hidden email]> wrote:

Hi,

1) you currently cannot merge multiple jobs into one after they have been submitted. What you can do though, is to combine multiple jobs in your Flink program before you submit it.

2) you can pass program arguments when you submit your job. After it has been submitted, it is no longer possible to change the command line arguments.

Cheers,

Till

On Mon, Oct 15, 2018 at 9:11 AM wangziyu <[hidden email]> wrote:

Dear Friend:
              Now ,I am a learn flink for 20 days.I would to trouble friends
to help solve two problems.
Questions are as follows：
              1. If I have some jobs,How can I merge the some jobs to One
that convenient for me to manage?
I have look for some restful api in
"https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/rest_api.html"。I
see "/jars/:jarid/plan" it seem say "Returns the dataflow plan of a job
contained in a jar previously uploaded via '/jars/upload'."I think it is not
my purpose.
              2.When I run a job,I need pass in several  parameters.For
example "./flink run -d -c streaming.Kafka010NumCountConsumer
/ziyu/flink/kafkaFlink-1.0-SNAPSHOT.jar h1 /ziyu/h1.txt" .Now If I have know
JobId,Can I get the job pass in several  parameters by java.I think it is
has some interface can use,But I can't get it.
             That is all.Can you help me that give me some
information.Thanks so mach.






--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[wangziyu]

Hi，
    Thanks for you reply!I will read this [1] and [2] carefully！If I also
have question ,Hope to hear from you again.



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[wangziyu]

Hi,
    1.I think I have some questions.When I have not submitted my jobs,I need
to read a job to contol jobs.It is mean that If I want to cancel a job which
is running , I can contol it. Maybe my jobs it is not running,I also can
contol them.
    2.When I run a job in terminal and pass program arguments . I don't want
wo change my program arguments. I want to get my arguments by java. If I
have some jobs . I want to get all of jobs arguments.
    Thanks for you letter ,I an looking forward to you next latter!



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[wangziyu]

Hi,
    Thanks for you letter.Now my program to get parameters  is ok. But ,I
also don't know how to merge some jobs to a job .Just go through a job to
control my jobs.Do you know to merge N jobs to One job ?
Looking forward to your next letter



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/