[DISCUSS] Preview release for Flink Kubernetes Operator

Hi Team! I would like to discuss the timeline for the initial preview/milestone release of the flink-kubernetes-operator project. The last few weeks we have been working very hard with the community to stabilize the initial feature set and I

[jira] [Created] (FLINK-26616) AdaptiveSchedulerITCase.testExceptionHistoryIsRetrievableFromTheRestAPI failed with a timeout

Matthias Pohl created FLINK-26616: - Summary: AdaptiveSchedulerITCase.testExceptionHistoryIsRetrievableFromTheRestAPI failed with a timeout Key: FLINK-26616 URL: https://issues.apache.org/jira/browse/FLINK-26616

[jira] [Created] (FLINK-26615) BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout fails on azure

Roman Khachatryan created FLINK-26615: - Summary: BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout fails on azure Key: FLINK-26615 URL: https://issues.apache.org/jira/browse/FLINK-26615

[jira] [Created] (FLINK-26614) Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets

Ning Ma created FLINK-26614: --- Summary: Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets Key: FLINK-26614 URL: https://issues.apache.org/jira/browse/FLINK-26614 Project:

Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser

Congrats Martijn!! Best, Marios On Thu, Mar 10, 2022 at 4:50 PM yu'an huang wrote: > Congrats, Martijn! > > > Best > Yuan > > > > On 3 Mar 2022, at 11:49 PM, Robert Metzger wrote: > > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Martijn Visser as a new > > Flink

[jira] [Created] (FLINK-26613) Stateful unified Sink V2 upgrades only work when operator uids are given

Fabian Paul created FLINK-26613: --- Summary: Stateful unified Sink V2 upgrades only work when operator uids are given Key: FLINK-26613 URL: https://issues.apache.org/jira/browse/FLINK-26613 Project:

[jira] [Created] (FLINK-26612) Create docs webpages like other Flink projects

Gyula Fora created FLINK-26612: -- Summary: Create docs webpages like other Flink projects Key: FLINK-26612 URL: https://issues.apache.org/jira/browse/FLINK-26612 Project: Flink Issue Type:

[jira] [Created] (FLINK-26611) Generate documentation for OperatorConfigOptions

Gyula Fora created FLINK-26611: -- Summary: Generate documentation for OperatorConfigOptions Key: FLINK-26611 URL: https://issues.apache.org/jira/browse/FLINK-26611 Project: Flink Issue Type:

Re: Add libatomic1 to flink image

Moving dev@ to bcc, adding user@ Hi Julius, the recommended approach would be to build your own Docker images from the official images along the lines of FROM apache/flink:1.14.3 RUN apt-get install -y libatomic1 Cheers, Konstantin On Fri, Mar 11, 2022 at 11:07 AM Almeida, Julius wrote: >

Re: Flink 1.15 Stabilisation Sync skipped tomorrow

Any news on the branch cut? The listed jira-s are closed as I see. G On Tue, Mar 8, 2022 at 3:02 PM Galen Warren wrote: > You're welcome. Fwiw, I've also run through testing steps on my > contribution -- [FLINK-26451] Test GCS FileSystem w/ RecoverableWriter > manually - ASF JIRA (apache.org)

[jira] [Created] (FLINK-26610) FileSink can not upgrade from 1.13 if the uid of the origin sink is not set.

Gen Luo created FLINK-26610: --- Summary: FileSink can not upgrade from 1.13 if the uid of the origin sink is not set. Key: FLINK-26610 URL: https://issues.apache.org/jira/browse/FLINK-26610 Project: Flink

Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

Hi Jacky, I think it’s a very useful feature, can get flame graph easily and avoid run script personally. But I think can package async-profiler library into flink, and use JNI execute the profiling, doesn’t depend on local environment. We did this way in out internal version, and provide api to

[jira] [Created] (FLINK-26608) Add a "sum" operator In PyFlink KeyedStream API

CaoYu created FLINK-26608: - Summary: Add a "sum" operator In PyFlink KeyedStream API Key: FLINK-26608 URL: https://issues.apache.org/jira/browse/FLINK-26608 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26609) Add a "sum" operator In PyFlink KeyedStream API

CaoYu created FLINK-26609: - Summary: Add a "sum" operator In PyFlink KeyedStream API Key: FLINK-26609 URL: https://issues.apache.org/jira/browse/FLINK-26609 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26607) There are multiple MAX_LONG_VALUE value errors in pyflink code

zhangjingcun created FLINK-26607: Summary: There are multiple MAX_LONG_VALUE value errors in pyflink code Key: FLINK-26607 URL: https://issues.apache.org/jira/browse/FLINK-26607 Project: Flink

[jira] [Created] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

Matthias Pohl created FLINK-26606: - Summary: CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore Key: FLINK-26606 URL: https://issues.apache.org/jira/browse/FLINK-26606

[jira] [Created] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

Yang Wang created FLINK-26605: - Summary: JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status Key: FLINK-26605 URL: https://issues.apache.org/jira/browse/FLINK-26605

Add libatomic1 to flink image

Hi Developers, I wish to add a new library to existing flink docker image since it’s a dependency requirement in my processor. Is it possible to add? apt-get install libatomic1 Thanks, Julius

[jira] [Created] (FLINK-26604) update AvroParquet format user-facing document

Jing Ge created FLINK-26604: --- Summary: update AvroParquet format user-facing document Key: FLINK-26604 URL: https://issues.apache.org/jira/browse/FLINK-26604 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

luoyuxia created FLINK-26603: Summary: [Umbrella] Decouple Hive with Flink itself Key: FLINK-26603 URL: https://issues.apache.org/jira/browse/FLINK-26603 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26602) The Rocksdb task failed savepoint, and then checkpoint failed several times

liuchenhong created FLINK-26602: --- Summary: The Rocksdb task failed savepoint, and then checkpoint failed several times Key: FLINK-26602 URL: https://issues.apache.org/jira/browse/FLINK-26602 Project:

Re: [RESULT] [VOTE] Release 1.14.4, release candidate #1

Thanks to all the testers and Konstantin for driving the release! Best regards, Martijn Visser https://twitter.com/MartijnVisser82 On Fri, 11 Mar 2022 at 09:36, Konstantin Knauf wrote: > Hi everyone, > > I am pleased to announce that we have unanimously approved this release > candidate: > >

[RESULT] [VOTE] Release 1.14.4, release candidate #1

Hi everyone, I am pleased to announce that we have unanimously approved this release candidate: There are 5 approving votes, 3 of which are binding: - Seth Wiesman (non-binding) - Yun Tang (non-binding) - Yun Gao (binding) - Timo Walther (binding) - Konstantin Knauf (binding) There are no

Re: [VOTE] Release 1.14.4, release candidate #1

+1 (binding) - checked signatures and checksums of binaries OK - build from sources - checked for suspicious changes in pom.xml between 1.14.3 and 1.14.4 - ran examples/python/table/batch/word_count.py in a local mini cluster - ran examples/python/table/batch/word_count.py against standalone