issues  

Messages by Thread

• [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)
• [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
• [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
• [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
• [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
• [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] [Commented] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Sangkyoon Nam (Jira)
• [jira] [Commented] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Sangkyoon Nam (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-41104) MapState.contains() returns false for an existing key whose value is None Sangkyoon Nam (Jira)
• [jira] [Commented] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Sangkyoon Nam (Jira)
• [jira] [Created] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• [jira] [Assigned] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG ASF GitHub Bot (Jira)
• [PR] [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG [flink] via GitHub
  • Re: [PR] [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG [flink] via GitHub
• [jira] [Assigned] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41114) Document the uid argument for FROM_CHANGELOG and TO_CHANGELOG Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-41089) Make cleanup of docker image parallel Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
  • Re: [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
  • Re: [PR] [FLINK-41113][Build] Bump jackson, log4j, assertj and pin curator-test transitives [flink-connector-pulsar] via GitHub
• [jira] [Resolved] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom ASF GitHub Bot (Jira)
• [PR] [FLINK-41112][Connectors/Cassandra] Support Flink 1.20 [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-41112][Connectors/Cassandra] Support Flink 1.20 [flink-connector-cassandra] via GitHub
• [jira] [Commented] (FLINK-40873) Fix overlapping config key prefixes in the operator yongfu.gao (Jira)
• [jira] [Created] (FLINK-41113) Connectors/Pulsar: Bump dependency versions with known advisories in the root pom Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Moritz Manner (Jira)
• Re: [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
  • Re: [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
  • Re: [PR] [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause [flink] via GitHub
• [PR] docs: remove stray brace in README streaming example [flink] via GitHub
  • Re: [PR] docs: remove stray brace in README streaming example [flink] via GitHub
• Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
  • Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
  • Re: [PR] [FLINK-40936][table] Reject VARIANT elements and keys in functions that compare them [flink] via GitHub
• [jira] [Assigned] (FLINK-41111) Changelog mode errors of FlinkChangelogModeInferenceProgram do not identify the part of the query that produces the changes Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41108) PyFlink namespace merges leave stale cached values for TTL-enabled ListState Dian Fu (Jira)
• [jira] [Updated] (FLINK-41109) Add guidelines for embedding user input in generated code to the planner's AGENTS.md ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34468) Implement Lineage Interface in Cassandra Connector Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34468) Implement Lineage Interface in Cassandra Connector Peter Huang (Jira)
• [jira] [Updated] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41112) Support Flink 1.20 in the Cassandra connector ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound Martijn Visser (Jira)
• [jira] [Created] (FLINK-41112) Support Flink 1.20 in the Cassandra connector Martijn Visser (Jira)
• [PR] [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields [flink] via GitHub
  • Re: [PR] [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields [flink] via GitHub
  • Re: [PR] [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields [flink] via GitHub
• Re: [PR] [FLINK-35546] Elasticsearch 8 connector fails fast for non-retryable bulk request items [flink-connector-elasticsearch] via GitHub
• [jira] [Assigned] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• [jira] [Updated] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41110) Find VARIANT object fields by comparing UTF-8 bytes Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects ASF GitHub Bot (Jira)
• [PR] [BP-3.7][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
  • Re: [PR] [BP-3.7][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
  • Re: [PR] [BP-3.7][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
  • Re: [PR] [BP-3.7][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xiqian Yu (Jira)
• [PR] [FLINK-41109][table] Add guidelines for query-controlled strings in generated code to planner AGENTS.md [flink] via GitHub
  • Re: [PR] [FLINK-41109][table] Add guidelines for query-controlled strings in generated code to planner AGENTS.md [flink] via GitHub
  • Re: [PR] [FLINK-41109][table] Add guidelines for query-controlled strings in generated code to planner AGENTS.md [flink] via GitHub
• [jira] [Assigned] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
  • [jira] [Assigned] (FLINK-41086) JSON_LENGTH and JSON_TYPE fail the job when a JSON path function throws Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects Ramin Gharib (Jira)
• [PR] [BP-3.6][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
  • Re: [PR] [BP-3.6][hotfix][ci] Pin all runner images at Ubuntu 24.04 (#4594) [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
  • [jira] [Commented] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
  • [jira] [Commented] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
• [jira] [Created] (FLINK-41107) schema.change.behavior: lenient or exclude.schema.changes is ignored by Hudi and MaxCompute sinks because their MetadataApplier implementations do not honor accepted schema evolution types Xin Chen (Jira)
• [jira] [Resolved] (FLINK-41028) Support data lake table properties in the Fluss pipeline sink Hongshun Wang (Jira)
• [jira] [Comment Edited] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• [I] [Feature] Add LiteLLM Router SDK integration for model routing and failover [flink-agents] via GitHub
  • Re: [I] [Feature] Add LiteLLM Router SDK integration for model routing and failover [flink-agents] via GitHub
• [jira] [Created] (FLINK-41106) MapState.put_all() iterates dictionary keys instead of key-value pairs Dian Fu (Jira)
• [jira] [Commented] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• [jira] [Created] (FLINK-41105) transform projection: arithmetic between DECIMAL column and numeric literal fails at Janino compile time — times(BigDecimal, double) has no matching overload zhanglu153 (Jira)
• [PR] [hotfix][ci] Reduce rescaling test logs and align Java IT [flink-agents] via GitHub
  • Re: [PR] [hotfix][ci] Reduce test logs and update Java IT and ReAct tests [flink-agents] via GitHub
• [jira] [Created] (FLINK-41104) MapState.contains() returns false for an existing key whose value is None Dian Fu (Jira)
• [jira] [Created] (FLINK-41103) ValueState.update(None) attempts to serialize None instead of clearing the state Dian Fu (Jira)
• [jira] [Commented] (FLINK-37607) Blocklist timeout check may lost Lei Yang (Jira)
• [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
  • Re: [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
  • Re: [PR] [hotfix][ci] Remove disallowed markdown link check action from docs workflow for release-3.7 [flink-cdc] via GitHub
• [jira] [Created] (FLINK-41102) Keyed state clear operations are lost on key changes when python.state.cache-size is zero Dian Fu (Jira)
• [jira] [Commented] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• [jira] [Created] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
• [jira] [Updated] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure due to FileNotFoundException Martijn Visser (Jira)
• [jira] [Updated] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• [jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI Martijn Visser (Jira)
• [jira] [Updated] (FLINK-35710) ClusterEntrypointTest failed on AZP due to exit code: 239 Martijn Visser (Jira)
• [jira] [Commented] (FLINK-35710) ClusterEntrypointTest failed on AZP due to exit code: 239 Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure due to FileNotFoundException Martijn Visser (Jira)
• [PR] [FLINK-40655][tests] Run deployment callbacks inline in ExecutionVertexTest [flink] via GitHub
  • Re: [PR] [FLINK-40655][tests] Run deployment callbacks inline in ExecutionVertexTest [flink] via GitHub
• [jira] [Created] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41100) DynamicKafkaSource shares one split output between partitions whose split ids collide ASF GitHub Bot (Jira)
• [I] [Tech Debt][runtime][java][python] Clarify subagent group cleanup and internal fault propagation [flink-agents] via GitHub
• Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] via GitHub
• [jira] [Resolved] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Martijn Visser (Jira)
• [PR] [hotfix][ci] Pin all runner images at Ubuntu 24.04 [flink-cdc] via GitHub
  • Re: [PR] [hotfix][ci] Pin all runner images at Ubuntu 24.04 [flink-cdc] via GitHub
  • Re: [PR] [hotfix][ci] Pin all runner images at Ubuntu 24.04 [flink-cdc] via GitHub
• [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
  • Re: [PR] [FLINK-41076] Bump netty-tcnative to 2.0.84.Final (release-21.0) [flink-shaded] via GitHub
• [jira] [Resolved] (FLINK-40617) Connectors/Kafka: Prune and bump dependency versions in the root pom Martijn Visser (Jira)
• [PR] [docs] [flink-cdc] via GitHub
• [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
  • Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
  • Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
  • Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
  • Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
  • Re: [PR] [FLINK-34625][python] Fix state TTL read cache disabling [flink] via GitHub
• [jira] [Updated] (FLINK-34625) TTL doesn't seem to work in pyflink ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• [jira] [Updated] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
  • [jira] [Updated] (FLINK-41099) Streaming RANK() / DENSE_RANK() OVER a non-time ORDER BY ignore ties (return the row count instead of the rank) Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41098) Streaming mode: IN / NOT IN in the SELECT list drops all rows when the subquery result is empty Yaoxuan Wu (Jira)
• [jira] [Created] (FLINK-41097) AVG returns NULL for a group with a NULL value once adaptive local hash aggregation switches to bypass mode Yaoxuan Wu (Jira)
• [jira] [Updated] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• [jira] [Commented] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• [jira] [Resolved] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• [jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order Feifan Wang (Jira)
  • [jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order Feifan Wang (Jira)
  • [jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order Feifan Wang (Jira)
• [PR] [hotfix][docs] Centralize stable release versions in setup examples [flink-agents] via GitHub
  • Re: [PR] [hotfix][docs] Centralize stable release versions in setup examples [flink-agents] via GitHub
• [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
  • Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
  • Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
  • Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
  • Re: [PR] [BP-3.6][FLINK-39573][docs] Fix Build documentation CI for release-3.6 [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits Leonard Xu (Jira)
• Re: [D] Flink Agents Release Process [flink-agents] via GitHub
  • Re: [D] Flink Agents Release Process [flink-agents] via GitHub
  • Re: [D] Flink Agents Release Process [flink-agents] via GitHub

• Earlier messages