[jira] [Created] (FLINK-21378) Rescale pointwise connection during unaligned checkpoint recovery

2021-02-15 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-21378: --- Summary: Rescale pointwise connection during unaligned checkpoint recovery Key: FLINK-21378 URL: https://issues.apache.org/jira/browse/FLINK-21378 Project: Flink

Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished

2021-02-15 Thread Yun Gao
Hi all, I'd like to first detail the issue with emitting records in notifyCheckpointComplete for context. For specific usage, an example would be for sink, it might want to write some metadata after all the transactions are committed (like write a marker file _SUCCESS to the output

Re: [DISCUSS] FLIP-151: Incremental snapshots for heap-based state backend

2021-02-15 Thread Roman Khachatryan
Thanks for your reply Stephan. Yes, there is overlap between FLIP-151 and FLIP-158 as both address incremental state updates. However, I think that FLIP-151 on top of FLIP-158 increases efficiency by: 1. "Squashing" the changes made to the same key. For example, if some counter was changed 10

Re: [VOTE] FLIP-164: Improve Schema Handling in Catalogs

2021-02-15 Thread Seth Wiesman
+1 (binding) On Fri, Feb 12, 2021 at 8:25 AM Jark Wu wrote: > +1 (binding) > > Best, > Jark > > > 2021年2月12日 20:37，Dawid Wysakowicz 写道： > > > > +1 (binding) > > > > Best, > > > > Dawid > > > > On 12/02/2021 13:33, Timo Walther wrote: > >> Hi everyone, > >> > >> I'd like to start a vote on

Re: [DISCUSS] Releasing Apache Flink 1.12.2

2021-02-15 Thread Yuan Mei
Hey devs, I'm very glad to announce that all known blocking issues for release-1.12.2 have been resolved. release-1.12.2 will freeze at: commit 1f8be1fd7b2b37a124e4d2b8080d08e259bdf095 Roman and I are about to prepare the first release candidate and many thanks to Roman for agreeing to do the

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-15 Thread Jark Wu
Hi Ingo, 1) I think you are right, the table path should be fully-qualified. 2) I think this is also a good point. The SHOW CREATE TABLE only aims to print DDL for the tables registered using SQL CREATE TABLE DDL. If a table is registered using Table API, e.g.

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-15 Thread Ingo Bürk
Hi all, I have a couple questions about the SHOW CREATE TABLE statement. 1) Contrary to the example in the FLIP I think the returned DDL should always have the table identifier fully-qualified. Otherwise the DDL depends on the current context (catalog/database), which could be surprising,

[jira] [Created] (FLINK-21377) Refactor some queryable-state JobMaster tests to work against schedulers

2021-02-15 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21377: Summary: Refactor some queryable-state JobMaster tests to work against schedulers Key: FLINK-21377 URL: https://issues.apache.org/jira/browse/FLINK-21377

[jira] [Created] (FLINK-21376) Failed state might not provide failureCause

2021-02-15 Thread Matthias (Jira)
Matthias created FLINK-21376: Summary: Failed state might not provide failureCause Key: FLINK-21376 URL: https://issues.apache.org/jira/browse/FLINK-21376 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21375) Refactor HybridMemorySegment

2021-02-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21375: Summary: Refactor HybridMemorySegment Key: FLINK-21375 URL: https://issues.apache.org/jira/browse/FLINK-21375 Project: Flink Issue Type: Task