Hi! For a Storm program, you would need a "RemoteStreamEnvironment" - the "RemoteEnvironment" is for batch programs.
Stephan On Wed, Apr 13, 2016 at 6:23 PM, star jlong <jlongs...@yahoo.fr.invalid> wrote: > 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 <trohrm...@apache.org> > 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 <se...@apache.org> 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 <jlongs...@yahoo.fr.invalid> > > 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 < > > ches...@apache.org> > > > 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 > > > <jlongs...@yahoo.fr.INVALID> 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 < > > > ches...@apache.org> 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 > > <jlongs...@yahoo.fr.invalid > > > > > > > >> 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 > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > >
