issues  

Messages by Thread

• [PR] [BP-2.3][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join ASF GitHub Bot (Jira)
• [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
  • Re: [PR] [FLINK-34380][table] Fix incorrect RowKind in MiniBatch join when INSERT is folded with retract [flink] via GitHub
• [jira] [Resolved] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• [PR] [infra] Add AGENTS.md [flink-agents] via GitHub
  • Re: [PR] [infra] Add AGENTS.md [flink-agents] via GitHub
• Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-39110] Add CRT support in native-s3-fs [flink] via GitHub
• [I] [Feature] Add AGENTS.md [flink-agents] via GitHub
  • Re: [I] [Feature] Add AGENTS.md [flink-agents] via GitHub
• [jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API Martijn Visser (Jira)
• Re: [PR] [FLINK-32695][e2e] Migrate SqlToolbox watermark push-down source to Source V2 [flink] via GitHub
• [PR] [FLINK-40087][mysql] Fix MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40087][mysql] Fix MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
  • [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
  • [jira] [Updated] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• [jira] [Resolved] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Timo Walther (Jira)
  • [jira] [Assigned] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Timo Walther (Jira)
• [jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`) Xin Gong (Jira)
• [jira] [Updated] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38441) ExecutionGraphCoLocationRestartTest failed in test_ci core Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39921) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• [jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction Matthias Pohl (Jira)
• [jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink reswqa (Jira)
• [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38054] Fix OperationSerializer issue for es8 sink [flink-connector-elasticsearch] via GitHub
• [PR] [hotfix] Bump Mockito for JDK 17 tests [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Bump Mockito for JDK 17 tests [flink-cdc] via GitHub
• [D] Memory Oobservation Capability Design [flink-agents] via GitHub
  • Re: [D] [Discussion]Memory Oobservation Capability Design [flink-agents] via GitHub
  • Re: [D] [Discussion] Memory Oobservation Capability Design [flink-agents] via GitHub
  • Re: [D] [Discussion] Memory Observation Capability Design [flink-agents] via GitHub
  • Re: [D] [Discussion] Memory Observation Capability Design [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-39429) NoClassDefFoundError for flink-shaded-guava31 in IncrementalSourceStreamFetcher (Flink 2.2 / CDC 3.6.0) Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Weiqing Yang (Jira)
• [jira] [Resolved] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Bowen Li (Jira)
• [jira] [Resolved] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
• [jira] [Commented] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka Bowen Li (Jira)
• [jira] [Updated] (FLINK-39981) Autoscaler cannot trigger source rebalance after active split removal on dynamic Kafka source ASF GitHub Bot (Jira)
• [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39981] [Autoscaler] Correct dynamic source topology from active split metrics [flink-kubernetes-operator] via GitHub
• [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
  • Re: [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
  • Re: [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
  • Re: [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
  • Re: [PR] [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope [flink-agents] via GitHub
• Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
  • Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
  • Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
  • Re: [PR] [api][integrations] Support models' native structured output (foundation + OpenAI) [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory) Martijn Visser (Jira)
• [PR] [ci] Use maintained 'temurin' distribution for setup-java [flink-agents] via GitHub
  • Re: [PR] [ci] Use maintained 'temurin' distribution for setup-java [flink-agents] via GitHub
• [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-1.20][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.1][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.2][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
  • Re: [PR] [BP-2.3][hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` [flink] via GitHub
• [jira] [Updated] (FLINK-40084) maven-shade-plugin does not respect multi release jars ASF GitHub Bot (Jira)
• [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
  • Re: [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
  • Re: [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
  • Re: [PR] [FLINK-40084][build] maven-shade-plugin does not respect multi release jars [flink] via GitHub
• [jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars Sergey Nuyanzin (Jira)
• [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download [flink-connector-jdbc] via GitHub
• [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
  • [jira] [Commented] (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)
  • [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-36242) Fix unstable test in MaterializedTableITCase Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS) Sergey Nuyanzin (Jira)
• [PR] [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwinf exceptions [flink] via GitHub
  • Re: [PR] [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
  • Re: [PR] [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions [flink] via GitHub
• [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
  • [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
  • [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
  • [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
  • [jira] [Updated] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Chris Lu (Jira)
  • [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
• [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
• [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
• [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
• [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
• [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
• [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)
• [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

• Earlier messages
• Later messages