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

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 P

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

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 t

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

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

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 Component

Energy/performance research questions

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 OS/VM/co

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

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

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

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

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

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 c

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

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 votes.

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

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

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

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

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 Open

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

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 Projec

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

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 Featur

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

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

+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: *OK*

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

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 eventu

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

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 Com

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

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

Re: [DISCUSS] Releasing Flink 1.15.2

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, > > I

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

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

Re: [DISCUSS] Releasing Flink 1.15.2

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 apprec

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

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

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

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

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 Compone

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

Jane Chan created FLINK-29075: - Summary: RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is not stable Key: FLINK-29075 URL: https://issues.apache.org/jira/browse/FLINK-29075 Project: Flink