[SUMMARY] Flink 1.16 release sync of 2022-08-02

Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-02. Currently, we have 19 features that have been completed for this release and 32 features are still expected to make it. We only have one week remaining until the feature freeze (at

[jira] [Created] (FLINK-28784) ParameterTool support read and parse program arguments from yml file

Aiden Gong created FLINK-28784: -- Summary: ParameterTool support read and parse program arguments from yml file Key: FLINK-28784 URL: https://issues.apache.org/jira/browse/FLINK-28784 Project: Flink

[jira] [Created] (FLINK-28783) Class ConfigOptions's example code have error.

Aiden Gong created FLINK-28783: -- Summary: Class ConfigOptions's example code have error. Key: FLINK-28783 URL: https://issues.apache.org/jira/browse/FLINK-28783 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28782) Support FileSink compaction in PyFlink

Juntao Hu created FLINK-28782: - Summary: Support FileSink compaction in PyFlink Key: FLINK-28782 URL: https://issues.apache.org/jira/browse/FLINK-28782 Project: Flink Issue Type: New Feature

Re: [RESULT][VOTE] FLIP-238: Introduce FLIP-27-based Data Generator Source

Looking forward to this, thanks Alex! On Tue, Aug 2, 2022 at 6:33 PM Alexander Fedulov wrote: > Hi, everyone. > > FLIP-238: Introduce FLIP-27-based Data Generator Source [1] has been > accepted. > > Votes for: 3 binding and 2 non-binding. > > - Martijn Visser (binding) > - Robert Metzger

[RESULT][VOTE] FLIP-238: Introduce FLIP-27-based Data Generator Source

Hi, everyone. FLIP-238: Introduce FLIP-27-based Data Generator Source [1] has been accepted. Votes for: 3 binding and 2 non-binding. - Martijn Visser (binding) - Robert Metzger (binding) - Qingsheng Ren (binding) - Jing Ge(non-binding) - Rui Fan(non-binding) Votes against: none. Thanks to

[jira] [Created] (FLINK-28781) Hybrid Shuffle should supports compression

Weijie Guo created FLINK-28781: -- Summary: Hybrid Shuffle should supports compression Key: FLINK-28781 URL: https://issues.apache.org/jira/browse/FLINK-28781 Project: Flink Issue Type: Bug

?????? [Phishing Risk] [External] [DISCUSS] FLIP-255 Introduce pre-aggregated merge to Table Store

Thank you for reviewing FLIP-255. That indeed is a typo. I will correct it immediately. Best, Nathan ---- ??: "dev"

?????? [Phishing Risk] [External] [DISCUSS] FLIP-255 Introduce pre-aggregated merge to Table Store

Very much thank you for reviewing FLIP-255. ## Aggregate functions I partly refer to Apache Druid[1]. In Druid, each aggregate column is designated by an Json/map string, such as ??{"type": count, "name": https://druid.apache.org/docs/latest/querying/aggregations.html [2]

[jira] [Created] (FLINK-28780) function docs of dayofmonth is not correct

jackylau created FLINK-28780: Summary: function docs of dayofmonth is not correct Key: FLINK-28780 URL: https://issues.apache.org/jira/browse/FLINK-28780 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28779) Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

lincoln lee created FLINK-28779: --- Summary: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems Key: FLINK-28779 URL: https://issues.apache.org/jira/browse/FLINK-28779

Re: Flink Table issue

Hi Sergiy, Per https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/jdbc/, do you also have the driver dependency for your database added to your POM? Best regards, Martijn Op di 2 aug. 2022 om 12:52 schreef Sergiy Gonta : > Hi, > Could you tell me please, why the Flink

Flink Table issue

Hi, Could you tell me please, why the Flink cluster can't find org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat if it is present in JAR? (the screenshot is attached) [image: image.png] Caused by: java.lang.Exception: Loading the input/output formats failed: at

[jira] [Created] (FLINK-28778) Bulk fetch of table and column statistics for given partitions

Jing Ge created FLINK-28778: --- Summary: Bulk fetch of table and column statistics for given partitions Key: FLINK-28778 URL: https://issues.apache.org/jira/browse/FLINK-28778 Project: Flink Issue

[jira] [Created] (FLINK-28777) Add configure session API for sql gateway rest endpoint

Wencong Liu created FLINK-28777: --- Summary: Add configure session API for sql gateway rest endpoint Key: FLINK-28777 URL: https://issues.apache.org/jira/browse/FLINK-28777 Project: Flink Issue

[RESULT][VOTE] FLIP--247 Bulk fetch of table and column statistics for given partitions

Hi, everyone. FLIP--247 Bulk fetch of table and column statistics for given partitions[1] has been accepted. There are 3 binding votes, 1 non-binding votes[2]. - Jark Wu(binding) - Godfrey He(binding) - Jingsong Li(binding) - Rui Fan(non-binding) None against. Thanks everyone! Best regards,

[jira] [Created] (FLINK-28776) RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream WatermarkAssignerOperator

jackylau created FLINK-28776: Summary: RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream WatermarkAssignerOperator Key: FLINK-28776 URL: https://issues.apache.org/jira/browse/FLINK-28776

[jira] [Created] (FLINK-28775) Unclean shade in flink-table-store-dist

Jingsong Lee created FLINK-28775: Summary: Unclean shade in flink-table-store-dist Key: FLINK-28775 URL: https://issues.apache.org/jira/browse/FLINK-28775 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28774) Allow user to configure whether to enable sort or not when it's for dynamic parition writing for HiveSource

luoyuxia created FLINK-28774: Summary: Allow user to configure whether to enable sort or not when it's for dynamic parition writing for HiveSource Key: FLINK-28774 URL:

[jira] [Created] (FLINK-28773) Allow to write a success file after finish writing for Hive sink in batch mode

luoyuxia created FLINK-28773: Summary: Allow to write a success file after finish writing for Hive sink in batch mode Key: FLINK-28773 URL: https://issues.apache.org/jira/browse/FLINK-28773 Project:

[jira] [Created] (FLINK-28772) Port AddJarOperation to Hive dialect

luoyuxia created FLINK-28772: Summary: Port AddJarOperation to Hive dialect Key: FLINK-28772 URL: https://issues.apache.org/jira/browse/FLINK-28772 Project: Flink Issue Type: Sub-task