Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints

+1 Might also be a good start to implement queryable stream state with snapshot isolation using that mechanism. Paris > On 17 Aug 2018, at 12:28, Gyula Fóra wrote: > > Hi All! > > I want to share with you a little project we have been working on at King > (with some help from some dataArtisa

Re: [VOTE] Release 1.5.3, release candidate #1

+1, - checkout the source code of Flink v1.5.3-rc1 and packaged (skip tests) successfully - reviewed announcement blog post and gave a little comment - ran flink-table's test successfully - checked all modules' version number is 1.5.3 Thanks, vino. Till Rohrmann 于2018年8月18日周六 上午12:25写道： > +1 (

[DISCUSS][TABLE] How to handle empty delete for UpsertSource

Hi all, Currently, I am working on FLINK-8577 Implement proctime DataStream to Table upsert conversion . And a design doc can be found here . It recei

[jira] [Created] (FLINK-10169) RowtimeValidator fails with custom TimestampExtractor

Timo Walther created FLINK-10169: Summary: RowtimeValidator fails with custom TimestampExtractor Key: FLINK-10169 URL: https://issues.apache.org/jira/browse/FLINK-10169 Project: Flink Issue T