[jira] [Created] (FLINK-35488) DataType Support Geometry Type

2024-05-29 Thread Leopold (Jira)
Leopold created FLINK-35488: --- Summary: DataType Support Geometry Type Key: FLINK-35488 URL: https://issues.apache.org/jira/browse/FLINK-35488 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35487) ContinuousFileProcessingCheckpointITCase crashed as process exit with code 127

2024-05-29 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35487: -- Summary: ContinuousFileProcessingCheckpointITCase crashed as process exit with code 127 Key: FLINK-35487 URL: https://issues.apache.org/jira/browse/FLINK-35487 Project:

[jira] [Created] (FLINK-35486) Potential sql expression generation issues on SQL gateway

2024-05-29 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-35486: --- Summary: Potential sql expression generation issues on SQL gateway Key: FLINK-35486 URL: https://issues.apache.org/jira/browse/FLINK-35486 Project: Flink

[jira] [Created] (FLINK-35485) JobMaster failed with "the job xx has not been finished"

2024-05-29 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-35485: --- Summary: JobMaster failed with "the job xx has not been finished" Key: FLINK-35485 URL: https://issues.apache.org/jira/browse/FLINK-35485 Project: Flink Issue

[jira] [Created] (FLINK-35484) Flink Document document file had removed but website can access

2024-05-29 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35484: --- Summary: Flink Document document file had removed but website can access Key: FLINK-35484 URL: https://issues.apache.org/jira/browse/FLINK-35484 Project: Flink

Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1

2024-05-29 Thread Yuepeng Pan
+1 (non-binding) - Built from source code with JDK 1.8 on MaxOS- Run examples locally.- Checked release notes Best, Yuepeng Pan At 2024-05-28 22:53:10, "gongzhongqiang" wrote: >+1(non-binding) > >- Verified signatures and hash sums >- Reviewed the web PR >- Built from source code with JDK 1.8

[jira] [Created] (FLINK-35483) BatchJobRecoveryTest.testRecoverFromJMFailover produced no output for 900 second

2024-05-29 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35483: -- Summary: BatchJobRecoveryTest.testRecoverFromJMFailover produced no output for 900 second Key: FLINK-35483 URL: https://issues.apache.org/jira/browse/FLINK-35483

Re: [DISCUSS] Flink CDC 3.1.1 Release

2024-05-29 Thread gongzhongqiang
+1 Thanks Xiqian. Best, Zhongqiang Gong Xiqian YU 于2024年5月28日周二 19:44写道: > Hi devs, > > I would like to make a proposal about creating a new Flink CDC 3.1 patch > release (3.1.1). It’s been a week since the last CDC version 3.1.0 got > released [1], and since then, 7 tickets have been closed,

[jira] [Created] (FLINK-35482) ParquetInt64TimestampReaderTest unit tests fail due to system timezone

2024-05-29 Thread Rob Young (Jira)
Rob Young created FLINK-35482: - Summary: ParquetInt64TimestampReaderTest unit tests fail due to system timezone Key: FLINK-35482 URL: https://issues.apache.org/jira/browse/FLINK-35482 Project: Flink

RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD

2024-05-29 Thread David Radley
Hi Gyula, Thank you for the quick response and confirmation we need a Flip. I am not an expert at K8s, Lajith will answer in more detail. Some questions I had anyway: I assume each of the ResourceLifecycleState do have a corresponding jobReady status. You point out some mistakes in the table,

Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD

2024-05-29 Thread Gyula Fóra
Hi David! This change definitely warrants a FLIP even if the code change is not huge, there are quite some implications going forward. Looping in @morh...@apache.org for this discussion. I have some questions / suggestions regarding the condition's meaning and naming. In your proposal you

Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD

2024-05-29 Thread David Radley
Hi, Thanks Lajith for raising this discussion thread under the Flip title. To summarise the concerns from the other discussion thread. “ - I echo Gyula that including some examples and further explanations might ease reader's work. With the current version, the FLIP is a bit hard to follow. -

Re: [DISCUSS] Add Flink CDC Channel to Apache Flink Slack Workspace

2024-05-29 Thread Ahmed Hamdy
Thanks Zhongqiang, +1 for sure. Best Regards Ahmed Hamdy On Wed, 29 May 2024 at 13:48, ConradJam wrote: > +1 best > > Hang Ruan 于2024年5月29日周三 11:28写道: > > > Hi, zhongqiang. > > > > Thanks for the proposal. +1 for it. > > > > Best, > > Hang > > > > Leonard Xu 于2024年5月28日周二 11:58写道: > > > > >

[jira] [Created] (FLINK-35481) Add HISTOGRAM function in SQL & Table API

2024-05-29 Thread Ufuk Celebi (Jira)
Ufuk Celebi created FLINK-35481: --- Summary: Add HISTOGRAM function in SQL & Table API Key: FLINK-35481 URL: https://issues.apache.org/jira/browse/FLINK-35481 Project: Flink Issue Type:

[jira] [Created] (FLINK-35480) Add FIELD function in SQL & Table API

2024-05-29 Thread Ufuk Celebi (Jira)
Ufuk Celebi created FLINK-35480: --- Summary: Add FIELD function in SQL & Table API Key: FLINK-35480 URL: https://issues.apache.org/jira/browse/FLINK-35480 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Add Flink CDC Channel to Apache Flink Slack Workspace

2024-05-29 Thread ConradJam
+1 best Hang Ruan 于2024年5月29日周三 11:28写道: > Hi, zhongqiang. > > Thanks for the proposal. +1 for it. > > Best, > Hang > > Leonard Xu 于2024年5月28日周二 11:58写道: > > > > > Thanks Zhongqiang for the proposal, we need the Channel and I should have > > been created it but not yet, +1 from my side. > > >

[DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD

2024-05-29 Thread Lajith Koova
Hello , Discussion thread here: https://lists.apache.org/thread/dvy8w17pyjv68c3t962w49frl9odoz4z to discuss a proposal to add Conditions field in the CR status of Flink Deployment and FlinkSessionJob. Note : Starting this new thread as discussion thread title has been modified to follow the

[jira] [Created] (FLINK-35479) Add end-to-end test for materialized table

2024-05-29 Thread Feng Jin (Jira)
Feng Jin created FLINK-35479: Summary: Add end-to-end test for materialized table Key: FLINK-35479 URL: https://issues.apache.org/jira/browse/FLINK-35479 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0

2024-05-29 Thread Mate Czagany
Hi Ferenc, Thanks for the FLIP, +1 from me for the proposal. I think these changes would be a great solution to all the confusion that comes from these two action parameters. Best regards, Mate Ferenc Csaky ezt írta (időpont: 2024. máj. 28., K, 16:13): > Thank you Xintong for your input. > >

RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-05-29 Thread David Radley
Hi Danny, Thank you for your feedback on this. I agree that using maps has pros and cons. The maps are flexible, but do require the sender and receiver to know what is in the map. When you say “That sounds like it would fit in better, I assume we cannot just take that approach?” The motivation

Re: [DISCUSS] Flink CDC 3.1.1 Release

2024-05-29 Thread Muhammet Orazov
Thanks Xiqian, It is good idea thanks, +1 Best, Muhammet On 2024-05-28 11:43, Xiqian YU wrote: Hi devs, I would like to make a proposal about creating a new Flink CDC 3.1 patch release (3.1.1). It’s been a week since the last CDC version 3.1.0 got released [1], and since then, 7 tickets

[DISCUSS] Flink CEP: to add processing of unmatched events

2024-05-29 Thread Anton Sidorov
Hello. Early I asked how can I get access to unmatched events in CEP Pattern ( https://lists.apache.org/thread/p7n507jvm5hw0xmpoh0lcf87gf3yk18p). Unfortunately Biao Geng answered me, that "that currently there is no such API to access the middle NFA state". I have reviewed the realization of