[jira] [Created] (FLINK-28796) Add Statement Completement API for sql gateway rest endpoint

2022-08-03 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28796: --- Summary: Add Statement Completement API for sql gateway rest endpoint Key: FLINK-28796 URL: https://issues.apache.org/jira/browse/FLINK-28796 Project: Flink

[jira] [Created] (FLINK-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-28795: Summary: Unstable test for HiveDialectQueryITCase#testInsertDirectory Key: FLINK-28795 URL: https://issues.apache.org/jira/browse/FLINK-28795 Project: Flink Issue

[jira] [Created] (FLINK-28794) Publish flink-table-store snapshot artifacts

2022-08-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28794: Summary: Publish flink-table-store snapshot artifacts Key: FLINK-28794 URL: https://issues.apache.org/jira/browse/FLINK-28794 Project: Flink Issue Type:

[jira] [Created] (FLINK-28793) Allow to GetInfo for HiveServer2 Endpoint

2022-08-03 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28793: - Summary: Allow to GetInfo for HiveServer2 Endpoint Key: FLINK-28793 URL: https://issues.apache.org/jira/browse/FLINK-28793 Project: Flink Issue Type:

FW: 1.13.2 - Flink Metrics not updated during job execution

2022-08-03 Thread Oliveira, Joao / Kuehne + Nagel / Opo MI-DH
From: "Oliveira, Joao / Kuehne + Nagel / Opo MI-DH" Date: Wednesday, 3 August 2022 at 09:54 To: "u...@flink.apache.org" Cc: "Melo, Jose / Kuehne + Nagel / Opo MI-DH" Subject: 1.13.2 - Flink Metrics not updated during job execution Hi Flink team, My name is João Oliveira, i’m living in

[GitHub] [flink-connector-rabbitmq] MartijnVisser commented on pull request #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API

2022-08-03 Thread GitBox
MartijnVisser commented on PR #1: URL: https://github.com/apache/flink-connector-rabbitmq/pull/1#issuecomment-1203925901 @pscls The CI fails due to spotless; can you fix that? (By running `mvn spotless:apply`) -- This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-28792) Upgrade to JOSDK 3.1.0

2022-08-03 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28792: -- Summary: Upgrade to JOSDK 3.1.0 Key: FLINK-28792 URL: https://issues.apache.org/jira/browse/FLINK-28792 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-217: Support watermark alignment of source splits

2022-08-03 Thread Martijn Visser
+1 (binding) Op wo 3 aug. 2022 om 14:33 schreef Piotr Nowojski : > +1 (binding) > > śr., 3 sie 2022 o 14:13 Thomas Weise napisał(a): > > > +1 (binding) > > > > > > On Sun, Jul 31, 2022 at 10:57 PM Sebastian Mattheis < > > sebast...@ververica.com> > > wrote: > > > > > Hi everyone, > > > > > > I

Re: [VOTE] FLIP-217: Support watermark alignment of source splits

2022-08-03 Thread Piotr Nowojski
+1 (binding) śr., 3 sie 2022 o 14:13 Thomas Weise napisał(a): > +1 (binding) > > > On Sun, Jul 31, 2022 at 10:57 PM Sebastian Mattheis < > sebast...@ververica.com> > wrote: > > > Hi everyone, > > > > I would like to start the vote for FLIP-217 [1]. Thanks for your feedback > > and the

Re: [VOTE] FLIP-217: Support watermark alignment of source splits

2022-08-03 Thread Thomas Weise
+1 (binding) On Sun, Jul 31, 2022 at 10:57 PM Sebastian Mattheis wrote: > Hi everyone, > > I would like to start the vote for FLIP-217 [1]. Thanks for your feedback > and the discussion in [2]. > > FLIP-217 is a follow-up on FLIP-182 [3] and adds support for watermark > alignment of source

[jira] [Created] (FLINK-28791) flink-sql-gateway-test does not compile on Java 11

2022-08-03 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28791: Summary: flink-sql-gateway-test does not compile on Java 11 Key: FLINK-28791 URL: https://issues.apache.org/jira/browse/FLINK-28791 Project: Flink

[jira] [Created] (FLINK-28790) Incorrect KafkaProducer metrics initialization

2022-08-03 Thread Valentina Predtechenskaya (Jira)
Valentina Predtechenskaya created FLINK-28790: - Summary: Incorrect KafkaProducer metrics initialization Key: FLINK-28790 URL: https://issues.apache.org/jira/browse/FLINK-28790 Project:

Re: slack

2022-08-03 Thread Ivan Mironov
Hi Martijn, Thank you! -- Regards, Ivan On Wed, 3 Aug 2022 at 12:06, Martijn Visser wrote: > Hi Ivan, > > I've invited you and also updated the Slack invite link at > https://flink.apache.org/community.html#slack > > Best regards, > > Martijn > > Op wo 3 aug. 2022 om 11:56 schreef Ivan

Re: slack

2022-08-03 Thread Martijn Visser
Hi Ivan, I've invited you and also updated the Slack invite link at https://flink.apache.org/community.html#slack Best regards, Martijn Op wo 3 aug. 2022 om 11:56 schreef Ivan Mironov : > Hi all! > > Can anybody invite me to Apache Flink Slack? > > Regards, > Ivan >

slack

2022-08-03 Thread Ivan Mironov
Hi all! Can anybody invite me to Apache Flink Slack? Regards, Ivan

[jira] [Created] (FLINK-28789) TPC-DS tests failed due to release input gate for task failure

2022-08-03 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-28789: -- Summary: TPC-DS tests failed due to release input gate for task failure Key: FLINK-28789 URL: https://issues.apache.org/jira/browse/FLINK-28789 Project: Flink

[jira] [Created] (FLINK-28788) Support SideOutput in Thread Mode

2022-08-03 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-28788: Summary: Support SideOutput in Thread Mode Key: FLINK-28788 URL: https://issues.apache.org/jira/browse/FLINK-28788 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28787) rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin

2022-08-03 Thread godfrey he (Jira)
godfrey he created FLINK-28787: -- Summary: rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin Key: FLINK-28787 URL: https://issues.apache.org/jira/browse/FLINK-28787 Project: Flink

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

2022-08-03 Thread Jingsong Li
Hi Nathan, Thanks for the reply. ## Aggregate functions I think `'fields.sum_field1.function'='sum'` is a safe one, I am more worried about using complex json, which will affect the sql parsing. ## Supported functions I think it is better to be consistent with Flink Table [1] and PostgreSQL

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

2022-08-03 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

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

2022-08-03 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

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

2022-08-03 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