Thanks for the reply.
@Stephen, I try using RemoteEnvironment to submit my topology to flink.
Here is the try that I did RemoteEnvironment remote = new
RemoteEnvironment(ipJobManager, 6123, jarPath); remote.execute();
While running the program, this is the exception that I got.
java.lang.RuntimeException: No data sinks have been created yet. A program
needs at least one sink that consumes data. Examples are writing the data set
or printing it.
Le Mercredi 13 avril 2016 16h54, Till Rohrmann <[email protected]> a
écrit :
I think this is not the problem here since the problem is still happening
on the client side when the FlinkTopology tries to copy the registered
spouts. This happens before the job is submitted to the cluster. Maybe
Mathias could chime in here.
Cheers,
Till
On Wed, Apr 13, 2016 at 5:39 PM, Stephan Ewen <[email protected]> wrote:
> Hi!
>
> For flink standalone programs, you would use a "RemoteEnvironment"
>
> For Storm, I would use the "FlinkClient" in "org.apache.flink.storm.api".
> That one should deal with jars, classloaders, etc for you.
>
> Stephan
>
>
> On Wed, Apr 13, 2016 at 3:43 PM, star jlong <[email protected]>
> wrote:
>
> > Thanks for the suggestion. Sure those examples are interesting and I have
> > deploy them successfully on flink. The deployment is done the command
> line
> > that is doing something like
> > bin/flink run example.jarBut what I want is to submit the topology to
> > flink using a java program.
> >
> > Thanks.
> >
> > Le Mercredi 13 avril 2016 14h12, Chesnay Schepler <
> [email protected]>
> > a écrit :
> >
> >
> > you can find examples here:
> >
> >
> https://github.com/apache/flink/tree/master/flink-contrib/flink-storm-examples
> >
> > we haven't established yet that it is an API issue; it could very well
> > be caused by the reflection magic you're using...
> >
> > On 13.04.2016 14:57, star jlong wrote:
> > > Ok, it seems like there an issue with the api. So please does anybody
> > has a working example for deploying a topology using the flink dependency
> > flink-storm_2.11 or any other will be welcoming.
> > >
> > > Thanks,
> > > jstar
> > >
> > > Le Mercredi 13 avril 2016 13h44, star jlong
> > <[email protected]> a écrit :
> > >
> > >
> > > Hi Schepler,
> > >
> > > Thanks for the concerned. Yes I'm actaully having the same issue as
> > indicated on that post because I'm the one that posted that issue.
> > >
> > > Le Mercredi 13 avril 2016 13h35, Chesnay Schepler <
> > [email protected]> a écrit :
> > >
> > >
> > >
> >
> http://stackoverflow.com/questions/36584784/issues-while-submitting-a-topology-to-apache-flink-using-the-flink-api
> > >
> > > On 13.04.2016 14:28, Till Rohrmann wrote:
> > >> Hi jstar,
> > >>
> > >> what's exactly the problem you're observing?
> > >>
> > >> Cheers,
> > >> Till
> > >>
> > >> On Wed, Apr 13, 2016 at 2:23 PM, star jlong
> <[email protected]
> > >
> > >> wrote:
> > >>
> > >>> Hi there,
> > >>>
> > >>> I'm jstar. I have been playing around with flink. I'm very much
> > interested
> > >>> in submitting a topoloy to flink using its api. As indicated
> > >>> on stackoverflow, that is the try that I have given. But I was stuck
> > with
> > >>> some exception. Please any help will be welcoming.
> > >>>
> > >>>
> > >>> Thanks.
> > >>> jstar
> > >
> > >
> > >
> > >
> > >
> >
> >
> >
> >
> >
>
