Re: Any advice on how to replay an event-timed stream?

2019-01-18 Thread Kanstantsin Kamkou
gt; If this isn't what you're trying to accomplish please be more thorough in > your explanation.. Thanks. > > -Jamie > > > On Thu, Jan 17, 2019 at 10:34 PM Kanstantsin Kamkou > wrote: > >> Thanks for the reply. As mentioned before the data comes from the &g

Any advice on how to replay an event-timed stream?

2019-01-17 Thread Kanstantsin Kamkou
an you narrow down your constraints? Where does the > historical data live? > > -Jamie > > > > > On Thu, Jan 17, 2019 at 4:36 PM Kanstantsin Kamkou > wrote: > >> Hi guys! As I understood (I hope I’m wrong) the current design concept of >> the watermarking

Any advice on how to replay an event-timed stream?

2019-01-17 Thread Kanstantsin Kamkou
misleading). Could you share your thoughts on how to replay historical data in event–time manner (i.e. from db to working application)? The solution with the processing time is not suitable here as the sessions windows are needed. Thank you! -- Best regards, Kanstantsin Kamkou email: kkam

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

2017-07-12 Thread Kanstantsin Kamkou
Hi users! I can't upgrade from 1.2.x to 1.3.x without code adaptations. Upgrading from 1.(0|1).x to 1.2.x produces configuration mess. Maybe you can discuss changing the release plan, speed it up a little bit and use the major.minor.patch versions as advantage to organize the release process more

Re: [DISCUSS] "Who's hiring on Flink" monthly thread in the mailing lists?

2016-12-07 Thread Kanstantsin Kamkou
Is it possible to avoid such a spam here? If I need a new job, I could search it. The same way I might want to subscribe to a different thread, like jobs@flink. * The idea itself is great. On Tue, 6 Dec 2016 at 14:04, Kostas Tzoumas wrote: > yes, of course! > > On Tue, Dec 6, 2016 at 12:54 PM, M

Re: Maintaining watermarks per key, instead of per operator instance

2016-06-02 Thread Kanstantsin Kamkou
Hi Aljoscha! Is it possible somehow to use the RichXFunction in CEP? The task is pretty similar, but I have to ignore once the next triggered event for the same key. On Wed, Jun 1, 2016 at 2:54 PM, Aljoscha Krettek wrote: > Hi, > yeah, in that case per-key watermarks would be useful for you. I w

Re: Visualize result of Flink job

2016-05-29 Thread Kanstantsin Kamkou
> I am thinking it may not be the best fit, because Elastic is by nature a > search engine that is good for trending and stuff like that - not entire > replacement of the current view. Why u think that the elasticsearch is not the right tool? To visualise something u have to find what to visuali