[jira] [Created] (FLINK-27335) Optimize async compaction in MergeTreeWriter

Jingsong Lee created FLINK-27335: Summary: Optimize async compaction in MergeTreeWriter Key: FLINK-27335 URL: https://issues.apache.org/jira/browse/FLINK-27335 Project: Flink Issue Type:

[jira] [Created] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions

Aitozi created FLINK-27334: -- Summary: Support auto generate the doc for the KubernetesOperatorConfigOptions Key: FLINK-27334 URL: https://issues.apache.org/jira/browse/FLINK-27334 Project: Flink

[VOTE] Release 1.15.0, release candidate #4

Hi everyone, Please review and vote on the release candidate #4 for the version 1.15.0, as follows: [ ] +1, Approve the release[ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

Re: [VOTE] FLIP-214: Support Advanced Function DDL

Thanks for driving this work @Ron, +1 (binding) Best, Jark On Thu, 21 Apr 2022 at 10:42, Mang Zhang wrote: > +1 > > > > > > > > > > > > > > -- > > Best regards, > Mang Zhang > > > > > > At 2022-04-20 18:28:28, "刘大龙" wrote: > >Hi, everyone > > > > > > > > > >I'd like to start a vote on

Re:[VOTE] FLIP-214: Support Advanced Function DDL

+1 -- Best regards, Mang Zhang At 2022-04-20 18:28:28, "刘大龙" wrote: >Hi, everyone > > > > >I'd like to start a vote on FLIP-214: Support Advanced Function DDL [1] which >has been discussed in [2]. > >The vote will be open for at least 72 hours unless there is an objection or

Re: [DISCUSS] FLIP-222: Support full query lifecycle statements in SQL client

ping @Timo @Jark @Shengkai Best, Paul Lam > 2022年4月18日 17:12，Paul Lam 写道： > > Hi team, > > I’d like to start a discussion about FLIP-222 [1], which adds query lifecycle > statements to SQL client. > > Currently, SQL client supports submitting queries (queries in a broad sense, > including

Upgrade flink-filesystems hadoop version to version 3.3.2

Hello, We have a security requirement to client side encrypt flink state for certain flink applications that process sensitive data. Currently, there is no feature that supports this out of the box on AWS S3 backend. One way to do it is to use flink-s3-fs-hadoop compiled against hadoop 3.3.2

Re: Upgrade flink-filesystems hadoop version to version 3.3.2

Hello, With regards to my earlier email and JIRA request : https://issues.apache.org/jira/browse/FLINK-27333 , I have opened a PR for the same: https://github.com/apache/flink/pull/19540 Thanks,

Upgrade flink-filesystems hadoop version to version 3.3.2

Hello, We have a security requirement to client side encrypt flink state for certain flink applications that process sensitive data. Currently, there is no feature that supports this out of the box on AWS S3 backend. One way to do it is to use flink-s3-fs-hadoop compiled against hadoop 3.3.2

[jira] [Created] (FLINK-27333) Upgrade flink-filesystems hadoop version to version 3.3.2

Chinmay Sumant created FLINK-27333: -- Summary: Upgrade flink-filesystems hadoop version to version 3.3.2 Key: FLINK-27333 URL: https://issues.apache.org/jira/browse/FLINK-27333 Project: Flink

[jira] [Created] (FLINK-27332) org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint

Darcy Lin created FLINK-27332: - Summary: org.apache.flink.streaming.api.functions.sink.filesystem.Bucket can't receive completion notification for savepoint Key: FLINK-27332 URL:

[jira] [Created] (FLINK-27331) Support Avro microsecond precision for TIME

Marios Trivyzas created FLINK-27331: --- Summary: Support Avro microsecond precision for TIME Key: FLINK-27331 URL: https://issues.apache.org/jira/browse/FLINK-27331 Project: Flink Issue

Re: [DISCUSS] FLIP-220: Temporal State

Hi Nico, Thanks for your clarification. For the discussion about generalizing Temporal state to sorted map state. I could give some examples of how to use sorted map state in min/max with retract functions. As you know, NavigableMap in java has several APIs like: Map.Entry firstEntry();

[jira] [Created] (FLINK-27330) Why Read File Stream Function Deprecated?

Karthik created FLINK-27330: --- Summary: Why Read File Stream Function Deprecated? Key: FLINK-27330 URL: https://issues.apache.org/jira/browse/FLINK-27330 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-27329) Add default value of replica of JM pod and remove declaring it in example yamls

Biao Geng created FLINK-27329: - Summary: Add default value of replica of JM pod and remove declaring it in example yamls Key: FLINK-27329 URL: https://issues.apache.org/jira/browse/FLINK-27329 Project:

[jira] [Created] (FLINK-27328) Could not resolve ResourceManager address

Viswanath Shanmugam created FLINK-27328: --- Summary: Could not resolve ResourceManager address Key: FLINK-27328 URL: https://issues.apache.org/jira/browse/FLINK-27328 Project: Flink

[jira] [Created] (FLINK-27327) Add description about changing max parallelism explicitly leads to state incompatibility

Hangxiang Yu created FLINK-27327: Summary: Add description about changing max parallelism explicitly leads to state incompatibility Key: FLINK-27327 URL: https://issues.apache.org/jira/browse/FLINK-27327

[jira] [Created] (FLINK-27326) Remove LocalExecutor#createWithFactory

Chesnay Schepler created FLINK-27326: Summary: Remove LocalExecutor#createWithFactory Key: FLINK-27326 URL: https://issues.apache.org/jira/browse/FLINK-27326 Project: Flink Issue Type:

Re: Alertmanager Sink Connector

cc user@, bcc dev@ Hi Dhruv, Yes, this should be totally possible. For 1, I would use a ProcessFunction to buffer the alerts and register timers per alert for the repeated firing (or to clear it from state if it is resolved). From this ProcessFunction you send records to an AlertManagerSink.

[jira] [Created] (FLINK-27325) Remove unnecessary forkCount settings

Chesnay Schepler created FLINK-27325: Summary: Remove unnecessary forkCount settings Key: FLINK-27325 URL: https://issues.apache.org/jira/browse/FLINK-27325 Project: Flink Issue Type:

[jira] [Created] (FLINK-27324) [JUnit5 Migration] Module: flink-rpc-akka-loader

Chesnay Schepler created FLINK-27324: Summary: [JUnit5 Migration] Module: flink-rpc-akka-loader Key: FLINK-27324 URL: https://issues.apache.org/jira/browse/FLINK-27324 Project: Flink

[jira] [Created] (FLINK-27323) [JUnit5 Migration] Module: flink-table-api-java

Sergey Nuyanzin created FLINK-27323: --- Summary: [JUnit5 Migration] Module: flink-table-api-java Key: FLINK-27323 URL: https://issues.apache.org/jira/browse/FLINK-27323 Project: Flink Issue

[VOTE] FLIP-214: Support Advanced Function DDL

Hi, everyone I'd like to start a vote on FLIP-214: Support Advanced Function DDL [1] which has been discussed in [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

[jira] [Created] (FLINK-27322) Add license headers and spotless checks for them

Nico Kruber created FLINK-27322: --- Summary: Add license headers and spotless checks for them Key: FLINK-27322 URL: https://issues.apache.org/jira/browse/FLINK-27322 Project: Flink Issue Type:

[jira] [Created] (FLINK-27321) [JUnit5 Migration] Module: java-ci-tools

Chesnay Schepler created FLINK-27321: Summary: [JUnit5 Migration] Module: java-ci-tools Key: FLINK-27321 URL: https://issues.apache.org/jira/browse/FLINK-27321 Project: Flink Issue Type:

[jira] [Created] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

Zhengqi Zhang created FLINK-27320: - Summary: When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies Key: FLINK-27320 URL: https://issues.apache.org/jira/browse/FLINK-27320

[jira] [Created] (FLINK-27319) Duplicated "-t" option for savepoint format and deployment target

Dawid Wysakowicz created FLINK-27319: Summary: Duplicated "-t" option for savepoint format and deployment target Key: FLINK-27319 URL: https://issues.apache.org/jira/browse/FLINK-27319 Project:

[jira] [Created] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

Zhengqi Zhang created FLINK-27318: - Summary: KafkaSink: when init transaction, it take too long to get a producerId with epoch=0 Key: FLINK-27318 URL: https://issues.apache.org/jira/browse/FLINK-27318

Re: Discuss making KafkaSubscriber Public

Hi all, Just following up on this thread. The subject header may have been misleading--I was proposing to make KafkaSubscriber @PublicEvolving and expose a setter to pass a custom implementation. It seems logical since the KafkaSource is also @PublicEvolving and this lets the user know that the

[jira] [Created] (FLINK-27317) Snapshot deployment fails due to .scalafmt.conf not being found

Chesnay Schepler created FLINK-27317: Summary: Snapshot deployment fails due to .scalafmt.conf not being found Key: FLINK-27317 URL: https://issues.apache.org/jira/browse/FLINK-27317 Project:

[jira] [Created] (FLINK-27316) Prevent users from changing bucket number

Jane Chan created FLINK-27316: - Summary: Prevent users from changing bucket number Key: FLINK-27316 URL: https://issues.apache.org/jira/browse/FLINK-27316 Project: Flink Issue Type: Sub-task