[jira] [Created] (FLINK-28918) Release Testing: Running Python DataStream jobs in Thread Mode

Huang Xingbo created FLINK-28918: Summary: Release Testing: Running Python DataStream jobs in Thread Mode Key: FLINK-28918 URL: https://issues.apache.org/jira/browse/FLINK-28918 Project: Flink

[jira] [Created] (FLINK-28919) Add built-in generate_series function.

jackylau created FLINK-28919: Summary: Add built-in generate_series function. Key: FLINK-28919 URL: https://issues.apache.org/jira/browse/FLINK-28919 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28920) Release Testing: Running Python DataStream Window Job

Huang Xingbo created FLINK-28920: Summary: Release Testing: Running Python DataStream Window Job Key: FLINK-28920 URL: https://issues.apache.org/jira/browse/FLINK-28920 Project: Flink Issue T

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

Hi Qingsheng, Thanks for the feedback--these are great points to raise. 1. This is something I missed that is now added. More generally, it can locate multiple topics in multiple clusters (1 topic on 1 cluster is the simplest case). 2. The KafkaMetadataService doesn't interact with the KafkaAdmi

[jira] [Created] (FLINK-28921) Optimize the Python DataStream Window Documentation

Huang Xingbo created FLINK-28921: Summary: Optimize the Python DataStream Window Documentation Key: FLINK-28921 URL: https://issues.apache.org/jira/browse/FLINK-28921 Project: Flink Issue Typ

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

5. At startup, GetMetadataUpdateEvent is also used to allow the MultiClusterKafkaSourceReader to get the latest metadata from the enumerator to filter out invalid splits This is how the reader can solve "removing" splits/topics in the startup case. Sorry for the late response, really appreciate yo

[Discuss] KafkaSink making low level components PublicEvolving

Hi devs and community, I would like to discuss making the low level components of the KafkaSink PublicEvolving. It looks like all of the classes are package private apart from the public facing API and classes were put in the same package to make this work. My desire to make at least the KafkaSink

Re: [Discuss] KafkaSink making low level components PublicEvolving

I understand that the 1.16 feature freeze is in place so I propose for these changes to go in the 1.17 release. Best, Mason On Thu, Aug 11, 2022 at 1:20 AM Mason Chen wrote: > Hi devs and community, > > I would like to discuss making the low level components of the KafkaSink > PublicEvolving. I

[jira] [Created] (FLINK-28922) Translate "ORDER BY clause" page into Chinese

Zhuang Liu created FLINK-28922: --- Summary: Translate "ORDER BY clause" page into Chinese Key: FLINK-28922 URL: https://issues.apache.org/jira/browse/FLINK-28922 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-28923) Release Testing: Verify flip-241 completed jobs information enhancement

Xintong Song created FLINK-28923: Summary: Release Testing: Verify flip-241 completed jobs information enhancement Key: FLINK-28923 URL: https://issues.apache.org/jira/browse/FLINK-28923 Project: Fli

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

Hi Rascal, Yes, you got the right answer for these two questions. If you have more questions about using Flink, welcome mailing to user support and questions mailing list: u...@flink.apache.org / user...@flink.apache.org ( https://flink.apache.org/community.html#mailing-lists). This dev maili

[jira] [Created] (FLINK-28924) Translate "LIMIT clause" page into Chinese

Zhuang Liu created FLINK-28924: --- Summary: Translate "LIMIT clause" page into Chinese Key: FLINK-28924 URL: https://issues.apache.org/jira/browse/FLINK-28924 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-28925) Fix the concurrency problem in hybrid shuffle

Weijie Guo created FLINK-28925: -- Summary: Fix the concurrency problem in hybrid shuffle Key: FLINK-28925 URL: https://issues.apache.org/jira/browse/FLINK-28925 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28926) Release Testing: Verify flip-235 hybrid shuffle mode

Weijie Guo created FLINK-28926: -- Summary: Release Testing: Verify flip-235 hybrid shuffle mode Key: FLINK-28926 URL: https://issues.apache.org/jira/browse/FLINK-28926 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

got it, thanks a lot for your help. Lincoln Lee 于2022年8月11日周四 17:29写道： > Hi Rascal, > > Yes, you got the right answer for these two questions. If you have > more questions about using Flink, welcome mailing to user support and > questions mailing list: u...@flink.apache.org / user...@flink.

[jira] [Created] (FLINK-28927) When the checkpoint times out, the uploaded shared files are not cleaned up

ChangjiGuo created FLINK-28927: -- Summary: When the checkpoint times out, the uploaded shared files are not cleaned up Key: FLINK-28927 URL: https://issues.apache.org/jira/browse/FLINK-28927 Project: Flin

[DISCUSS] Releasing Flink 1.15.2

Hello all, I would like to start discussing the release of Flink 1.15.2. Flink 1.15.1 was released on 6th July [1] and we have resolved 31 issues since then [2]. During the Flink 1.15.1 vote [3] we identified one blocker [4] and one critical issue [5] that should be fixed soon after. We also have

Re: [DISCUSS] Releasing Flink 1.15.2

I think that's a good idea; a user in the Flink slack was asking for it just yesterday. About FLINK-28861, let's wait a day or something because there should be PR very soon. It's perfectly fine for you to be the release manager; I can help you out with things with that require PMC permissio

[jira] [Created] (FLINK-28928) Add E2E test for hybrid shuffle mode

Weijie Guo created FLINK-28928: -- Summary: Add E2E test for hybrid shuffle mode Key: FLINK-28928 URL: https://issues.apache.org/jira/browse/FLINK-28928 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-28929) Add built-in datediff function.

jackylau created FLINK-28929: Summary: Add built-in datediff function. Key: FLINK-28929 URL: https://issues.apache.org/jira/browse/FLINK-28929 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-28930) Add "What is Flink Table Store?" link to flink website

Nicholas Jiang created FLINK-28930: -- Summary: Add "What is Flink Table Store?" link to flink website Key: FLINK-28930 URL: https://issues.apache.org/jira/browse/FLINK-28930 Project: Flink Is

[jira] [Created] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

Roman Khachatryan created FLINK-28931: - Summary: BlockingPartitionBenchmark doesn't compile Key: FLINK-28931 URL: https://issues.apache.org/jira/browse/FLINK-28931 Project: Flink Issue Ty

[jira] [Created] (FLINK-28932) Use Builder#withConfiguration instead of deprecated EnvironmentSettings#fromConfiguration

Sergey Nuyanzin created FLINK-28932: --- Summary: Use Builder#withConfiguration instead of deprecated EnvironmentSettings#fromConfiguration Key: FLINK-28932 URL: https://issues.apache.org/jira/browse/FLINK-28932

[flink-connector-elasticsearch] Supporting ElasticSearch 8 & Dropping ES 6 ?

Hi, I was building something that puts data in ES and found that the current connector is not compatible with an ES 8 cluster. I found that - The currently employed `RestHighLevelClient` has been deprecated by Elastic . - There is an `ApiCompatibilityMode` you can use in the latest ES 7 RestHighL

[jira] [Created] (FLINK-28933) Support ON CONFLICT DO NOTHING in flink-jdbc-connector

Nir Tsruya created FLINK-28933: -- Summary: Support ON CONFLICT DO NOTHING in flink-jdbc-connector Key: FLINK-28933 URL: https://issues.apache.org/jira/browse/FLINK-28933 Project: Flink Issue Type

[jira] [Created] (FLINK-28934) Pulsar Source put all the splits to only one parallelism when using Exclusive subscription

Yufan Sheng created FLINK-28934: --- Summary: Pulsar Source put all the splits to only one parallelism when using Exclusive subscription Key: FLINK-28934 URL: https://issues.apache.org/jira/browse/FLINK-28934

[jira] [Created] (FLINK-28935) Calcite -test.jar are no longer published, use calcite-testkit instead

Sergey Nuyanzin created FLINK-28935: --- Summary: Calcite -test.jar are no longer published, use calcite-testkit instead Key: FLINK-28935 URL: https://issues.apache.org/jira/browse/FLINK-28935 Project:

Re: [DISCUSS] Releasing Flink 1.15.2

Hi Danny, Thanks for driving the release. +1 for the 1.15.2 release. Best, Xingbo Chesnay Schepler 于2022年8月11日周四 20:06写道： > I think that's a good idea; a user in the Flink slack was asking for it > just yesterday. > > About FLINK-28861, let's wait a day or something because there should be > P

[jira] [Created] (FLINK-28936) Fix RSET endpoint can not serialize CHAR(0)

Shengkai Fang created FLINK-28936: - Summary: Fix RSET endpoint can not serialize CHAR(0) Key: FLINK-28936 URL: https://issues.apache.org/jira/browse/FLINK-28936 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28937) Add doc for SqlGateway

Shengkai Fang created FLINK-28937: - Summary: Add doc for SqlGateway Key: FLINK-28937 URL: https://issues.apache.org/jira/browse/FLINK-28937 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-28938) Fix HiveServer2 Endpoint can not set variable correctly

Shengkai Fang created FLINK-28938: - Summary: Fix HiveServer2 Endpoint can not set variable correctly Key: FLINK-28938 URL: https://issues.apache.org/jira/browse/FLINK-28938 Project: Flink Iss

[jira] [Created] (FLINK-28940) Release Testing: Verify FLIP-248 Dynamic Partition Prunning

godfrey he created FLINK-28940: -- Summary: Release Testing: Verify FLIP-248 Dynamic Partition Prunning Key: FLINK-28940 URL: https://issues.apache.org/jira/browse/FLINK-28940 Project: Flink Issu

[jira] [Created] (FLINK-28939) Release Testing: Verify FLIP-241 ANALYZE TABLE

godfrey he created FLINK-28939: -- Summary: Release Testing: Verify FLIP-241 ANALYZE TABLE Key: FLINK-28939 URL: https://issues.apache.org/jira/browse/FLINK-28939 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

Yunfeng Zhou created FLINK-28941: Summary: Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case Key: FLINK-28941 URL: https://issues.apache.org/jira/browse/FLINK-28941 Project: F

[jira] [Created] (FLINK-28942) Deadlock may occurs when releasing readers for SortMergeResultPartition

Yuxin Tan created FLINK-28942: - Summary: Deadlock may occurs when releasing readers for SortMergeResultPartition Key: FLINK-28942 URL: https://issues.apache.org/jira/browse/FLINK-28942 Project: Flink

[jira] [Created] (FLINK-28943) Add Transformer and Estimator for MaxAbsScaler

weibo zhao created FLINK-28943: -- Summary: Add Transformer and Estimator for MaxAbsScaler Key: FLINK-28943 URL: https://issues.apache.org/jira/browse/FLINK-28943 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-28944) Optimize the Python Execution Mode Documentation

Huang Xingbo created FLINK-28944: Summary: Optimize the Python Execution Mode Documentation Key: FLINK-28944 URL: https://issues.apache.org/jira/browse/FLINK-28944 Project: Flink Issue Type: