Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

2020-06-25 Thread Thomas Weise
--> On Wed, Jun 24, 2020 at 8:24 AM Aljoscha Krettek wrote: > Hi! > > On 24.06.20 00:51, Thomas Weise wrote: > > * -import org.apache.flink.table.api.java.StreamTableEnvironment; > >+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; > > This is very unfortunate yes, pleas

Re: [ANNOUNCE] Apache Flink 1.11.0, release candidate #2

2020-06-25 Thread Thomas Weise
Hi Till, Thanks for taking a look and for opening the PR. Previous options that specified a "pause" seem to be semantically different from new options that specify a "timeout", so probably best to remove them from code and documentation (old options are also still listed on https://ci.apache.org/

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

2020-06-25 Thread Jark Wu
Hi all, Thanks Leonard for summarizing our discussion. I want to share more of my thoughts: * rowtime is a column in the its schema, so the rowtime of DELETE event is the value of the previous image. * operation time is the time when the DML statements happen in databases, so the operation time o

Re: [VOTE] Release 1.11.0, release candidate #3

2020-06-25 Thread Marta Paes Moreira
Thanks, Zhijiang! The PR for the release announcement blogpost is now available in [1]. Any feedback or comments are appreciated! [1] https://github.com/apache/flink-web/pull/352 On Wed, Jun 24, 2020 at 5:03 PM Zhijiang wrote: > Hi everyone, > > This RC3 vote is re-launched for fixing the tag

[jira] [Created] (FLINK-18434) Can not select fields with JdbcCatalog

2020-06-25 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18434: Summary: Can not select fields with JdbcCatalog Key: FLINK-18434 URL: https://issues.apache.org/jira/browse/FLINK-18434 Project: Flink Issue Type: Bu

[FLINK-17073] checkpoint backpressure design doc

2020-06-25 Thread Etienne Chauchot
Hi all, regarding this [1] ticket I wrote a design document [2] for a checkpoint backpressure system. I wrote it using the FLIP formalism as I could not create a FLIP because I don't have the rights on the Flink confluence workspace. Can you tell me what you think ? Best Etienne Chauchot