scala IT

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

Re: scala IT

ion. More information on 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:0

python vs java api

Which java features of flink are not supported by the python API when writing a pipeline?

Re: python vs java api

reaming/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? >> > >

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: would you join a Slack workspace for Flink?

nel; 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

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 a Slack

Re: would you join a Slack workspace for Flink?

elping out on the 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

test windows

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

Re: test windows

, you 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? >> >>

Re: test windows

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: 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.. > > https://github.com/ottogroup/flink-spector/wiki

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 understandi

replacing WindowFunction with AggregateFunction

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

Re: replacing WindowFunction with AggregateFunction

> On 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. > &

Re: test windows

jar > > > >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: > > > >

DatabaseClient at async example

Hello, I have a short question about the following example in your documentation. https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/asyncio.html Which is the package and the maven dependency of the class DatabaseClient? I am building a Proof of Concept based on t

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: 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 2