Re: S3 Checkpointing taking long time with stateful operations

2020-06-20 Thread Congxian Qiu
Hi Sandeep The picture isn't shown. First, you can try to find out whether there is some operator's e2e time is big, the e2e time of snapshot for one operator is time${barrier align time} + time{sync-snapshot} + time{async-snapshot}. exactly-once and at least once both need to wait for barrier al

[jira] [Created] (FLINK-18399) TableResult#print can not print the result of unbounded stream query

2020-06-20 Thread godfrey he (Jira)
godfrey he created FLINK-18399: -- Summary: TableResult#print can not print the result of unbounded stream query Key: FLINK-18399 URL: https://issues.apache.org/jira/browse/FLINK-18399 Project: Flink

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

2020-06-20 Thread Leonard Xu
Hi everyone, Thanks for the nice discussion. I’d like to move forward the work, please let me simply summarize the main opinion and current divergences. 1. The agreements have been achieved: 1.1 The motivation we're discussing temporal table DDL is just for creating temporal table in pure SQL

Re: Apply contributor

2020-06-20 Thread Benchao Li
Hi Shiwei, Welcome to the community! Now we don't have contributor permissions, you can just ping a committer to assign the issue to you if you are interested to contribute. FYI, you can read the "how to contribute"[1] doc before your contribution. [1] https://flink.apache.org/contributing/how-to