Re: Live configuration change

Ning can you provide another example except for rate limiting? On Tue, Nov 6, 2018, 6:20 PM Piotr Nowojski Hi, > > Sorry but none that I’m aware of. As far as I know, the only way to > dynamically configure Kafka source would be for you to copy and modify it’s > code. > > Piotrek > > > On 6 Nov

Re: DatabaseClient at async example

e asyncio concept. There > is no interface/class for this client in Flink codebase. You can use any > mariaDB client implementation which supports concurrent request to DB. > > -- > Cheers, > Amit > > On Wed, Oct 3, 2018 at 8:14 PM Nicos Maris wrote: > >> Hello, >>

Re: test windows

gt; > > >org.mockito >mockito-all >1.10.19 >jar >test > > > >org.apache.flink > flink-runtime_2.11 >${flink.version} >test >test-jar > > > On Thu, Aug 30, 2018 at 3:04 PM Nicos Maris wrote: > > > > Can

Re: replacing WindowFunction with AggregateFunction

Sun, Sep 9, 2018 at 4:40 AM Nicos Maris wrote: > Hi, > > > I am replacing replacing my legacy > <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#windowfunction-legacy> > WindowFunction with AggregateFunction. > > I use

replacing WindowFunction with AggregateFunction

Hi, I am replacing replacing my legacy WindowFunction with AggregateFunction. I use TumblingEventTimeWindows, how can I get the start

maxOutOfOrderness

Hello, Does maxOutOfOrderness affect performance? Setting it to Long.MAX_VALUE doesn't affect performance, so either flink is really fast in my simple pipeline or my

Re: ODP: API for delayed/scheduled interval input source for integrationtests

flink-spector is not really active and I have tried it and it is not as simple as it seams to be. On Sat, Sep 1, 2018 at 10:45 PM Yee-Ning Cheng wrote: > I haven't tried it yet, but I saw flink-spector which seems to actually do > what I want.. > >

Re: test windows

g I can get from flink as regards automated testing of pipelines with time windows. On Tue, Aug 28, 2018 at 3:12 PM Nicos Maris wrote: > Hi Zhengwen, > > > I have tested my job manually (both by submitting a job and through > execute()) and I am trying to write a test. > > The follo

Re: test windows

could run these examples directly from your > IDE by standalone mode. > > best, > Zhengwen > > On Tue, Aug 28, 2018 at 7:35 PM Nicos Maris wrote: > >> Hi all, >> >> >> How can I test in Java any streaming job that has a time window? >> >> >

test windows

Hi all, How can I test in Java any streaming job that has a time window? best, Nicos

Re: would you join a Slack workspace for Flink?

he mailing list feel the > same. > > Best, > Fabian > > Am So., 26. Aug. 2018 um 15:17 Uhr schrieb Nicos Maris < > nicos.ma...@gmail.com>: > >> Hi Dominik, >> >> I was writing about gitter just now :) >> >> If searchability is an issue, then

Re: would you join a Slack workspace for Flink?

> > Wysłane z aplikacji Poczta > <https://go.microsoft.com/fwlink/?LinkId=550986> dla Windows 10 > > > > *Od: *Hequn Cheng > *Wysłano: *niedziela, 26 sierpnia 2018 14:37 > *Do: *Nicos Maris > *DW: *ches...@apache.org; user > *Temat: *Re: would you join

Re: would you join a Slack workspace for Flink?

channel; I'm not aware of any > committer actually spending time there. > > On 25.08.2018 17:07, Nicos Maris wrote: > > > Hi all, > > > This mailing list is for user support and questions. If you would also use > slack for user support and questions, then please vote at

would you join a Slack workspace for Flink?

Hi all, This mailing list is for user support and questions. If you would also use slack for user support and questions, then please vote at the following ticket. If you don't have an account at that jira, you can reply to this email with a "+1". [FLINK-10217

Re: python vs java api

ng/python/api/datastream/PythonDataStream.java > > Thanks, vino. > > > 2018-07-31 22:59 GMT+08:00 Nicos Maris : > >> Which java features of flink are not supported by the python API when >> writing a pipeline? >> > >

Re: scala IT

the Flink type > system can be found in the official documentation[1]. > > [1]: > https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/types_serialization.html#type-information-in-the-scala-api > > Thanks, vino. > > 2018-07-31 6:30 GMT+08:00 Nicos Maris : &g

scala IT

and I would like to have both, not flink with Java. Am I doing something that is fundamentally wrong? thanks, Nicos Maris