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
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
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
+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,
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
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
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
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
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