[jira] [Created] (FLINK-35501) Use common thread pools when transferring RocksDB state files

Roman Khachatryan created FLINK-35501: - Summary: Use common thread pools when transferring RocksDB state files Key: FLINK-35501 URL: https://issues.apache.org/jira/browse/FLINK-35501 Project:

Re: [DISCUSS] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

Thanks for this FLIP. We are also interested in learning/contributing to the hybrid shuffle integration with celeborn for batch executions. On Tue, May 28, 2024, 7:07 PM Yuxin Tan wrote: > Hi, Xintong, > > > I think we can also publish the prototype codes so the > community can better

[jira] [Created] (FLINK-35500) DynamoDb SinkWriter fails to delete elements due to key not found

Ahmed Hamdy created FLINK-35500: --- Summary: DynamoDb SinkWriter fails to delete elements due to key not found Key: FLINK-35500 URL: https://issues.apache.org/jira/browse/FLINK-35500 Project: Flink

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

Hi Mate and Gyula, Thank you very much for your clarifications; it is clearer for me now. I agree that a reconciliation condition would be useful – maybe reconciled instead of ready for the boolean, so it is very explicit. Your suggestion of a job related readiness condition related to it’s

[jira] [Created] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

Ryan Skraba created FLINK-35499: --- Summary: EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing Key: FLINK-35499 URL: https://issues.apache.org/jira/browse/FLINK-35499

[jira] [Created] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf

lincoln lee created FLINK-35498: --- Summary: Unexpected argument name conflict error when do extract method params from udf Key: FLINK-35498 URL: https://issues.apache.org/jira/browse/FLINK-35498

[jira] [Created] (FLINK-35497) The wrong enum value was used to get month in timestampDiff

haishui created FLINK-35497: --- Summary: The wrong enum value was used to get month in timestampDiff Key: FLINK-35497 URL: https://issues.apache.org/jira/browse/FLINK-35497 Project: Flink Issue

Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2

-1 (non-binding) blocked by https://issues.apache.org/jira/browse/FLINK-35496. Best, Yuepeng Pan On 2024/05/22 12:13:51 Leonard Xu wrote: > +1 (binding) > > - verified signatures > - verified hashsums > - built from source code with java 1.8 succeeded > - checked Github release tag > -

[jira] [Created] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

RocMarshal created FLINK-35496: -- Summary: The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving Key: FLINK-35496 URL: https://issues.apache.org/jira/browse/FLINK-35496