[jira] [Created] (FLINK-29091) Correct RAND and RAND_INTEGER function to evaluate once at query-level for batch mode

2022-08-23 Thread lincoln lee (Jira)
lincoln lee created FLINK-29091: --- Summary: Correct RAND and RAND_INTEGER function to evaluate once at query-level for batch mode Key: FLINK-29091 URL: https://issues.apache.org/jira/browse/FLINK-29091

[upsert-kafka][SQL] Why Upsert-Kafka SQL connector is a different connector from the Kafka SQL Connector

2022-08-23 Thread Yufei Zhang
Hi all, I noticed there is a Upsert-Kafka SQL Connector[1] and the Kafka SQL Connector[2], my question is why do we implement them as two different connectors? For example, why not add a `upsert` config option in the Kafka SQL connector to specify whether the table enables upsert mode or not. Is

[jira] [Created] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData

2022-08-23 Thread Danny Chen (Jira)
Danny Chen created FLINK-29090: -- Summary: Fix the code gen for ColumnarMapData and ColumnarArrayData Key: FLINK-29090 URL: https://issues.apache.org/jira/browse/FLINK-29090 Project: Flink Issue

[jira] [Created] (FLINK-29089) Error when run test case in Windows

2022-08-23 Thread hjw (Jira)
hjw created FLINK-29089: --- Summary: Error when run test case in Windows Key: FLINK-29089 URL: https://issues.apache.org/jira/browse/FLINK-29089 Project: Flink Issue Type: Improvement

Energy/performance research questions

2022-08-23 Thread Sharma, Sanskriti, Rakesh
Hi everyone, We are a team of researchers at Boston University investigating the energy and performance behavior of open-source stream processing platforms. We have started looking into Flink and we wanted to reach out to community to see if anyone has tried to optimize the underlying

[jira] [Created] (FLINK-29088) Project push down cause the source reuse can not work

2022-08-23 Thread Aitozi (Jira)
Aitozi created FLINK-29088: -- Summary: Project push down cause the source reuse can not work Key: FLINK-29088 URL: https://issues.apache.org/jira/browse/FLINK-29088 Project: Flink Issue Type:

[jira] [Created] (FLINK-29087) Jdbc connector sql ITCase failed when run in idea

2022-08-23 Thread dalongliu (Jira)
dalongliu created FLINK-29087: - Summary: Jdbc connector sql ITCase failed when run in idea Key: FLINK-29087 URL: https://issues.apache.org/jira/browse/FLINK-29087 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29086) Fix the Helm chart's Pod env reference

2022-08-23 Thread Xin Hao (Jira)
Xin Hao created FLINK-29086: --- Summary: Fix the Helm chart's Pod env reference Key: FLINK-29086 URL: https://issues.apache.org/jira/browse/FLINK-29086 Project: Flink Issue Type: Improvement

Re: [VOTE] Release 1.15.2, release candidate #2

2022-08-23 Thread Danny Cranmer
Thanks everyone. The voting has concluded and the release has been approved. This thread is now closed. On Tue, Aug 23, 2022 at 9:37 AM Konstantin Knauf wrote: > +1 (binding) > > * checked checksum of binaries > * checked signatures of binaries & Maven artifacts > * checked dependency & NOTICE

[RESULT][VOTE] Release 1.15.2, release candidate #2

2022-08-23 Thread Danny Cranmer
I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * Chesnay Schepler (binding) * Xingbo Huang (non-binding) * Dawid Wysakowicz (binding) * Peng Kang (non-binding) * Konstantin Knauf (binding) There are no disapproving

[jira] [Created] (FLINK-29085) Add the name for test as hint for BuiltInFunctionTestBase

2022-08-23 Thread Aitozi (Jira)
Aitozi created FLINK-29085: -- Summary: Add the name for test as hint for BuiltInFunctionTestBase Key: FLINK-29085 URL: https://issues.apache.org/jira/browse/FLINK-29085 Project: Flink Issue Type:

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

2022-08-23 Thread Xingbo Huang
I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-23. *Since the feature freeze(9th of August 2022, end of business CEST), we have started release-testing[1] in the last two weeks. Only two tickets have been completed so far. We hope that the testers of the

[DISCUSS] ARM support for Flink

2022-08-23 Thread bo zhaobo
Hi Flinkers, In 2019, we raised an discussion in Flink about "ARM support for Flink"[1]. And we got so many helps and supports from Flink community about introducing a ARM CI system into Flink community, which is named "OpenLab"[2], and finally we create a full stack regression Flink tests on

[jira] [Created] (FLINK-29084) Program argument containing # (pound sign) mistakenly truncated in Kubernetes mode

2022-08-23 Thread Weike Dong (Jira)
Weike Dong created FLINK-29084: -- Summary: Program argument containing # (pound sign) mistakenly truncated in Kubernetes mode Key: FLINK-29084 URL: https://issues.apache.org/jira/browse/FLINK-29084

[jira] [Created] (FLINK-29083) how to split String to Array with scalar functions

2022-08-23 Thread Zha Ji (Jira)
Zha Ji created FLINK-29083: -- Summary: how to split String to Array with scalar functions Key: FLINK-29083 URL: https://issues.apache.org/jira/browse/FLINK-29083 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29082) Clean-up Leftovers for changelog pre-uploading files after failover

2022-08-23 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-29082: Summary: Clean-up Leftovers for changelog pre-uploading files after failover Key: FLINK-29082 URL: https://issues.apache.org/jira/browse/FLINK-29082 Project: Flink

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #2

2022-08-23 Thread Yu Li
+1 (binding) - Checked release notes: *Action Required* - Minor: there're still 25 open issues with fix version marked as 0.2.0 and need to be updated [1] - Checked sums and signatures: *OK* - Checked the jars in the staging repo: *OK* - Checked source distribution doesn't include binaries:

Re: [Discuss] Let's Session Cluster JobManager take a breather (FLIP-257: Flink JobManager Process Split)

2022-08-23 Thread David Morávek
Hi Zheng, Thanks for the write-up! I tend to agree with Chesnay that this introduces additional complexity to an already complex deployment model. One of the main focuses in this area is to reduce feature sparsity and to have fewer high-quality options. Example efforts are deprecation (and

[jira] [Created] (FLINK-29081) Join Hint cannot be identified by lowercase

2022-08-23 Thread xuyang (Jira)
xuyang created FLINK-29081: -- Summary: Join Hint cannot be identified by lowercase Key: FLINK-29081 URL: https://issues.apache.org/jira/browse/FLINK-29081 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.15.2, release candidate #2

2022-08-23 Thread Konstantin Knauf
+1 (binding) * checked checksum of binaries * checked signatures of binaries & Maven artifacts * checked dependency & NOTICE changes * ran TopSpeedWindowing locally Thanks for driving the release, Danny! Good job. Am Di., 23. Aug. 2022 um 04:16 Uhr schrieb Peng Kang : > +1 > > --

Re: [DISCUSS] Releasing Flink 1.15.2

2022-08-23 Thread Konstantin Knauf
Hi Guillaume, as long as those vulnerabilities have not been introduced since Flink 1.15.1, which they haven't, we can proceed with should not block the release. Best, Konstantin Am Di., 23. Aug. 2022 um 10:12 Uhr schrieb Guillaume Vauvert < guillaume.vauvert@gmail.com>: > Hello all, > >

[jira] [Created] (FLINK-29080) Migrate unit and integration tests from managed table to catalog-based tests

2022-08-23 Thread Jane Chan (Jira)
Jane Chan created FLINK-29080: - Summary: Migrate unit and integration tests from managed table to catalog-based tests Key: FLINK-29080 URL: https://issues.apache.org/jira/browse/FLINK-29080 Project:

Re: [DISCUSS] Releasing Flink 1.15.2

2022-08-23 Thread Guillaume Vauvert
Hello all, I am wondering if it is safe to release 1.15.2 despite https://issues.apache.org/jira/browse/FLINK-29065 ? Regards, Guillaume On 8/16/22 12:53, Danny Cranmer wrote: Hello all, I have created a PR [1] to update the documentation to cover the 1.15.x stateful upgrades. Would

[jira] [Created] (FLINK-29079) Add doc for show statement of Hive dialect

2022-08-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-29079: Summary: Add doc for show statement of Hive dialect Key: FLINK-29079 URL: https://issues.apache.org/jira/browse/FLINK-29079 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29078) Add doc for drop statement of Hive dialect

2022-08-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-29078: Summary: Add doc for drop statement of Hive dialect Key: FLINK-29078 URL: https://issues.apache.org/jira/browse/FLINK-29078 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29077) Add doc for creeate statement of Hive dialect

2022-08-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-29077: Summary: Add doc for creeate statement of Hive dialect Key: FLINK-29077 URL: https://issues.apache.org/jira/browse/FLINK-29077 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29076) Add alter doc for Hive dialect

2022-08-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-29076: Summary: Add alter doc for Hive dialect Key: FLINK-29076 URL: https://issues.apache.org/jira/browse/FLINK-29076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29075) RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is not stable

2022-08-23 Thread Jane Chan (Jira)
Jane Chan created FLINK-29075: - Summary: RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is not stable Key: FLINK-29075 URL: https://issues.apache.org/jira/browse/FLINK-29075 Project:

[jira] [Created] (FLINK-29074) use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement"

2022-08-23 Thread xuyang (Jira)
xuyang created FLINK-29074: -- Summary: use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement" Key: FLINK-29074 URL: https://issues.apache.org/jira/browse/FLINK-29074