[jira] [Created] (FLINK-27823) Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink

suheng.cloud created FLINK-27823: Summary: Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink Key: FLINK-27823 URL: https://issues.apache.o

[jira] [Created] (FLINK-27824) Implement Pyflink KeyedSchema

Zixuan Rao created FLINK-27824: -- Summary: Implement Pyflink KeyedSchema Key: FLINK-27824 URL: https://issues.apache.org/jira/browse/FLINK-27824 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-27825) Update the doc of aligned checkpoint timeout

fanrui created FLINK-27825: -- Summary: Update the doc of aligned checkpoint timeout Key: FLINK-27825 URL: https://issues.apache.org/jira/browse/FLINK-27825 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27826) Support machine learning training for high dimesional models

Zhipeng Zhang created FLINK-27826: - Summary: Support machine learning training for high dimesional models Key: FLINK-27826 URL: https://issues.apache.org/jira/browse/FLINK-27826 Project: Flink

Re: [DISCUSS] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors

Hi Godfrey, It seems that the "SupportStatisticReport" interface name and "table.optimizer.source.connect-statistics-enabled" option name is not updated in the FLIP. Besides, in the terms of the option name, the meaning of "source.statistics-type" is not very straightforward and clean to me. May

[jira] [Created] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

Andreas Hailu created FLINK-27827: - Summary: StreamExecutionEnvironment method supporting explicit Boundedness Key: FLINK-27827 URL: https://issues.apache.org/jira/browse/FLINK-27827 Project: Flink

Re: [DISCUSS] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors

Hi Godfrey, Thanks for driving this FLIP. It looks really good! Looking forward to it! If I am not mistaken, partition pruning could also happen in the following pseudocode condition block: else if (filterPushDownSpec != null) { // only filter push down (*the description means parti

[jira] [Created] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

Jiangfei Liu created FLINK-27828: Summary: FlinkKafkaProducer VS KafkaSink Key: FLINK-27828 URL: https://issues.apache.org/jira/browse/FLINK-27828 Project: Flink Issue Type: Bug Com

Re: [VOTE] FLIP-235: Hybrid Shuffle Mode

+1 (non-binding) Best, Aitozi Yangze Guo 于2022年5月27日周五 11:17写道： > +1 > > Best, > Yangze Guo > > On Thu, May 26, 2022 at 4:42 PM Xintong Song > wrote: > > > > +1 > > > > Best, > > > > Xintong > > > > > > > > On Thu, May 26, 2022 at 3:47 PM weijie guo > > wrote: > > > > > Hi everyone, > > > > >

[jira] [Created] (FLINK-27829) Remove Calcite usages in flink-python

Chesnay Schepler created FLINK-27829: Summary: Remove Calcite usages in flink-python Key: FLINK-27829 URL: https://issues.apache.org/jira/browse/FLINK-27829 Project: Flink Issue Type: Tec