dev  

Messages by Thread

• [jira] [Created] (FLINK-40379) AdaptiveScheduler is in restart loop when task cancellation consistently times out Anton Kalashnikov (Jira)
• [jira] [Created] (FLINK-40378) Support GROUP BY position, ORDER BY ALL, and GROUP BY ALL in Flink SQL Tisya Bhatia (Jira)
• [jira] [Created] (FLINK-40377) MatchRecognize fails with Unsupported RelDataType: UNKNOWN while json plan generation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40376) Integrate VARIANT type to the flink-json format Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-40375) Operator API tests: kube-API-server tests silently skipped in CI (Tests run: 0) Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40374) Redeploying a FlinkSessionJob from an explicit savepoint fails with IllegalArgumentException: Cannot parse JobID from "null" if the job was previously suspended Dale Lane (Jira)
• [jira] [Created] (FLINK-40373) JSON_VALUE might fail on code generation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40372) [Kubernetes Operator] JOSDK per-resource metrics are not unregistered after resource cleanup liting liu (Jira)
• [jira] [Created] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Kushagra Tyagi (Jira)
• [jira] [Created] (FLINK-40370) Bytes-backed decimal logical types corrupt PyFlink GenericRecordAvroTypeInfo JVM/Python serialization Joey Pereira (Jira)
• [jira] [Created] (FLINK-40369) ARRAY functions might lead to wrong results Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute David Anderson (Jira)
• [jira] [Created] (FLINK-40367) Make Kafka consumer poll timeout configurable Robert Metzger (Jira)
• [jira] [Created] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40365) Job Management docs: "Config Requirement" for savepoint upgrade mode is incorrect Dale Lane (Jira)
• [jira] [Created] (FLINK-40364) flink-connector-pulsar Flink 2.x support Hongbo Miao (Jira)
• [jira] [Created] (FLINK-40363) MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN is unstable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40362) DynamicKafkaSource idle reader never finishes when no-more-splits precedes the metadata update Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40361) Extract license check into a separate job in Azure Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40360) Fix DECIMAL precision truncation when arithmetic result precision exceeds 19 digits Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40359) Split FetchedChannelStateReader into drain-side and checkpoint-side interfaces Rui Fan (Jira)
• [jira] [Created] (FLINK-40358) Use native S3 filesystem for all S3 end-to-end tests Samrat Deb (Jira)
• [DISCUSS] Long-term recommendation for durable checkpoint storage Ordencia Wu
  • RE: [DISCUSS] Long-term recommendation for durable checkpoint storage Ordencia Wu
  • Re: [DISCUSS] Long-term recommendation for durable checkpoint storage Gabor Somogyi
• [jira] [Created] (FLINK-40357) Add ARRAY_FLATTEN function Shengyao He (Jira)
• [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Luca Castelli via dev
  • Re: [DISCUSS] Flink Kubernetes Operator: One-shot statelessRestartNonce Gyula Fóra
  • 退订 Yanko24
  • 退订 18524655605
• [DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Piotr Nowojski
  • Re:[DISCUSS] FLIP-605: State catch-up of streaming jobs state using BATCH execution mode Xuyang
• [jira] [Created] (FLINK-40356) Add MAP_FROM_ENTRIES function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40355) Add MAP_CONTAINS_KEY function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend Mykola Lukashchuk (Jira)
• Fwd: [DISCUSS] FIP-49: Fluss Gateway REST API Hongshun Wang
  • Re: [DISCUSS] FIP-49: Fluss Gateway REST API Junbo Wang
• [jira] [Created] (FLINK-40353) Leverage RocksDB ordered MapState TemporalRowTimeJoinOperator Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-40352) Add CloseableIterator support to MapState Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-40351) Reduce heap footprint of RocksDBMapState's iterator Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-40350) LPAD/RPAD split supplementary-plane characters into unpaired surrogates sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Hongshun Wang (Jira)
• [jira] [Created] (FLINK-40348) ZSTD fails at runtime with the SQL Kafka Connector Kumar Mallikarjuna (Jira)
• [jira] [Created] (FLINK-40347) Introduce scan.partition.boundary-query and scan.partition.use-physical-id config options Chanhae Oh (Jira)
• [jira] [Created] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" sepuri sai krishna (Jira)
• Reopening FLIP-505 (Flink History Server Remote Fetch) archit goyal
• [jira] [Created] (FLINK-40345) Buffer is recycled twice in FilteringHandler#recoverWithFiltering when delivery fails Rui Fan (Jira)
• [jira] [Created] (FLINK-40344) Computed grouping expressions cannot be selected in Table API aggregations Liu Liu (Jira)
• [FLINK-40143] Request for review and assignment RL.93 c
• [jira] [Created] (FLINK-40343) Support row‑level precise batch incremental update for Materialized Table with Left Join support colagy wang (Jira)
• [jira] [Created] (FLINK-40342) Support schema event listener melin (Jira)
• [jira] [Created] (FLINK-40341) flink-kubernetes-operator: Bump jackson-bom to 2.21.5 to retire 11 advisories Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40340) UnsupportedOperationException for MySQL ZEROFILL types without UNSIGNED Zhuojun Jiang (Jira)
• [jira] [Created] (FLINK-40339) WatermarkCompactingSinkMaterializer reads MapState entries after removing them Gustavo de Morais (Jira)
• [DISCUSS] FLIP-XXX : Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
• Kubernetes Operator 1.16.0 release planning Gyula Fóra
  • Re: Kubernetes Operator 1.16.0 release planning Ferenc Csaky
  • Re: Kubernetes Operator 1.16.0 release planning Dennis-Mircea Ciupitu
  • Re: Kubernetes Operator 1.16.0 release planning P Sinha
  • Re: Kubernetes Operator 1.16.0 release planning Weiqing Yang
• [jira] [Created] (FLINK-40338) ELT() throws ClassCastException when the index argument is not INT sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40337) Preserve operator precedence in generated Janino expressions Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends Mate Czagany (Jira)
• [jira] [Created] (FLINK-40335) Hybrid shuffle index files can be corrupted by a ByteBuffer shared across result partitions Mate Czagany (Jira)
• [jira] [Created] (FLINK-40334) Insert-only input should not be materialized under upsert-materialize FORCE Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40333) Move setLastReconciledSpec to after successful transition start for BG deployments Gyula Fora (Jira)
• [jira] [Created] (FLINK-40332) FileCatalogStore is not validating catalog names Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink Hongshun Wang (Jira)
• Re: [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
  • [DISCUSS] FLIP-563: Support provided lib archives for YARN application mode archit goyal
• [jira] [Created] (FLINK-40330) [Kubernetes HA] Orphaned per-job leader entries accumulate in the cluster ConfigMap after interrupted cleanup or leadership loss Chaitanya Waikar (Jira)
• [jira] [Created] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication Gyula Komlossi (Jira)
• [jira] [Created] (FLINK-40328) Add MariaDB-cdc connector docs sanqingleo (Jira)
• [jira] [Created] (FLINK-40327) ForSt async multiGet leaks a native ReadOptions per read batch Yordan Pavlov (Jira)
• [jira] [Created] (FLINK-40326) GatedRateLimiter admits more events per cycle than configured Aleksandr Savonin (Jira)
• [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Timo Walther
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Mate Czagany
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Gustavo de Morais
  • Re: [DISCUSS] FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Ramin Gharib
• [jira] [Created] (FLINK-40325) Support Kafka as a CDC Source Connector in Flink CDC Pipeline Gopal Dirisala (Jira)
• [DISCUSS] Operational Agent Skills for Apache Flink : provider-agnostic troubleshooting & debugging guides Jim Pizagno
• [jira] [Created] (FLINK-40324) Append-only should stay unmaterialized without an ON CONFLICT clause Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40323) [cdc-common] Support JSON Data Type in Flink CDC Thorne (Jira)
• [jira] [Created] (FLINK-40322) PyFlink ArrayType/MultisetType.from_sql_type calls to_sql_type instead Nikolaus Schuetz (Jira)
• [jira] [Created] (FLINK-40321) [Flink CDC][Postgres] Table-level DDL metrics are not updated for schema change records Jira
• [jira] [Created] (FLINK-40320) CI: community review labeling counts the PR author's and co-authors' own reviews Purushottam Sinha (Jira)
• Hackathon task list needed - 10 weeks out Bowen, Rich
• [jira] [Created] (FLINK-40319) Add a raw-bytes accessor for VARIANT string values, and use it to validate UTF-8 on the character-string cast and to let a string variant reach a binary target Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40318) Add a validation entry point for a VARIANT binary Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40317) DeletesByKeySemanticTests is unstable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40316) Add MariaDB CDC SQL connector sanqingleo (Jira)
• [jira] [Created] (FLINK-40315) Add MariaDB CDC DataStream source sanqingleo (Jira)
• [jira] [Created] (FLINK-40314) Introduce a MariaDB CDC connector sanqingleo (Jira)
• [jira] [Created] (FLINK-40313) Support collection constructors and functions in YAML Transform Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40312) Support EXTRACT, date-part functions, and interval arithmetic in YAML Transform Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40311) Rename EndiannessAccessChecks to EndiannessAccessChecksTest as it is not executed in CI Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40310) Rename CsvBulkWriterIT to CsvBulkWriterTest as it is not executed in CI Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40309) ML_PREDICT streaming semantic tests fail upsert-key validation Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40308) Table planner: 14 test classes named *Tests never execute in CI or locally Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40307) RestoreTestCompleteness was never executed in CI Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40306) Restore tests are absent for BatchExecHashAggregate and BatchExecNestedLoopJoin Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40305) VARIANT string and object key decoding ignores the UTF-8 charset Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments Qilong Wang (Jira)
• [jira] [Created] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Qilong Wang (Jira)
• [jira] [Created] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled Jira
• [jira] [Created] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
• [jira] [Created] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types Liu Liu (Jira)
• [jira] [Created] (FLINK-40299) Add end-to-end state migration tests for RowData schema evolution Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40298) Opt-in name-based state schema evolution for RowData Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40297) Route TTL-aware value migration through the TypeSerializerSnapshot migrate hook Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40295) Document UDF metrics Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40292) Add UdfMetrics helper for UDF metrics Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40291) instrumentation scope in otel metric adaptor is wrongly hardcoded Kaiqi Dong (Jira)
• [jira] [Created] (FLINK-40290) Histogram summary emits duplicate quantile 1.0 Kaiqi Dong (Jira)
• [jira] [Created] (FLINK-40289) Window Top-N examples are not reproducible in streaming mode Hancheng Deng (Jira)
• [jira] [Created] (FLINK-40288) Multiple JoinSemanticTests fail Sergey Nuyanzin (Jira)
• Confluence Wiki Access Request - vaquarkhan1 vaquar khan
• [jira] [Created] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink vaquar khan (Jira)
• [RESULT][VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
• [jira] [Created] (FLINK-40286) Adapt keyless upsert sink should fall back to retract to MiscSemanticTests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40285) MLPredictSemanticTests fails because of ON CONFLICT Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40284) A number of tests ending with Tests in class name are skipped from CI/local tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40283) CorrelateITCase2 is not executed while running tests locally or via CI Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40282) Expand and correct the concepts Glossary Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-40281) Improve HTTP sink failure observability Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40279) Add HTTP sink parity for OIDC, proxy, and HTTP version configuration Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40280) Document HTTP sink retry, error handling, and configuration parity Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40278) Define and implement HTTP sink batch retry semantics Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40277) Add HTTP sink response classification and retry support Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40276) Add HTTP sink response classification and retry support Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40275) Improve HTTP sink parity with HTTP lookup source Bharath Reddy Gunapati (Jira)
• [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI P Sinha
  • Re: [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI Yuepeng Pan
  • Re: [DISCUSS] FLINK-39566: Checkpoint duration timeline view in the Web UI Ferenc Csaky
• [jira] [Created] (FLINK-40274) Flink CDC Remove unsupported kubernetes-session from target option help message jaejun lee (Jira)
• [jira] [Created] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40272) Add cache file for checkstyle Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40271) Group window properties produce invalid SQL in QueryOperation#asSerializableString Timo Theusner (Jira)
• [jira] [Created] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names) Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream Rui Fan (Jira)
• [jira] [Created] (FLINK-40268) Add new JSON_TYPE built-in function Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER Arvid Heise (Jira)
• [jira] [Created] (FLINK-40266) MAX_WATERMARK might not be emitted for finished operators Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters Shuo Cheng (Jira)
• FLINK-39900 - Change in review Francis Altomare
• [jira] [Created] (FLINK-40264) nested legacyTimestampMapping Pritam Kumar (Jira)
• [jira] [Created] (FLINK-40263) Enum symbol validation Pritam Kumar (Jira)
• [jira] [Created] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters Pritam Kumar (Jira)
• [jira] [Created] (FLINK-40261) Support Set semantics, pass-through columns and ROW Value State for Python PTF Wang Chengyu (Jira)
• [jira] [Created] (FLINK-40260) Support Python PTF definition API and the stateless runtime path Wang Chengyu (Jira)
• [jira] [Created] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• [jira] [Created] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• [jira] [Created] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira)
• [jira] [Created] (FLINK-40256) Docs: config options in sub-packages are silently missing from the configuration reference Purushottam Sinha (Jira)
• [DISCUSS] FLIP-603: [FileSystems] GCS SDK-native filesystem Samrat Deb
• [jira] [Created] (FLINK-40255) COMPILE PLAN fails for any plan containing a VARIANT type Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40254) Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file wenhao.yu (Jira)
• [jira] [Created] (FLINK-40252) Graceful TaskManager termination on Kubernetes Gangadharayya Hiremath (Jira)
• [jira] [Created] (FLINK-40251) Support Process Table Function (PTF) in Python Table API Wang Chengyu (Jira)
• [jira] [Created] (FLINK-40250) Non-comparable types in ORDER BY / GROUP BY throw UnsupportedOperationException instead of a clean ValidationException Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40249) JDBC Connector: Bump Flink, PostgreSQL driver, and other dependency versions Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40248) Move publishing nightly snapshots from AZP to GHA Dale Lane (Jira)
• [jira] [Created] (FLINK-40247) Umbrella: FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh (Jira)
• [jira] [Created] (FLINK-40246) flink-kubernetes-operator bundles vulnerable logback-core 1.2.13 (CVE-2024-12798, CVE-2025-11226, CVE-2026-1225) Yishai Greenberg (Jira)
• [jira] [Created] (FLINK-40245) Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBuilder Nikita Singhvi (Jira)
• [jira] [Created] (FLINK-40244) Support YashanDB in flink-connector-jdbc Linsert (Jira)
• [RESULT][VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
• [jira] [Created] (FLINK-40243) Bump postgresql jdbc driver from 42.5.6 to 42.7.13 Siddharth R (Jira)
• [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
  • Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator P Sinha
  • Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
  • Re: [DISCUSS] running Flink jobs in MiniCluster using the Kubernetes Operator P Sinha
• [jira] [Created] (FLINK-40242) Support filtered pagination splits using a supporting index for efficient queries Michael (Jira)
• [jira] [Created] (FLINK-40241) Support VARIANT as column type in the 'raw' format Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40240) Support additional Flink SQL regular expression functions in YAML Transform Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40239) Support additional Flink SQL regular expression functions in YAML Transform Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40238) Expose numberOfConsecutiveFailedCheckpoints as a JobManager-level gauge Yang Li (Jira)
• [VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
  • Re:[VOTE] FLIP-485: Add UDF Metrics Xuyang
  • Re: [VOTE] FLIP-485: Add UDF Metrics Yuepeng Pan
  • Re: [VOTE] FLIP-485: Add UDF Metrics Peter Huang
  • Re: [VOTE] FLIP-485: Add UDF Metrics P Sinha
  • Re: [VOTE] FLIP-485: Add UDF Metrics Weiqing Yang
• [jira] [Created] (FLINK-40237) CepOperator does not clean up expired NFA state in processing-time timer callbacks YuXiang Zhou (Jira)
• [ANNOUNCE] Apache Flink Agents 0.3.1 released wenjin
• [jira] [Created] (FLINK-40236) _infer_type infers ARRAY<NULL> for a list whose first element is None Nikolaus Schuetz (Jira)
• [RESULT][VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
• [jira] [Created] (FLINK-40235) FLIP-27 source subtask stalls the watermark after all its splits finish Jing Hung (Jira)
• [jira] [Created] (FLINK-40234) Busy subtask thread may cause splits to be marked as idle erroneously and cause dropped records Keith Lee (Jira)
• [ANNOUNCE] Apache flink-connector-jdbc 3.4.0 & 4.1.0 released Yuepeng Pan
• [jira] [Created] (FLINK-40233) JSON functions return NULL when sharing a parsed input Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40231) HistoryServerArchiveFetcherTest.testArchiveStateTransition is flaky in CI Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null Fan Deng (Jira)

• Earlier messages