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

2022-08-02 Thread luoyuxia (Jira)
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: Flink

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

2022-08-02 Thread luoyuxia (Jira)
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: https://issues.apache.org/jira/browse/FLINK-2877

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

2022-08-02 Thread Jingsong Lee (Jira)
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-28776) RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream WatermarkAssignerOperator

2022-08-02 Thread jackylau (Jira)
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

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

2022-08-02 Thread Jing Ge
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, J

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

2022-08-02 Thread Wencong Liu (Jira)
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 T

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

2022-08-02 Thread Jing Ge (Jira)
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 T

Flink Table issue

2022-08-02 Thread Sergiy Gonta
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 org.apache.flink.runti

Re: Flink Table issue

2022-08-02 Thread Martijn Visser
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 c

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

2022-08-02 Thread lincoln lee (Jira)
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 Projec

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

2022-08-02 Thread jackylau (Jira)
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

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

2022-08-02 Thread Hannan Kan
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] https://doris.apache.o

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

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

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

2022-08-02 Thread Weijie Guo (Jira)
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

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

2022-08-02 Thread Alexander Fedulov
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 ever

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

2022-08-02 Thread Austin Cawley-Edwards
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 (bindin

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

2022-08-02 Thread Juntao Hu (Jira)
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

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

2022-08-02 Thread Aiden Gong (Jira)
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-28784) ParameterTool support read and parse program arguments from yml file

2022-08-02 Thread Aiden Gong (Jira)
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

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

2022-08-02 Thread Xingbo Huang
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 2022-08-0

[VOTE] Apache Flink Table Store 0.2.0, release candidate #1

2022-08-02 Thread Jingsong Li
Hi everyone, Please review and vote on the release candidate #1 for the version 0.2.0 of Apache Flink Table Store, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of the follo

[jira] [Created] (FLINK-28785) Hybrid shuffle consumer thread and upstream thread may have dead lock

2022-08-02 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-28785: -- Summary: Hybrid shuffle consumer thread and upstream thread may have dead lock Key: FLINK-28785 URL: https://issues.apache.org/jira/browse/FLINK-28785 Project: Flink

[jira] [Created] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-08-02 Thread Ran Tao (Jira)
Ran Tao created FLINK-28786: --- Summary: Cannot run PyFlink 1.16 on MacOS with M1 chip Key: FLINK-28786 URL: https://issues.apache.org/jira/browse/FLINK-28786 Project: Flink Issue Type: Bug Affec