[jira] [Created] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

xiechenling created FLINK-25440: --- Summary: Apache Pulsar Connector Document description error about 'Starting Position'. Key: FLINK-25440 URL: https://issues.apache.org/jira/browse/FLINK-25440 Project:

[jira] [Created] (FLINK-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes

HunterHunter created FLINK-25439: Summary: StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes Key: FLINK-25439 URL: https://issues.apache.org/jira/browse/FLINK-25439

[jira] [Created] (FLINK-25438) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators failed due to topic 'exactlyTopicCustomOperator20' already exists

Yun Tang created FLINK-25438: Summary: KafkaProducerExactlyOnceITCase.testMultipleSinkOperators failed due to topic 'exactlyTopicCustomOperator20' already exists Key: FLINK-25438 URL:

[jira] [Created] (FLINK-25437) Build wheels failed

Huang Xingbo created FLINK-25437: Summary: Build wheels failed Key: FLINK-25437 URL: https://issues.apache.org/jira/browse/FLINK-25437 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-25436) Allow BlobServer/BlobCache to clean up unused blobs after recovering from working directory

Till Rohrmann created FLINK-25436: - Summary: Allow BlobServer/BlobCache to clean up unused blobs after recovering from working directory Key: FLINK-25436 URL: https://issues.apache.org/jira/browse/FLINK-25436

[jira] [Created] (FLINK-25435) Can not read jobmanager/taskmanager.log in yarn-per-job mode.

Moses created FLINK-25435: - Summary: Can not read jobmanager/taskmanager.log in yarn-per-job mode. Key: FLINK-25435 URL: https://issues.apache.org/jira/browse/FLINK-25435 Project: Flink Issue Type:

[jira] [Created] (FLINK-25434) Throw an error when BigDecimal precision overflows.

Ada Wong created FLINK-25434: Summary: Throw an error when BigDecimal precision overflows. Key: FLINK-25434 URL: https://issues.apache.org/jira/browse/FLINK-25434 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25433) Integrate retry strategy for cleanup stage

Matthias Pohl created FLINK-25433: - Summary: Integrate retry strategy for cleanup stage Key: FLINK-25433 URL: https://issues.apache.org/jira/browse/FLINK-25433 Project: Flink Issue Type:

[jira] [Created] (FLINK-25432) Implement cleanup strategy

Matthias Pohl created FLINK-25432: - Summary: Implement cleanup strategy Key: FLINK-25432 URL: https://issues.apache.org/jira/browse/FLINK-25432 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25431) Implement file-based JobResultStore

Matthias Pohl created FLINK-25431: - Summary: Implement file-based JobResultStore Key: FLINK-25431 URL: https://issues.apache.org/jira/browse/FLINK-25431 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25430) Introduce JobResultStore

Matthias Pohl created FLINK-25430: - Summary: Introduce JobResultStore Key: FLINK-25430 URL: https://issues.apache.org/jira/browse/FLINK-25430 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25429) Avoid to close output streams twice during uploading changelogs

Yun Tang created FLINK-25429: Summary: Avoid to close output streams twice during uploading changelogs Key: FLINK-25429 URL: https://issues.apache.org/jira/browse/FLINK-25429 Project: Flink

Re: [ANNOUNCE] Apache Flink Stateful Functions 3.1.1 released

Thanks a lot for being our release manager and swiftly addressing the log4j CVE Igal! Cheers, Till On Wed, Dec 22, 2021 at 5:41 PM Igal Shilman wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink Stateful Functions (StateFun) 3.1.1. > > This is a bugfix

Re: [DISCUSS] Slimmed down docker images.

Hi David, Thanks for starting this discussion. I like the idea of providing smaller images that can be used by more advanced users that don't need everything. Having smaller image sizes can be really helpful when having to pull the image (with your changes this time should roughly be decreased by

Re: [DISCUSS] Changing the minimal supported version of Hadoop

If there are no users strongly objecting to dropping Hadoop support for < 2.8, then I am +1 for this since otherwise we won't gain a lot as Xintong said. Cheers, Till On Wed, Dec 22, 2021 at 10:33 AM David Morávek wrote: > Agreed, if we drop the CI for lower versions, there is actually no

[jira] [Created] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

Till Rohrmann created FLINK-25427: - Summary: SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP Key: FLINK-25427 URL: https://issues.apache.org/jira/browse/FLINK-25427 Project:

[jira] [Created] (FLINK-25428) Expose complex types CAST to String

Francesco Guardiani created FLINK-25428: --- Summary: Expose complex types CAST to String Key: FLINK-25428 URL: https://issues.apache.org/jira/browse/FLINK-25428 Project: Flink Issue

[jira] [Created] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

Till Rohrmann created FLINK-25426: - Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers Key: FLINK-25426 URL:

[jira] [Created] (FLINK-25425) flink sql cassandra connector

sky created FLINK-25425: --- Summary: flink sql cassandra connector Key: FLINK-25425 URL: https://issues.apache.org/jira/browse/FLINK-25425 Project: Flink Issue Type: New Feature Components: