issues  

Messages by Thread

• [jira] [Commented] (FLINK-38808) Support partition transforms in Iceberg sink Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39063) FIx some spelling mistakes in fluss connector Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-37586) YAML pipeline supports passing extra options to UDFs Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38647) NullPointerException in Postgres CDC pipeline when update data in table Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39417) YAML Pipeline could not [de]serialize GenericRecordData Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-37586) YAML pipeline supports passing extra options to UDFs Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39144) fix IOManager not close Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39171) Oracle pipeline transform fails with quoted uppercase projection columns Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39718) Paimon pipeline sink fails with distributed source when target table does not exist Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39346) Improve the error message when the AddColumnEvent fails Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39372) Potential MySQL Binlog offset comparison failure after mysql-bin.999999 Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39363) [Flaky Tests] PaimonSinkITCase.testDuplicateCommitAfterRestore Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39684) YAML PaimonWriter throws NullPointerException when handling REPLACE event Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39696) Distributed SchemaOperator emits FlushEvent with schema operator subtaskId instead of upstream sourcePartition Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39682) Unable to invoke TO_DATE with TIMESTAMP types Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39698) Fix incorrect content in SQLServer CDC connector documentation Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40091) upgrade paimon to 1.4.2 Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40202) HybridSplitAssigner may initialize enumerator metrics concurrently with snapshot split assignment Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39568) Decouple YAML built-in AI Function and model providers Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-40533) Upgrade Flink CDC dependency to Flink 2.3 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
  • [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
  • [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
  • [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
  • [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
• [jira] [Assigned] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
• [jira] [Commented] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40313) Support collection constructors and functions in YAML Transform Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40416) Add built-in text AI functions to Pipeline transforms Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40507) upgrade paimon to 2.0.0 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39416) Fix link address errors in documents Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40572) Support dynamic model selection for AI functions Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40656) Distributed schema coordinator can remain EVOLVING after checkpoint restore Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys Xiqian Yu (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 "`) Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39569) YAML pipeline supports HLS live-streaming video source Xiqian Yu (Jira)
• [jira] [Closed] (FLINK-39569) YAML pipeline supports HLS live-streaming video source Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39386) For Flink 2.x+, support limit the rate at the source Xiqian Yu (Jira)
• [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
  • Re: [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
  • Re: [PR] [FLINK-24908][table-planner] Include the parser position in SqlParserException messages [flink] via GitHub
  • Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
  • Re: [PR] [FLINK-24908][table-planner] Show the position and the failing line in parse errors [flink] via GitHub
• [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
  • Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Leonard Xu (Jira)
• [jira] [Comment Edited] (FLINK-40488) Comparison and ordering for UUID dylanhz (Jira)
• [PR] [plan][java][python] Unify function schemas and argument validation [flink-agents] via GitHub
  • Re: [PR] [plan][java][python] Unify function schemas and argument validation [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-40512) PostgreSQL yaml source is busy on inferring schema change event Xiqian Yu (Jira)
• [jira] [Closed] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40480) [doc] CDC Yaml supports fluss source. Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40091) upgrade paimon to 1.4.2 Xiqian Yu (Jira)
• Re: [PR] [FLINK-25453] [core] Ignore files deleted concurrently in LocalFileSystem#listStatus [flink] via GitHub
• Re: [PR] [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors [flink-agents] via GitHub
• [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
  • Re: [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
  • Re: [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
  • Re: [PR] [build] Bump version to 3.8-SNAPSHOT [flink-cdc] via GitHub
• Re: [I] [Feature] Support registering ReActAgent as a general-purpose subagent [flink-agents] via GitHub
  • Re: [I] [Feature] Support registering ReActAgent as a general-purpose subagent [flink-agents] via GitHub
• Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• Re: [I] [Feature][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
• Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
• [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• [PR] [runtime][java] Preserve pending Fluss action state across checkpoints [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Preserve pending Fluss action state across checkpoints [flink-agents] via GitHub
• [I] [Bug][runtime] Fluss recovery can skip saved results for pending actions [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Fluss recovery can skip saved results for pending actions [flink-agents] via GitHub
• Re: [PR] [FLINK-40676] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
  • Re: [PR] [FLINK-40676] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• [PR] [FLINK-40839][table] Support VARIANT and BITMAP columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT and BITMAP columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
  • Re: [PR] [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list [flink] via GitHub
• [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
  • [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT or BITMAP Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Roman Khachatryan (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• [PR] [FLINK-40838][tests] Add a DataStream end-to-end test for the Confluent Schema Registry format [flink-connector-kafka] via GitHub
• [PR] [FLINK-32451][tests] Rewrite the Confluent Schema Registry e2e test without the Kafka connector [flink] via GitHub
  • Re: [PR] [FLINK-32451][tests] Rewrite the Confluent Schema Registry e2e test without the Kafka connector [flink] via GitHub
• [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Martijn Visser (Jira)
• [jira] [Updated] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-36454) FlinkContainer always overwrites default config Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39674) flink-avro-confluent-registry uses an obsolete schema registry client Martijn Visser (Jira)
• [jira] [Closed] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Martijn Visser (Jira)
• [jira] [Created] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• [jira] [Commented] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Martijn Visser (Jira)
• [jira] [Commented] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure Martijn Visser (Jira)
• [jira] [Closed] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure Martijn Visser (Jira)
• [jira] [Updated] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Martijn Visser (Jira)
• [jira] [Commented] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Martijn Visser (Jira)
• [jira] [Created] (FLINK-40837) SavepointWriter#changeOperatorIdentifier drops the operator coordinator state Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40836) Restoring with execution.state-recovery.without-channel-state.checkpoint-id drops operator coordinator state Spoorthi Basu (Jira)
• [jira] [Created] (FLINK-40835) Operator state restore reads state files one byte at a time Spoorthi Basu (Jira)
• [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink] via GitHub
  • Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink] via GitHub
• [jira] [Updated] (FLINK-40834) CI artifacts keep only one of jobmanager.log and jobmanager.log.N for YARN containers ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40834) CI artifacts keep only one of jobmanager.log and jobmanager.log.N for YARN containers Martijn Visser (Jira)
• [PR] [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts [flink] via GitHub
  • Re: [PR] [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts [flink] via GitHub
  • Re: [PR] [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts [flink] via GitHub
• [jira] [Resolved] (FLINK-38506) SideOutputITCase.testWatermarkForwarding failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40396) Create SplitReaders on the split fetcher thread instead of the caller thread ASF GitHub Bot (Jira)
• [PR] [FLINK-40604][datastream] Route expired async retry results through timeout handler [flink] via GitHub
  • Re: [PR] [FLINK-40604][datastream] Route expired async retry results through timeout handler [flink] via GitHub
• Re: [PR] [FLINK-40262][format/avro] Support matching Avro record fields by name [flink] via GitHub
• [jira] [Resolved] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-38908) ExecutionPartitionLifecycleTest fails intermittently Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40604) AsyncWaitOperator bypasses timeout handler when retry result mail runs after the deadline ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• [jira] [Created] (FLINK-40830) Reuse jdk getBytes for StringUtf8Utils Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-32609) Kafka table source supports projection push down fqaiser94 (Jira)
• [jira] [Assigned] (FLINK-40833) JobManager and TaskManager logs are rolled at startup with log4j 2.25.2 and later Martijn Visser (Jira)
• [jira] [Created] (FLINK-40829) operators hidden by `assign_timestamps_and_watermarks` get no uid, breaking `pipeline.auto-generate-uids: false` Florian Vazelle (Jira)
• Re: [PR] [api][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Support parallel action execution on JDK < 21 [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Purushottam Sinha (Jira)
  • [jira] [Comment Edited] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• [PR] [BP-2.2][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• [PR] [BP-2.3][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• [PR] [FLINK-40739][maxcompute] Fix partition handling for sink writes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40739][maxcompute] Fix partition handling for sink writes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40739][maxcompute] Fix partition handling for sink writes [flink-cdc] via GitHub
• [jira] [Created] (FLINK-40831) Mini-batch outer join loses the null-padded row when an input record is updated without UPDATE_BEFORE Gustavo de Morais (Jira)
• Re: [I] [Feature] Add checkpoint-aligned cleanup for Kafka action state [flink-agents] via GitHub
• Re: [PR] [FLINK-40180] Non-keyed/operator state support in State Catalog [flink] via GitHub
  • Re: [PR] [FLINK-40180] Non-keyed/operator state support in State Catalog [flink] via GitHub
  • Re: [PR] [FLINK-40180] Non-keyed/operator state support in State Catalog [flink] via GitHub
• [jira] [Updated] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image Martijn Visser (Jira)
• [PR] [hotfix][docs] Stop nightly docs builds for release-1.19, release-2.0 and release-2.1 [flink] via GitHub
  • Re: [PR] [hotfix][docs] Stop nightly docs builds for release-1.19, release-2.0 and release-2.1 [flink] via GitHub
  • Re: [PR] [hotfix][docs] Stop nightly docs builds for release-1.19, release-2.0 and release-2.1 [flink] via GitHub
• [jira] [Resolved] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
  • Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
  • Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
  • Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub

• Earlier messages
• Later messages