Distributed Cache support for StreamExecutionEnvironment

Hi Team, Is there support for Distributed Cache in StreamExecutionEnvironment? I didn't find any such things in StreamExecutionEnvironment. I am using flink 1.1.1 I found distributed cache for ExecutionEnvironment but not for StreamExecutionEnvironment If Yes, Can anybody tell me how to use same

Re: Exception in CEP 1.1.2

Hi, So we cant seem to be able to reproduce the error after clearing the local maven cache. It works now :) Gyula Gyula Fóra ezt írta (időpont: 2016. szept. 7., Sze, 22:05): > Interestingly on my local machine I could not reproduce the problem, maybe > it was some build

Re: Exception in CEP 1.1.2

Great to hear :-) I was already afraid that I've overlooked another window boundary condition which I got wrong. If you should encounter other problems, then let me know. Cheers, Till On Fri, Sep 9, 2016 at 9:59 AM, Gyula Fóra wrote: > Hi, > So we cant seem to be able to

Re: Firing windows multiple times

Hi, I'd be very happy to give you pointers for FLIP-2 and FLIP-4. Why don't you start a separate thread on the dev list so that we don't hijack this thread. For FLIP-4 we also have to coordinate with Vishnu, he was driving FLIP-4 but lately everyone has been a bit inactive on that. Let's see if

Re: NoClassDefFoundError with ElasticsearchSink on Yarn

Hi Steffen, I think it would be good to add it to the documentation. Would you like to open a pull request? Regards, Robert On Mon, Sep 5, 2016 at 10:26 PM, Steffen Hausmann < stef...@hausmann-family.de> wrote: > Thanks Aris for your explanation! > > A guava version mismatch was indeed the

Re: Distributed Cache support for StreamExecutionEnvironment

Hi Swapnil, there's no support for something like DistributedCache in the DataStream API. However, as a workaround, you can rely on the RichFunction's open() method's to load such data directly from a distributed file system. Regards, Robert On Fri, Sep 9, 2016 at 8:13 AM, Swapnil Chougule

Re: NoClassDefFoundError with ElasticsearchSink on Yarn

+1 I ran into that issue as well. Would be great to have that in the docs! 2016-09-09 11:49 GMT+02:00 Robert Metzger : > Hi Steffen, > > I think it would be good to add it to the documentation. > Would you like to open a pull request? > > > Regards, > Robert > > > On Mon,

Re: Administration of running jobs

Hi Marek, You can use the RemoteExecutionEnvironment to submit a job programatically to a Flink cluster. there is also some ongoing work to programatically control submitted jobs: https://issues.apache.org/jira/browse/FLINK-4272. But for now you would probably need to hack something using the

Re: Administration of running jobs

Hi Robert. Thank you very much for your reply. I'll take a look at it. Marek. On 9.9.2016 12:09, Robert Metzger wrote: Hi Marek, You can use the RemoteExecutionEnvironment to submit a job programatically to a Flink cluster. there is also some ongoing work to programatically control