Re: Frequent Flink JM restarts due to Kube API server errors.

2024-02-05 Thread Yang Wang
This might be related with FLINK-28481, which is a bug in fabric8io k8s client. [1]. https://issues.apache.org/jira/browse/FLINK-28481 Best, Yang On Tue, Feb 6, 2024 at 12:30 PM Lavkesh Lahngir wrote: > Hi, Matthias, I was wondering if there are any timeout or heartbeat > configurations for Ku

[jira] [Created] (FLINK-34384) Release Testing: Verify FLINK-33735 Improve the exponential-delay restart-strategy

2024-02-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-34384: --- Summary: Release Testing: Verify FLINK-33735 Improve the exponential-delay restart-strategy Key: FLINK-34384 URL: https://issues.apache.org/jira/browse/FLINK-34384 Pro

[jira] [Created] (FLINK-34383) Modify the comment with incorrect syntax

2024-02-05 Thread li you (Jira)
li you created FLINK-34383: -- Summary: Modify the comment with incorrect syntax Key: FLINK-34383 URL: https://issues.apache.org/jira/browse/FLINK-34383 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34382) Release Testing: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded

2024-02-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-34382: --- Summary: Release Testing: Verify FLINK-33625 Support System out and err to be redirected to LOG or discarded Key: FLINK-34382 URL: https://issues.apache.org/jira/browse/FLINK-34382

[jira] [Created] (FLINK-34381) `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34381: -- Summary: `RelDataType#getFullTypeString` should be used to print in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString` Key: FLINK-34381 URL: https://issues.apache.org/j

Re: 退订

2024-02-05 Thread Hang Ruan
Hi, 请分别发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 和 dev-unsubscr...@flink.apache.org 地址来取消订阅来自 user...@flink.apache.org 和 dev@flink.apache.org 邮件组的邮件,你可以参考[1][2] 管理你的邮件订阅。 Please send email to user-zh-unsubscr...@flink.apache.org and dev-unsubscr...@flink.apache.org if you want to unsubscrib

[jira] [Created] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34380: -- Summary: Strange RowKind and records about intermediate output when using minibatch join Key: FLINK-34380 URL: https://issues.apache.org/jira/browse/FLINK-34380 Project: Flink

[jira] [Created] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-02-05 Thread zhu (Jira)
zhu created FLINK-34379: --- Summary: table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError Key: FLINK-34379 URL: https://issues.apache.org/jira/browse/FLINK-34379 Project: Flink Issue Type:

Re: Frequent Flink JM restarts due to Kube API server errors.

2024-02-05 Thread Lavkesh Lahngir
Hi, Matthias, I was wondering if there are any timeout or heartbeat configurations for KubeHA available. Thanks. On Mon, 5 Feb 2024 at 8:58 PM, Matthias Pohl wrote: > That's stated in the Jira issue. I didn't have the time to investigate it > further. > > On Mon, Feb 5, 2024 at 1:55 PM Lavkesh

[jira] [Created] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34378: -- Summary: Minibatch join disrupted the original order of input records Key: FLINK-34378 URL: https://issues.apache.org/jira/browse/FLINK-34378 Project: Flink Issue Type:

[jira] [Created] (FLINK-34377) Release Testing : Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread Junrui Li (Jira)
Junrui Li created FLINK-34377: - Summary: Release Testing : Verify FLINK-33297 Support standard YAML for FLINK configuration Key: FLINK-34377 URL: https://issues.apache.org/jira/browse/FLINK-34377 Project:

[jira] [Created] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-34376: - Summary: FLINK SQL SUM() causes a precision error Key: FLINK-34376 URL: https://issues.apache.org/jira/browse/FLINK-34376 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34375) Complete work for syntax `DESCRIBE EXTENDED tableName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34375: -- Summary: Complete work for syntax `DESCRIBE EXTENDED tableName` Key: FLINK-34375 URL: https://issues.apache.org/jira/browse/FLINK-34375 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-34374) Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34374: -- Summary: Complete work for syntax `DESCRIBE EXTENDED DATABASE databaseName` Key: FLINK-34374 URL: https://issues.apache.org/jira/browse/FLINK-34374 Project: Flink Issue

[jira] [Created] (FLINK-34373) Complete work for syntax `DESCRIBE DATABASE databaseName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34373: -- Summary: Complete work for syntax `DESCRIBE DATABASE databaseName` Key: FLINK-34373 URL: https://issues.apache.org/jira/browse/FLINK-34373 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34372) Complete work for syntax `DESCRIBE CATALOG catalogName`

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34372: -- Summary: Complete work for syntax `DESCRIBE CATALOG catalogName` Key: FLINK-34372 URL: https://issues.apache.org/jira/browse/FLINK-34372 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-05 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-34371: Summary: FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment Key: FLINK-34371 URL: https://issues.apache.org/jira/

[DISCUSS] Flink aggregate push down is not user-friendly.

2024-02-05 Thread yh z
Hi, Devs, When I try to develop a new connector, which support aggregate push down. I found that Flink aggregate pushdown is not user-friendly. The `AggregateExpression` passed to the connector by `SupportsAggregatePushDown#applyAggregates` doesn't provide access to subclasses. This makes it i

[jira] [Created] (FLINK-34370) [Umbrella] Complete work about enhanced Flink SQL DDL

2024-02-05 Thread xuyang (Jira)
xuyang created FLINK-34370: -- Summary: [Umbrella] Complete work about enhanced Flink SQL DDL Key: FLINK-34370 URL: https://issues.apache.org/jira/browse/FLINK-34370 Project: Flink Issue Type: Improv

jira permission request

2024-02-05 Thread 李游
HI, I want to contribute to Apache flink. Would you please give me the contributor permission? My jira id is lxliyou. Thanks.

Re: [DISCUSS] FLIP-417: Expose JobManagerOperatorMetrics via REST API

2024-02-05 Thread Mason Chen
Hi all, Alex (cc'ed) and I discussed offline about the endpoint path and making it easier to use. Focusing on the main clients of the Flink Metrics REST API, the Flink UI and Flink Kubernetes Operator, we determined that exposing the operator id is unnecessary. There are few considerations: 1. In

[jira] [Created] (FLINK-34369) Elasticsearch connector supports SSL provider

2024-02-05 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34369: - Summary: Elasticsearch connector supports SSL provider Key: FLINK-34369 URL: https://issues.apache.org/jira/browse/FLINK-34369 Project: Flink Issue Type: I

[jira] [Created] (FLINK-34368) Update GCS filesystems to latest available version v3.0

2024-02-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34368: -- Summary: Update GCS filesystems to latest available version v3.0 Key: FLINK-34368 URL: https://issues.apache.org/jira/browse/FLINK-34368 Project: Flink I

[DISCUSS] Kubernetes Operator 1.8.0 release planning

2024-02-05 Thread Gyula Fóra
Hi all! I would like to kick off the release planning for the operator 1.8.0 release. The last operator release was November 22 last year. Since then we have added a number of fixes and improvements to both the operator and the autoscaler logic. There are a few outstanding PRs currently, includin

[jira] [Created] (FLINK-34367) Release Testing Instructions: Verify FLINK-34027 AsyncScalarFunction for asynchronous scalar function support

2024-02-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-34367: --- Summary: Release Testing Instructions: Verify FLINK-34027 AsyncScalarFunction for asynchronous scalar function support Key: FLINK-34367 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-34366) Add support to group rows by column ordinals

2024-02-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34366: -- Summary: Add support to group rows by column ordinals Key: FLINK-34366 URL: https://issues.apache.org/jira/browse/FLINK-34366 Project: Flink Issue Type:

[jira] [Created] (FLINK-34365) [docs] Delete repeated pages in Chinese Flink website and correct the Paimon url

2024-02-05 Thread Waterking (Jira)
Waterking created FLINK-34365: - Summary: [docs] Delete repeated pages in Chinese Flink website and correct the Paimon url Key: FLINK-34365 URL: https://issues.apache.org/jira/browse/FLINK-34365 Project: F

Re: Frequent Flink JM restarts due to Kube API server errors.

2024-02-05 Thread Matthias Pohl
That's stated in the Jira issue. I didn't have the time to investigate it further. On Mon, Feb 5, 2024 at 1:55 PM Lavkesh Lahngir wrote: > Hi Matthias, > Thanks for the suggestion. Do we know which part of code caused this issue > and how it was fixed? > > Thanks! > > On Mon, 5 Feb 2024 at 18:06

Re: Frequent Flink JM restarts due to Kube API server errors.

2024-02-05 Thread Lavkesh Lahngir
Hi Matthias, Thanks for the suggestion. Do we know which part of code caused this issue and how it was fixed? Thanks! On Mon, 5 Feb 2024 at 18:06, Matthias Pohl wrote: > Hi Lavkesh, > FLINK-33998 [1] sounds quite similar to what you describe. > > The solution was to upgrade to Flink version 1.1

[RESULT][VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-05 Thread Xuannan Su
Hi devs, I'm happy to announce that FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment [1] has been accepted with 6 approving votes (4 binding) [2]: - Xintong Song (binding) - Rui Fan (binding) - Weijie Guo (binding) - Dong Lin (bi

Re: [VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-05 Thread Xuannan Su
Hi all, Thank you all! Closing the vote. The result will be announced in a separate email. Best regards, Xuannan On Mon, Feb 5, 2024 at 12:11 PM Yuxin Tan wrote: > > +1 (non-binding) > > Best, > Yuxin > > > Hang Ruan 于2024年2月5日周一 11:22写道: > > > +1 (non-binding) > > > > Best, > > Hang > > > >

Re: [VOTE] Release flink-connector-parent, release candidate #1

2024-02-05 Thread Etienne Chauchot
Hi, I just got back from vacations. I'll close the vote thread and proceed to the release later this week. Here is the ticket: https://issues.apache.org/jira/browse/FLINK-34364 Best Etienne Le 04/02/2024 à 05:06, Qingsheng Ren a écrit : +1 (binding) - Verified checksum and signature - Ver

[jira] [Created] (FLINK-34364) stage_source_release.sh should exclude tools/release directory from the source release

2024-02-05 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34364: Summary: stage_source_release.sh should exclude tools/release directory from the source release Key: FLINK-34364 URL: https://issues.apache.org/jira/browse/FLINK-34364

[jira] [Created] (FLINK-34363) Connectors release utils should allow to not specify flink version in stage_jars.sh

2024-02-05 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34363: Summary: Connectors release utils should allow to not specify flink version in stage_jars.sh Key: FLINK-34363 URL: https://issues.apache.org/jira/browse/FLINK-34363

Re: Frequent Flink JM restarts due to Kube API server errors.

2024-02-05 Thread Matthias Pohl
Hi Lavkesh, FLINK-33998 [1] sounds quite similar to what you describe. The solution was to upgrade to Flink version 1.14.6. I didn't have the capacity to look into the details considering that the mentioned Flink version 1.14 is not officially supported by the community anymore and a fix seems to

Re: [ANNOUNCE] Flink 1.19 feature freeze & sync summary on 01/30/2024

2024-02-05 Thread Lincoln Lee
Thanks to Xintong for clarifying this! @Rui Due to the rules of feature freeze: "Only bug fixes and documentation changes are allowed."[1], your merge request has been discussed among 1.19 RMs, we also agree that do not merge these PRs which are purely cleanup work and no more benefits for users.

[jira] [Created] (FLINK-34362) Add argument to reuse connector docs cache in setup_docs.sh to improve build times

2024-02-05 Thread Jane Chan (Jira)
Jane Chan created FLINK-34362: - Summary: Add argument to reuse connector docs cache in setup_docs.sh to improve build times Key: FLINK-34362 URL: https://issues.apache.org/jira/browse/FLINK-34362 Project:

[jira] [Created] (FLINK-34361) PyFlink end-to-end test fails in GHA

2024-02-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34361: - Summary: PyFlink end-to-end test fails in GHA Key: FLINK-34361 URL: https://issues.apache.org/jira/browse/FLINK-34361 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34360: - Summary: GHA e2e test failure due to no space left on device error Key: FLINK-34360 URL: https://issues.apache.org/jira/browse/FLINK-34360 Project: Flink I