issues  

Messages by Thread

• [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
  • [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
  • [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
  • [jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• [jira] [Created] (FLINK-39080) Missing license undetected by connector CI Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI featzhang (Jira)
• [jira] [Commented] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation ASF GitHub Bot (Jira)
• [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
  • Re: [PR] [FLINK-35321] Register commitables metric at snapshotState invocation [flink] via GitHub
• Re: [PR] Add Turkish Translation for Apache Flink Website [flink-web] via GitHub
• [jira] [Assigned] (FLINK-39002) Could not resolve ResourceManager because of NPE Piotr Nowojski (Jira)
  • [jira] [Assigned] (FLINK-39002) Could not resolve ResourceManager because of NPE Piotr Nowojski (Jira)
• [PR] [FLINK-XXXXX][Web UI] Add Top N Metrics Dashboard for performance diagnostics [flink] via GitHub
  • Re: [PR] [FLINK-XXXXX][Web UI] Add Top N Metrics Dashboard for performance diagnostics [flink] via GitHub
• [jira] [Updated] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks ASF GitHub Bot (Jira)
• [PR] [FLINK-39078] Disallow ON CONFLICT for non upsert sinks [flink] via GitHub
  • Re: [PR] [FLINK-39078] Disallow ON CONFLICT for non upsert sinks [flink] via GitHub
• [jira] [Created] (FLINK-39078) Disallow ON CONFLICT for non upsert sinks Dawid Wysakowicz (Jira)
• [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] via GitHub
  • Re: [PR] [FLINK-39077][table] Calculation of table changes for MT with several non persisted columns might fail [flink] via GitHub
• [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI featzhang (Jira)
• [jira] [Created] (FLINK-39076) [web ui] Display slot sharing group in operator nodes in Flink Web UI featzhang (Jira)
• [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
  • [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
  • [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
  • [jira] [Comment Edited] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• [jira] [Commented] (FLINK-35321) CheckpointCommittableManagerImpl re-registers pendingCommittables gauge on every commit operation Piotr Rudnicki (Jira)
• [PR] [FLINK-XXXXX][Web UI] Display slot sharing group ID in operator nodes [flink] via GitHub
  • Re: [PR] [FLINK-XXXXX][Web UI] Display slot sharing group ID in operator nodes [flink] via GitHub
• [jira] [Closed] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-39075) fn_execution test collection fails in test_flink_fn_execution_pb2.py Samrat Deb (Jira)
• [jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL featzhang (Jira)
  • [jira] [Updated] (FLINK-39062) Support applying watermark on logical relations in SQL featzhang (Jira)
• [jira] [Updated] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" ASF GitHub Bot (Jira)
• [PR] [FLINK-8093][connectors/kafka] Add client.id.prefix support to KafkaSink [flink-connector-kafka] via GitHub
• [jira] [Closed] (FLINK-18379) Introduce asynchronous UDF/UDTF Natea Eshetu Beshada (Jira)
• [jira] [Commented] (FLINK-18379) Introduce asynchronous UDF/UDTF Natea Eshetu Beshada (Jira)
• [jira] [Assigned] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
  • [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
  • [jira] [Updated] (FLINK-39062) Support logical-level watermark definition via SQL function featzhang (Jira)
• [jira] [Closed] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types Natea Eshetu Beshada (Jira)
• [jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types Natea Eshetu Beshada (Jira)
• [jira] [Closed] (FLINK-38969) Extend current JSON_STRING to convert a Variant to a Json string. Gyula Fora (Jira)
• Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] via GitHub
  • Re: [PR] [FLINK-38515][flink-avro-confluent-registry] Implement OAuth2 mechanism that supports token inheritance for the Schema Registry authentication [flink] via GitHub
• [jira] [Updated] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management featzhang (Jira)
• [jira] [Updated] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode ASF GitHub Bot (Jira)
• [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink] via GitHub
  • Re: [PR] [FLINK-26051][table] Fix ROW_NUMBER with CASE WHEN and WHERE clause causing window ordering exception [flink] via GitHub
• [jira] [Assigned] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. Leonard Xu (Jira)
• [jira] [Created] (FLINK-39074) Add built-in AI model inference capability to PyFlink with automatic lifecycle management featzhang (Jira)
• [jira] [Assigned] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry Natea Eshetu Beshada (Jira)
• [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
  • Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
  • Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• [jira] [Updated] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry ASF GitHub Bot (Jira)
• [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink] via GitHub
  • Re: [PR] [FLINK-XXXXX][PyFlink] Add AI inference lifecycle management with infer() API [flink] via GitHub
• [jira] [Updated] (FLINK-39071) Select fields rather than * to read snapshot data in case of schema changes. Hongshun Wang (Jira)
• Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] via GitHub
• Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38249] Add support for skipping specific Debezium operations in MySQL CDC source. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
  • [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
  • [jira] [Updated] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME) EMERSON WANG (Jira)
• [jira] [Resolved] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Bowen Li (Jira)
• [jira] [Closed] (FLINK-39040) allow additional json to be specified for the body request Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-39040) allow additional json to be specified for the body request Ferenc Csaky (Jira)
• [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
  • Re: [PR] [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment [flink] via GitHub
• [jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources ASF GitHub Bot (Jira)
• [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-120] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-1.20] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• [jira] [Assigned] (FLINK-39073) Idle source splits are picked by watermark alignment Rui Fan (Jira)
• [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
  • Re: [PR] [hotfix][infra][BP-2.2] Add .metals and .bloop into .gitignore (#27480) [flink] via GitHub
• [jira] [Created] (FLINK-39073) Idle source splits are picked by watermark alignment Efrat Levitan (Jira)
• [jira] [Updated] (FLINK-39067) Move Python docs to PyDocs ASF GitHub Bot (Jira)
• [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
  • Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
  • Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
  • Re: [PR] [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs [flink] via GitHub
• [jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry Natea Eshetu Beshada (Jira)
• [jira] [Assigned] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file Natea Eshetu Beshada (Jira)
• [jira] [Assigned] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink ASF GitHub Bot (Jira)
• [PR] [pipeline] Use GHA workflow triggers to run labeler workflow [flink-cdc] via GitHub
• [PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink] via GitHub
  • Re: [PR] [FLINK-30068][runtime] Add configurable commit failure strategy for S… [flink] via GitHub
• [jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file ASF GitHub Bot (Jira)
• [PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRe… [flink] via GitHub
  • Re: [PR] [FLINK-23886][runtime] Fix null column family handle in RocksDBFullRestoreOperation [flink] via GitHub
• [PR] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka] via GitHub
  • Re: [PR] Handle InvalidPidMappingException as known failure in KafkaCommitter [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter Natea Eshetu Beshada (Jira)
  • [jira] [Updated] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter Natea Eshetu Beshada (Jira)
• [jira] [Created] (FLINK-39072) Handle InvalidPidMappingException as known failure in KafkaCommitter Natea Eshetu Beshada (Jira)
• [PR] Select fileds rathert * to read snapshot data in case schema changes. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history ASF GitHub Bot (Jira)
• [PR] [FLINK-39069][SQL Client] Support saving and exporting SQL execution history [flink] via GitHub
  • Re: [PR] [FLINK-39069][SQL Client] Support saving and exporting SQL execution history [flink] via GitHub
• Re: [I] [Bug] Failed to connect to remote mcp server [flink-agents] via GitHub
• [jira] [Created] (FLINK-39071) Select fileds rathert * to read snapshot data incase schema changes. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-39070) Update Kafka parent connector David Radley (Jira)
• [jira] [Created] (FLINK-39069) [SQL Client] Support saving and exporting SQL execution history featzhang (Jira)
• [jira] [Created] (FLINK-39068) [SQL Client] Support saving and exporting SQL execution history featzhang (Jira)
• [PR] [hotfix] add .worktrees to .gitignore [flink] via GitHub
  • Re: [PR] [hotfix] add .worktrees to .gitignore [flink] via GitHub
• [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
  • Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
  • Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
  • Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
  • Re: [PR] [minor][hotfix] Update configOption name from `sink.job.id.prefix` to `job.id.prefix` [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-36796) oracle cdc supports pipeline configuration connector Yanquan Lv (Jira)
• [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] via GitHub
  • Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] via GitHub
• [jira] [Closed] (FLINK-38823) Error running wide table task peiyu (Jira)
• [jira] [Resolved] (FLINK-38512) Postgres YAML CDC support database name with middlescore Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-39047) Translate the Chinese documentation related to Transform Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38514) Postgres YAML CDC support UUID_ARRAY Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-39010) YAML Pipeline supports item subscription of variant types Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization Natea Eshetu Beshada (Jira)
• [jira] [Commented] (FLINK-35284) Streaming File Sink end-to-end test times out Natea Eshetu Beshada (Jira)
• [jira] [Reopened] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Piotr Nowojski (Jira)
• [jira] [Updated] (FLINK-39066) Fix fluss's metric Histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric Histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric Histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric Histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric histogram always return null Thorne (Jira)
  • [jira] [Updated] (FLINK-39066) Fix fluss's metric histogram always return null Thorne (Jira)
• [jira] [Updated] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API ASF GitHub Bot (Jira)
• [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
  • Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
  • Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
  • Re: [PR] [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API [flink] via GitHub
• [jira] [Commented] (FLINK-38988) Support INET_ATON and INET_NTOA functions for IP address conversion Liu (Jira)
• [jira] [Created] (FLINK-39067) Move Python docs to PyDocs Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-39064) Add built-in REGEXP_SPLIT function to split string by regular expression pattern Natea Eshetu Beshada (Jira)
• [jira] [Commented] (FLINK-38945) [FLIP-561] Restructure Flink documentation Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-39038) GitHub flink-cdc repository actions clean-up Leonard Xu (Jira)
• [jira] [Updated] (FLINK-39063) FIx some spelling mistakes in fluss connector Thorne (Jira)
  • [jira] [Updated] (FLINK-39063) FIx some spelling mistakes in fluss connector ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-39017) Flink WebUI Job graph node click interaction fails in Chrome 144+ (PointerEvents suppression) Martijn Visser (Jira)
• [D] Memory Framework Investigation [flink-agents] via GitHub
• [D] Agent Skills Investigation [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Natea Eshetu Beshada (Jira)
• [jira] [Updated] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager ASF GitHub Bot (Jira)
• [PR] [FLINK-32212][runtime] Fix infinite restart loop from BlobLibraryCach… [flink] via GitHub
  • Re: [PR] [FLINK-32212][runtime] Fix infinite restart loop from BlobLibraryCach… [flink] via GitHub
• [jira] [Closed] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing Natea Eshetu Beshada (Jira)
• [jira] [Commented] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing Natea Eshetu Beshada (Jira)
• [jira] [Assigned] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing Natea Eshetu Beshada (Jira)
• [jira] [Resolved] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Natea Eshetu Beshada (Jira)
• Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] via GitHub
  • Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] via GitHub
• [jira] [Commented] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy Taranpreet Kaur (Jira)
• [jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy Taranpreet Kaur (Jira)
• [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub
  • Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink] via GitHub

• Earlier messages