issues  

Messages by Thread

• • [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
• [jira] [Commented] (FLINK-39859) Upgrade Calcite version to 1.41.0 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39859) Upgrade Calcite version to 1.41.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Fred Teunissen (Jira)
• [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v3.4.0 [flink-web] via GitHub
• [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
  • Re: [PR] Adding JDBC Connector v4.1.0 [flink-web] via GitHub
• [jira] [Updated] (FLINK-39783) Add translation rules to convert lateral call of SNAPSHOT function into join operator ASF GitHub Bot (Jira)
• [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
  • Re: [PR] [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator [flink] via GitHub
• Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• [jira] [Resolved] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• [PR] [FLINK-40081] Enable the spilling backend for checkpointing during recovery [flink] via GitHub
  • Re: [PR] [FLINK-40081] Enable the spilling backend for checkpointing during recovery [flink] via GitHub
• [jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40081) Enable the spilling backend for checkpointing during recovery ASF GitHub Bot (Jira)
• [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
  • Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
  • Re: [PR] [FLINK-39524][checkpoint] Fetched channel state: spill files, filtered write, reader [flink] via GitHub
• [PR] [FLINK-40080][checkpoint] Drain spilled state into channels; replay spilled slices into checkpoints [flink] via GitHub
  • Re: [PR] [FLINK-40080][checkpoint] Drain spilled state into channels; replay spilled slices into checkpoints [flink] via GitHub
• [jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name Yuepeng Pan (Jira)
• [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink] via GitHub
  • Re: [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink] via GitHub
  • Re: [PR] [FLINK-39523] Checkpoint coordination during recovery (memory-based trigger) [flink] via GitHub
• [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
  • Re: [PR] [FLINK-39522] Rework StreamTask recovery: async future chain, consume only after filtering completes [flink] via GitHub
• [jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40041) Update JDBC connector version to 3.4.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38616) Jdbc Catalog supports jdbc properties. Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-36242) Fix unstable test in MaterializedTableITCase Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-36242) Fix unstable test in MaterializedTableITCase Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-36242][table] Fix unstable MaterializedTableStatementITCase [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-36242][table] Fix unstable MaterializedTableStatementITCase [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-36242][table] Fix unstable MaterializedTableStatementITCase [flink] via GitHub
• [jira] [Updated] (FLINK-40015) Wrap atomic PTF output in Row partition-key prepend & rowtime append in PTF Test Harness ASF GitHub Bot (Jira)
• [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getSystemOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getRuntimeOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
  • Re: [PR] [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness [flink] via GitHub
• [PR] [BP-2.3][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• [jira] [Updated] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) ASF GitHub Bot (Jira)
• [PR] [BP-1.20][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
  • Re: [PR] [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test [flink] via GitHub
• Re: [PR] [FLINK-34368][fs] Update GCS connector to 3.1.18 [flink] via GitHub
• [jira] [Updated] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Piotr Nowojski (Jira)
• [jira] [Closed] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint Piotr Nowojski (Jira)
• Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• Re: [PR] [FLINK-39680][FLINK-21378] Supports unaligned checkpoint on pointwise edges [flink] via GitHub
  • Re: [PR] [FLINK-39680][FLINK-21378] Supports unaligned checkpoint on pointwise edges [flink] via GitHub
• [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
  • Re: [PR] [FLINK-39521][network] Push-based recovery support in input channels [flink] via GitHub
• [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
  • Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
  • Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
  • Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
  • Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
  • Re: [PR] [FLINK-39520] Preparatory refactoring for channel state recovery (no behavior change) [flink] via GitHub
• [jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints Rui Fan (Jira)
• [jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery Rui Fan (Jira)
• [jira] [Updated] (FLINK-39524) Introduce the fetched-channel-state spill subsystem (segmented spill files, filtered write, reader) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39524) Introduce the fetched-channel-state spill subsystem (segmented spill files, filtered write, reader) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39524) Introduce the fetched-channel-state spill subsystem (segmented spill files, filtered write, reader) ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39523) Support checkpoint coordination during recovery via a recovery-checkpoint trigger (memory-based) ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39521) Support push-based recovery in input channels ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39522) Rework StreamTask channel-state recovery into an async future chain; start consumption only after filtering completes ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) Rui Fan (Jira)
  • [jira] [Updated] (FLINK-39520) Preparatory refactoring for channel-state recovery: split the recovered-state handler, add InputGate#getChannel(InputChannelInfo) ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths Fabian Hueske (Jira)
• [jira] [Updated] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Filippo Ghibellini (Jira)
• [jira] [Commented] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x Taranpreet Kaur (Jira)
• [jira] [Updated] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x ASF GitHub Bot (Jira)
• [PR] [FLINK-40049] [Connectors / Prometheus] compatibility changes for Flink-connector-Prometheus for … [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-40049] [Connectors / Prometheus] compatibility changes for Flink-connector-Prometheus for … [flink-connector-prometheus] via GitHub
• [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• [PR] [BP-2.3][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• [jira] [Assigned] (FLINK-40045) Upgrade d3-flame-graph to v5 Martijn Visser (Jira)
• [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• [jira] [Resolved] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
• [jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause Martijn Visser (Jira)
• Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
  • Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] via GitHub
• [jira] [Updated] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause ASF GitHub Bot (Jira)
• [PR] [FLINK-40077][table-planner] Fix lost NoMoreSplitsEvent masking failure cause in CommonExecSinkITCase [flink] via GitHub
  • Re: [PR] [FLINK-40077][table-planner] Fix lost NoMoreSplitsEvent masking failure cause in CommonExecSinkITCase [flink] via GitHub
• [jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Matthias Pohl (Jira)
• [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
  • Re: [PR] [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause [flink] via GitHub
• [jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Piotr Nowojski (Jira)
  • [jira] [Commented] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• Re: [I] [Feature] [integration] [java] Integrate built-in Google Gemini chat model [flink-agents] via GitHub
  • Re: [I] [Feature] [integration] [java] Integrate built-in Google Gemini chat model [flink-agents] via GitHub
• Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Evaluate deprecating Python local_runner / local_execution_environment [flink-agents] via GitHub
• Re: [I] [Feature] Support tool parameter injection [flink-agents] via GitHub
• Re: [I] [python] Verify and admit `bytes` in the Python memory value contract [flink-agents] via GitHub
• Re: [PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents] via GitHub
• Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
  • Re: [I] [Feature] Add lineage fields to the event log for per-run trace reconstruction [flink-agents] via GitHub
• [jira] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED Mao Jiayi (Jira)
• Re: [PR] [FLINK-39669][table-planner] BatchPhysicalCorrelateRule / StreamPhysicalCorrelateRule drop right-side projection when a Calc sits between Correlate and TableFunctionScan [flink] via GitHub
• [jira] [Resolved] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism Yanquan Lv (Jira)

• Earlier messages
• Later messages