…
> >
> > Cheers
> > Malte
> >
> > Von: Robert Metzger mailto:rmetz...@apache.org
> >>
> > Antworten an: mailto:user@flink.apache.org>>
> > Datum: Freitag, 8. Mai 2015 14:57
> > An: "user@flink.apache.org <mailto:user@
jar/multiplejobs.jar
> …
>
> Cheers
> Malte
>
> Von: Robert Metzger mailto:rmetz...@apache.org>>
> Antworten an: mailto:user@flink.apache.org>>
> Datum: Freitag, 8. Mai 2015 14:57
> An: "user@flink.apache.org <mailto:u
t;
> Cheers
> Malte
>
> Von: Robert Metzger
> Antworten an:
> Datum: Freitag, 8. Mai 2015 14:57
> An: "user@flink.apache.org"
> Betreff: Re: Package multiple jobs in a single jar
>
> Hi Flavio,
>
> the pom from our quickstart is a good refere
an:
Datum: Freitag, 8. Mai 2015 14:57
An: "user@flink.apache.org"
Betreff: Re: Package multiple jobs in a single jar
Hi Flavio,
the pom from our quickstart is a good reference:
https://github.com/apache/flink/blob/master/flink-quickstart/flink-quickstar
t-java/src/main/resources
Hi Flavio,
the pom from our quickstart is a good reference:
https://github.com/apache/flink/blob/master/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml
On Fri, May 8, 2015 at 2:53 PM, Flavio Pompermaier
wrote:
> Ok, get it.
> And is there a reference pom
Ok, get it.
And is there a reference pom.xml for shading my application into one
fat-jar? which flink dependencies can I exclude?
On Fri, May 8, 2015 at 1:05 PM, Fabian Hueske wrote:
> I didn't say that the main should return the ExecutionEnvironment.
> You can define and execute as many program
I didn't say that the main should return the ExecutionEnvironment.
You can define and execute as many programs in a main function as you like.
The program can be defined somewhere else, e.g., in a function that
receives an ExecutionEnvironment and attaches a program such as
public void buildMyProg
Hi Fabian,
thanks for the response.
So my mains should be converted in a method returning the
ExecutionEnvironment.
However it think that it will be very nice to have a syntax like the one of
the Hadoop ProgramDriver to define jobs to invoke from a single root class.
Do you think it could be useful
You easily have multiple Flink programs in a single JAR file.
A program is defined using an ExecutionEnvironment and executed when you
call ExecutionEnvironment.exeucte().
Where and how you do that does not matter.
You can for example implement a main function such as:
public static void main(Str
Hi to all,
is there any way to keep multiple jobs in a jar and then choose at runtime
the one to execute (like what ProgramDriver does in Hadoop)?
Best,
Flavio
10 matches
Mail list logo