issues  

Messages by Thread

• [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
  • Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
  • Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
  • Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
  • Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
• [PR] [hotfix][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41158][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41158][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka] via GitHub
• [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink] via GitHub
  • Re: [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink] via GitHub
• [jira] [Updated] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
• [jira] [Created] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
• [PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [PR] [hotfix] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
  • Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
• [jira] [Assigned] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira)
• [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input ASF GitHub Bot (Jira)
• [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-40729) Refresh the JDBC driver and test dependency versions raised by Dependabot Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Martijn Visser (Jira)
• Re: [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
• [jira] [Created] (FLINK-41136) Exactly-once JdbcSink in BATCH mode fails for good after its committer restarts mid-commit Martijn Visser (Jira)
• [jira] [Created] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
• [jira] [Created] (FLINK-41133) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• [jira] [Created] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
• [jira] [Created] (FLINK-41129) [release-2.4] Add release notes Yuepeng Pan (Jira)
• [PR] [hotfix][build] Update version to 5.0-SNAPSHOT [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][build] Update version to 5.0-SNAPSHOT [flink-connector-jdbc] via GitHub
  • Re: [PR] [hotfix][build] Update version to 5.0-SNAPSHOT [flink-connector-jdbc] via GitHub
• [jira] [Commented] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41123) [release-2.4] Prepare RC0 release Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Martijn Visser (Jira)
• Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink] via GitHub
• [jira] [Resolved] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
  • [jira] [Assigned] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
• Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
• [jira] [Resolved] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41127) [release-2.4] Review and update documentation Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41126) [release-2.4] Triage release blockers in JIRA Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41124) [release-2.4] Review release notes in JIRA Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41125) [release-2.4] Cross-team testing Yuepeng Pan (Jira)
• [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
  • Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
  • Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
  • Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
  • Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
• [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource ASF GitHub Bot (Jira)
• [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
  • Re: [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
  • Re: [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
• [jira] [Created] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41117) Move CI to ubuntu 26 ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector ASF GitHub Bot (Jira)
• [PR] [FLINK-28596][jdbc] Support writing ARRAY values in the PostgreSQL dialect [flink-connector-jdbc] via GitHub
• [jira] [Commented] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector Tomoyuki NAKAMURA (Jira)
• [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
• [jira] [Commented] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• [jira] [Resolved] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)
• [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
• [PR] [FLINK-41051][jdbc] Report the configured table name in source lineage [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-40873) Fix overlapping config key prefixes in the operator ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL ASF GitHub Bot (Jira)
• [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide yongfu.gao (Jira)
• [jira] [Commented] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL yongfu.gao (Jira)
• [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
  • Re: [PR] [FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose [flink] via GitHub
• [jira] [Updated] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40747][jdbc] PreparedSplitterEnumerator.of(sql) yields one split [flink-connector-jdbc] via GitHub
• [jira] [Resolved] (FLINK-40747) PreparedSplitterEnumerator.of(sqlTemplate) produces no split, the source reads nothing Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40779) JdbcSourceEnumerator snapshots splitter state ahead of the splits it has handled Martijn Visser (Jira)
• [PR] [FLINK-41115][runtime] Isolate adaptive graph recovery from IO [flink] via GitHub
  • Re: [PR] [FLINK-41115][runtime] Isolate adaptive graph recovery from IO [flink] via GitHub
• [jira] [Resolved] (FLINK-37288) Add Google Cloud Spanner dialect and catalog Martijn Visser (Jira)
• Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• [jira] [Resolved] (FLINK-41088) DynamicKafkaSource loses or rejects splits whose formatted split ids collide Martijn Visser (Jira)
• [jira] [Created] (FLINK-41115) Checkpoint cleanup can starve AdaptiveScheduler execution-graph creation David Peacock (Jira)
• Re: [PR] [FLINK-40604][datastream] Route expired async retry results through timeout handler [flink] via GitHub
• [jira] [Resolved] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
• [PR] [FLINK-41087][table] Build the PARSE_JSON error only where PARSE_JSON rethrows [flink] via GitHub
  • Re: [PR] [FLINK-41087][table] Build the PARSE_JSON error only where PARSE_JSON rethrows [flink] via GitHub
  • Re: [PR] [FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects [flink] via GitHub
  • Re: [PR] [FLINK-41087][table] Don't build the `PARSE_JSON` error for rows `TRY_PARSE_JSON` rejects [flink] via GitHub
• [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] via GitHub
  • Re: [PR] [FLINK-41066][table] Handle upsert inputs in multi-way joins [flink] via GitHub
• [jira] [Updated] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
  • [jira] [Updated] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Dian Fu (Jira)
• [jira] [Commented] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Dian Fu (Jira)
• [jira] [Updated] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE ASF GitHub Bot (Jira)
• [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
  • Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
  • Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
  • Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
  • Re: [PR] [hotfix] Update copyright year to 2026 [flink-connector-cassandra] via GitHub
• [jira] [Commented] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira)
• [jira] [Commented] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• [jira] [Commented] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Sangkyoon Nam (Jira)

• Earlier messages
• Later messages