[jira] [Created] (FLINK-28797) Hive source should also support verctor reading for complex data type when with parquet format

luoyuxia created FLINK-28797: Summary: Hive source should also support verctor reading for complex data type when with parquet format Key: FLINK-28797 URL: https://issues.apache.org/jira/browse/FLINK-28797

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

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 I

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

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 T

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

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: Impr

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

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: Sub-t

FW: 1.13.2 - Flink Metrics not updated during job execution

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 Portu

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

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 the

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

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 Componen

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

+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 w

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

+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 discussion

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

+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 spli

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

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 Is

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

Valentina Predtechenskaya created FLINK-28790: - Summary: Incorrect KafkaProducer metrics initialization Key: FLINK-28790 URL: https://issues.apache.org/jira/browse/FLINK-28790 Project: Flin

Re: slack

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 Mironov

Re: slack

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

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

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

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

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 Issu

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

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 [2