[jira] [Created] (FLINK-19693) Scheduler Change for Approximate Local Recovery

Yuan Mei created FLINK-19693: Summary: Scheduler Change for Approximate Local Recovery Key: FLINK-19693 URL: https://issues.apache.org/jira/browse/FLINK-19693 Project: Flink Issue Type: Sub-task

Re: Re: [VOTE] Add Translation Specification for Stateful Functions

@Shawn Thanks for the notice, that's is not related to this thread, but I think we should fix it, will update it accordingly. Best, Congxian Shawn Huang 于2020年10月17日周六 上午11:27写道： > Hi, Congxian. > Thanks for your contribution. > I noticed that in wiki, the link format is still like "{{ site.ba

[jira] [Created] (FLINK-19694) Support [UPDATE_AFTER, DELETE] ChangelogMode for ScanTableSource

Jark Wu created FLINK-19694: --- Summary: Support [UPDATE_AFTER, DELETE] ChangelogMode for ScanTableSource Key: FLINK-19694 URL: https://issues.apache.org/jira/browse/FLINK-19694 Project: Flink Issue

[jira] [Created] (FLINK-19695) Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException

Konstantin Knauf created FLINK-19695: Summary: Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException Key: FLINK-19695 URL: https://issues.apache.org/jira/browse/FLINK-19

[jira] [Created] (FLINK-19696) Implement Batch committer for the new API

Guowei Ma created FLINK-19696: - Summary: Implement Batch committer for the new API Key: FLINK-19696 URL: https://issues.apache.org/jira/browse/FLINK-19696 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19697) Make the streaming committer retry-able

Guowei Ma created FLINK-19697: - Summary: Make the streaming committer retry-able Key: FLINK-19697 URL: https://issues.apache.org/jira/browse/FLINK-19697 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

Jiangjie Qin created FLINK-19698: Summary: Add close() method and onCheckpointComplete() to the Source. Key: FLINK-19698 URL: https://issues.apache.org/jira/browse/FLINK-19698 Project: Flink

[jira] [Created] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

Dian Fu created FLINK-19699: --- Summary: PrometheusReporterEndToEndITCase crashes with exit code 143 Key: FLINK-19699 URL: https://issues.apache.org/jira/browse/FLINK-19699 Project: Flink Issue Type

[jira] [Created] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

Yang Wang created FLINK-19700: - Summary: Make Kubernetes Client in KubernetesResourceManagerDriver use io executor Key: FLINK-19700 URL: https://issues.apache.org/jira/browse/FLINK-19700 Project: Flink

Re: [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

+1 On Fri, Oct 16, 2020 at 2:33 PM Leonard Xu wrote: > +1 > > Best, > Leonard > > > 在 2020年10月16日，11:01，Jark Wu 写道： > > > > +1 > > > > On Fri, 16 Oct 2020 at 10:27, admin <17626017...@163.com> wrote: > > > >> +1 > >> > >>> 2020年10月16日 上午10:05，Danny Chan 写道： > >>> > >>> +1, nice job ! > >>> > >

[jira] [Created] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

Yun Gao created FLINK-19701: --- Summary: Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier Key: FLINK-19701 URL: https://issues.apache.org/jira/browse/FLINK-19701 Pr

Re: [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

+1 Jingsong Li 于2020年10月19日周一 上午10:54写道： > +1 > > On Fri, Oct 16, 2020 at 2:33 PM Leonard Xu wrote: > > > +1 > > > > Best, > > Leonard > > > > > 在 2020年10月16日，11:01，Jark Wu 写道： > > > > > > +1 > > > > > > On Fri, 16 Oct 2020 at 10:27, admin <17626017...@163.com> wrote: > > > > > >> +1 > > >> >

[jira] [Created] (FLINK-19702) Avoid using HiveConf::hiveSiteURL

Rui Li created FLINK-19702: -- Summary: Avoid using HiveConf::hiveSiteURL Key: FLINK-19702 URL: https://issues.apache.org/jira/browse/FLINK-19702 Project: Flink Issue Type: Improvement Compo

?????? [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

 +1       It is A essential feature for the users who use DataStream inside of TableSource/TableSink so that they can do some advanced operations. As one of them, I feel really excited and look forward to the implementation of FLIP-146 Appreciate it! --  --

Re?? [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

 +1      It is A essential feature for the users who use DataStream inside of TableSource/TableSink so that they can do some advanced operations. As one of them, I feel really excited and look forward to the implementation of FLIP-146 Appreciate it! -- --

[jira] [Created] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager

Zhu Zhu created FLINK-19703: --- Summary: A result partition is not untracked after its producer task failed in TaskManager Key: FLINK-19703 URL: https://issues.apache.org/jira/browse/FLINK-19703 Project: Flin

[jira] [Created] (FLINK-19704) Flink checkpoint will fail when keytab dir meets a failure, and the flink should handle it.

zhuqi created FLINK-19704: - Summary: Flink checkpoint will fail when keytab dir meets a failure, and the flink should handle it. Key: FLINK-19704 URL: https://issues.apache.org/jira/browse/FLINK-19704 Project

[jira] [Created] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer

Robert Metzger created FLINK-19705: -- Summary: Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer Key: FLINK-19705 URL: https://issues.apache.org/jira/browse/