Re: Issue regarding the submission of a topology to a remote flink cluster.

2016-04-15 Thread star jlong
annot create generate a file with the key-pair. So ssh the instance to deploy the flink topology wouldn't be possible as we can't provide them with key-pairs.  On Fri, Apr 15, 2016 at 4:36 PM, star jlong wrote: Hi Till, Thanks for the reply. The idea of ssh of the instance is a good one. I

Re: Issue regarding the submission of a topology to a remote flink cluster.

2016-04-15 Thread star jlong
Hi Till, Thanks for the reply. The idea of ssh of the instance is a good one. I thought of that but in my case it is not applicable because I setting up a cluster some employees of a company. And ssh the instance by employees will mean giving them the instance's key-pair, which I can not. Matte

Re: Issue deploying a topology to flink with a java api

2016-04-14 Thread star jlong
-SNAPSHOT Could  not be satisfy, but this one could be org.apache.flink flink-storm_2.10 1.1-SNAPSHOT Le Jeudi 14 avril 2016 13h05, Matthias J. Sax a écrit : change the version to 1.1-SNAPSHOT On 04/14/2016 11:52 AM, star jlong wrote: > One question which dependency of flink are

Re: Issue deploying a topology to flink with a java api

2016-04-14 Thread star jlong
One question which dependency of flink are you using because I'm using  org.apache.flink flink-storm-examples_2.11 1.0.0 And once I change the version to SNAPSHOT version, the pom.xml complains that it could not satisfy the given dependency. Le Jeudi 14 avril 2016 10h45, star jlo

Re: Issue deploying a topology to flink with a java api

2016-04-14 Thread star jlong
ClassLoader: > ClassLoader loader = URLClassLoader.newInstance(new URL[] { new URL(path) }, > FlinkGitService.class.getClassLoader()); It is the class that contains methods deploy() and getFlinkTopology() ? -Matthias On 04/14/2016 05:20 AM, star jlong wrote: > What I'm  trying to say

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
écrit : I cannot follow completely in your last step when you fail. What do you mean by "I'm stuck at the level when I want to copy that from the jar to submit it to flink"? Btw: I copied the code from the SO question and it works for me on the current master (which inclu

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
@Stephan,  I have try using RemoteStreamEnvironment but I have another exception which is  java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute. Le Mercredi 13 avril 2016 20h40, star jlong a écrit : Thanks Matthias for the reply.  Maybe I

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
m storm-examples. It uses maven plug-ins in assemble the jar correctly. (Regular maven artifact do not work for job submission...) Will have a close look and follow up... Hope this helps already. -Matthias On 04/13/2016 06:23 PM, star jlong wrote: > Thanks for the reply. > @Stephen, I try using

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
uld 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 > wrote: > &

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
ing... 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

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
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 a écrit : Hi Schepler, Thanks

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
bmitting-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 > wrote: > >> Hi there, >>

Re: Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
jstar, what's exactly the problem you're observing? Cheers, Till On Wed, Apr 13, 2016 at 2:23 PM, star jlong 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

Issue deploying a topology to flink with a java api

2016-04-13 Thread star jlong
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