issues  

Messages by Thread

• • Re: [PR] [hotfix] Typo fix [flink-connector-http] via GitHub
• [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
  • Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
• [jira] [Updated] (FLINK-39163) Support ML_PREDICT in Flink Python API ASF GitHub Bot (Jira)
• [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
• [jira] [Commented] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content. Yuepeng Pan (Jira)
• Re: [PR] [FLINK-37485][starrocks] Add support for TIME type [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37485][starrocks] Add support for TIME type [flink-cdc] via GitHub
• Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• [PR] [infra] Support python 3.12. [flink-agents] via GitHub
  • Re: [PR] [infra] Support python 3.12. [flink-agents] via GitHub
  • Re: [PR] [infra] Support python 3.12. [flink-agents] via GitHub
• [I] [Feature] Support python 3.12 [flink-agents] via GitHub
  • Re: [I] [Feature] Support python 3.12 [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure ASF GitHub Bot (Jira)
• [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39179) Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing failure MengHui Yu (Jira)
• Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
  • Re: [PR] [FLINK-38974][runtime] Handle jobs in running applications during HA recovery [flink] via GitHub
• Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
  • Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
• Re: [PR] [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval [flink] via GitHub
• Re: [PR] [FLINK-39021][Deployment/Kubernetes] Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments [flink] via GitHub
• Re: [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink] via GitHub
  • Re: [PR] [FLINK-39051][Table SQL/Planner] Support APPROX_COUNT_DISTINCT aggregate function in streaming mode with Window TVF [flink] via GitHub
• [jira] [Closed] (FLINK-38977) Expose exceptions for applications Zhu Zhu (Jira)
• Re: [PR] [FLINK-39175][table-planner] Allow calc that contains non-deterministic func to consume duplicate changes [flink] via GitHub
• [jira] [Updated] (FLINK-39178) Support cascaded delta join Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39178) Support cascaded delta join Xuyang Zhong (Jira)
• [jira] [Updated] (FLINK-39174) Support lookup join after delta join ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39174) Support lookup join after delta join Xuyang Zhong (Jira)
• Re: [PR] [FLINK-39174][table-planner] Support lookup join after delta join [flink] via GitHub
• [jira] [Created] (FLINK-39178) Support cascaded delta join Xuyang Zhong (Jira)
• Re: [I] [Feature] Support OpenAI latest Response API [flink-agents] via GitHub
• [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Closed] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit Zhu Zhu (Jira)
• Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37837][core] Always add create.table to include.schema.changes option [flink-cdc] via GitHub
• Re: [PR] Add Node.js CI workflow for testing [flink-web] via GitHub
• Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
  • Re: [PR] [FLINK-38342][runtime] Support record rescale information. [flink] via GitHub
• [jira] [Assigned] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
  • [jira] [Commented] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
• [jira] [Comment Edited] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Thorne (Jira)
  • [jira] [Comment Edited] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Comment Edited] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Thorne (Jira)
• [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Thorne (Jira)
  • [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Thorne (Jira)
  • [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Commented] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Thorne (Jira)
• [jira] [Closed] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions Gyula Fora (Jira)
• [jira] [Created] (FLINK-39177) Add Flink 2.2 to operator e2es and bump example flink versions Gyula Fora (Jira)
• [jira] [Commented] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java Wei Zhong (Jira)
• [jira] [Resolved] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java Wei Zhong (Jira)
• [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic func to consume duplicate changes ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39175) Allow calc that contains non-deterministic to consume duplicate changes Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39176) Introduce Node Health Management & Quarantine Framework for ResourceManager featzhang (Jira)
• [jira] [Closed] (FLINK-39167) Initialize source output before emitting final watermark Roman Khachatryan (Jira)
• [jira] [Closed] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Roman Khachatryan (Jira)
• [jira] [Closed] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky Roman Khachatryan (Jira)
• [jira] [Comment Edited] (FLINK-39166) Add bucket level config parity Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-39166) Add bucket level config parity Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39175) Support calc that contains non-deterministic after delta join Xuyang Zhong (Jira)
• [jira] [Assigned] (FLINK-39175) Support calc that contains non-deterministic after delta join Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-39174) Support lookup join after delta join Xuyang Zhong (Jira)
• [jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Lei Yang (Jira)
  • [jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Lei Yang (Jira)
  • [jira] [Comment Edited] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Lei Yang (Jira)
• [jira] [Closed] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39022) Update default cipher suite value in SecurityOptions Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39173) Support application-level blob storage Yi Zhang (Jira)
• [jira] [Updated] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env Dian Fu (Jira)
• [jira] [Comment Edited] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env Dian Fu (Jira)
• [jira] [Closed] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env Dian Fu (Jira)
• [jira] [Commented] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml Ryan van Huuksloot (Jira)
• [jira] [Created] (FLINK-39172) Flink Bash Scripts don't support the new yaml 1.2 syntax when reading from config.yaml Ryan van Huuksloot (Jira)
• [jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns tianfy (Jira)
  • [jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns tianfy (Jira)
  • [jira] [Updated] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns tianfy (Jira)
• [jira] [Created] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns tianfy (Jira)
• [jira] [Updated] (FLINK-38974) Handle jobs in running applications during HA recovery Yi Zhang (Jira)
  • [jira] [Updated] (FLINK-38974) Handle jobs in running applications during HA recovery ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38974) Handle jobs during HA recovery Yi Zhang (Jira)
• [jira] [Commented] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky Roman Khachatryan (Jira)
• [jira] [Commented] (FLINK-39126) Support exporting metrics through grpc in batches Aleksandr Iushmanov (Jira)
• [jira] [Updated] (FLINK-39167) Initialize source output before emitting final watermark Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39167) Initialize source output before emitting final watermark Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39170) [Table/SQL] Add async batch lookup join optimization for temporal table joins featzhang (Jira)
• [jira] [Closed] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING Dawid Wysakowicz (Jira)
• [jira] [Comment Edited] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 Jon Chase (Jira)
• [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Jon Chase (Jira)
• [jira] [Commented] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4 Jon Chase (Jira)
• [jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails Rui Fan (Jira)
• [jira] [Comment Edited] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader Rui Fan (Jira)
• [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader Rui Fan (Jira)
• [jira] [Resolved] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests Rui Fan (Jira)
• [jira] [Assigned] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Martijn Visser (Jira)
• [jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException Piotr Nowojski (Jira)
• [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split-Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split Thorne (Jira)
  • [jira] [Updated] (FLINK-39168) improve mysql’s snapshot-split Thorne (Jira)
• [jira] [Created] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots in clustered instances Luca Occhipinti (Jira)
• [jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
  • [jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots Luca Occhipinti (Jira)
• [jira] [Commented] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env Biao Geng (Jira)
• [jira] [Created] (FLINK-39168) improve mysql’s snapshot-split Thorne (Jira)
• [jira] [Created] (FLINK-39167) Initialize source output before emitting final watermark Roman Khachatryan (Jira)
• [jira] [Updated] (FLINK-39166) Add bucket level config parity Samrat Deb (Jira)
• [jira] [Created] (FLINK-39166) Add bucket level config parity Samrat Deb (Jira)
• [jira] [Closed] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order Grzegorz Liter (Jira)
• [jira] [Comment Edited] (FLINK-39130) Allow native types to be used for MetricConfig Rui Fan (Jira)
• [jira] [Updated] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss Ihor Mielientiev (Jira)
  • [jira] [Updated] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss Ihor Mielientiev (Jira)
• [jira] [Commented] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Zhu Zhu (Jira)
• [jira] [Assigned] (FLINK-38956) Fix the job-overview Web UI cannot automatically show the latest edge name for AdaptiveScheduler Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Taranpreet Kaur (Jira)
  • [jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Martijn Visser (Jira)
• [jira] [Created] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit Yi Zhang (Jira)
• [jira] [Commented] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2 Jinkun Liu (Jira)
• [jira] [Created] (FLINK-39163) Support ML_PREDICT in Flink Python API Biao Geng (Jira)
• [jira] [Assigned] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-38973) Job ID assignment and matching based on name Zhu Zhu (Jira)
• [jira] [Resolved] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations Wei Zhong (Jira)
• [jira] [Commented] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations Wei Zhong (Jira)
• [jira] [Comment Edited] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency Jon Chase (Jira)
• [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Roman Khachatryan (Jira)
  • [jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-39162) The data of the custom partitioner is corrupted during unaligned checkpoint Rui Fan (Jira)
• [jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
• [jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
  • [jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
  • [jira] [Updated] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
• [jira] [Created] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics Arun Lakshman (Jira)
• [PR] FLINK-39098 fixing test-case failure due to build server not supporting docker 1.33 api [flink-connector-mongodb] via GitHub
  • Re: [PR] FLINK-39098 fixing test-case failure [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb] via GitHub
  • Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb] via GitHub
• [jira] [Created] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order Grzegorz Liter (Jira)

• Earlier messages
• Later messages