dev  

Messages by Thread

• [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)
• [jira] [Created] (FLINK-40230) StringToBinary and RawToBinary cast rules might generate runtime code with useless array copy Sergey Nuyanzin (Jira)
• [RESULT][VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 wenjin
• [jira] [Created] (FLINK-40229) Introduce HttpSinkConfig and wire core sink options via ReadableConfig Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40228) Bump frontend-maven-plugin to 2.0.1 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore Yuhan Hao (Jira)
• [jira] [Created] (FLINK-40226) Standalone session cluster JM recovery enters infinite MISSING loop and fails with HTTP 409 on TM Deployment when TaskManager pods still exist Aniruddh J (Jira)
• [jira] [Created] (FLINK-40225) JSON parsing for json functions accepts trailing content after the first value Gustavo de Morais (Jira)
• Flink operator stuck with "Job not found" Filippo Ghibellini
  • Re: Flink operator stuck with "Job not found" Gyula Fóra
• [jira] [Created] (FLINK-40224) Move CI scripts used by both GHA and AZP out of tools/azure-pipelines Dale Lane (Jira)
• [jira] [Created] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40222) ValueLiteralExpression.asSerializableString() drops leading-field precision for INTERVAL literals Timo Theusner (Jira)
• [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
  • Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Leonard Xu
  • Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Yuepeng Pan
  • Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Rui Fan
  • Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Yanquan Lv
  • Re: [VOTE] FLIP-602: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion Chanhae Oh
• RE: Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Wenhao Ji
  • Re: Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector Wenhao Ji
• FLINK-38023: PR #28161 code review request Avi Sanwal
  • Re: FLINK-38023: PR #28161 code review request Avi Sanwal
• [jira] [Created] (FLINK-40221) Update weekly.yml of jdbc connector for jdbc-3.4.0 and jdbc-4.1.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40220) Update the version of JDBC connector docs Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40219) Incorrect output type of LateralSnapshotJoin for build-side time attribute with inconsistent nullability Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40218) Allow building a Variant from a token source, without a String round-trip Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40217) Variant.toJson() can emit invalid JSON for numbers that overflow to non-finite doubles Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40216) [cdc-base] Meta groups of finished snapshot splits become inconsistent after restore due to lexicographic re-sorting of assigned splits kim (Jira)
• FLINK-37686: ForSt consecutive checkpoint failures after JM deletes reused files (production report, 2.2.1) Francis Altomare
• [jira] [Created] (FLINK-40215) AvroSerializer is not adhering to pojo rules of avro generation Taranpreet Kaur (Jira)
• [jira] [Created] (FLINK-40214) JSON_OBJECTAGG produces incorrect keys when key and value use the same column Qilong Wang (Jira)
• [jira] [Created] (FLINK-40213) Preserve JSON_OBJECTAGG key when wrapping value Qilong Wang (Jira)
• Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Ferenc Csaky
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Ferenc Csaky
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Leonard Xu
  • Re: Help Needed for JDBC Release v3.4.0 & v4.1.0 Yuepeng Pan
• Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
  • Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
  • Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
  • Re: Introducing Cobble-flink: Observable and Consumable State with Disaggregated Storage Zakelly Lan
• [jira] [Created] (FLINK-40212) Add Regional Checkpoint user documentation raoraoxiong (Jira)
• [jira] [Created] (FLINK-40211) Add Regional Checkpoint metrics, REST API and Web UI support raoraoxiong (Jira)
• [jira] [Created] (FLINK-40210) Add Per-Region timeout handling and bounded source forced global checkpoint raoraoxiong (Jira)
• [jira] [Created] (FLINK-40209) Introduce Regional Checkpoint core mechanism and notification dispatch raoraoxiong (Jira)
• [jira] [Created] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-40207) Make NaN and Infinity case-insensitive Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40206) Upgrade pulsar client to latest patch version to address critical vulnerabilities Nikola Stanisavljevic (Jira)
• [jira] [Created] (FLINK-40205) PTF are failing in case of usage multiple PARTITION/ORDER BY Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40204) Introduce statement-level codegen for YAML Transform expressions Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40203) Add explicit option for Flink SQL-compatible YAML Transform expression semantics Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40202) HybridSplitAssigner may initialize enumerator metrics concurrently with snapshot split assignment Hongshun Wang (Jira)
• [VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
  • Re: [VOTE] FLIP-527: State Schema Evolution for RowData gyula . fora
  • Re: [VOTE] FLIP-527: State Schema Evolution for RowData Shengkai Fang
  • Re: [VOTE] FLIP-527: State Schema Evolution for RowData Leonard Xu
  • Re: [VOTE] FLIP-527: State Schema Evolution for RowData Zakelly Lan
  • Re: [VOTE] FLIP-527: State Schema Evolution for RowData Weiqing Yang
• [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Rich Bowen
  • Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Weiqing Yang
  • Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Dian Fu
  • Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.3.1, release candidate #1 Zhu Zhu
• [jira] [Created] (FLINK-40201) [Oracle CDC] Fix compatibility with Oracle 26ai and Debezium 3.4.2.Final Mohammad Suhel Ksolves Cassandra Experties (Jira)
• [jira] [Created] (FLINK-40200) TaskManager locking up in org.rocksdb.Checkpoint.createCheckpoint Efrat Levitan (Jira)
• [jira] [Created] (FLINK-40199) Add generic connector source and sink APIs to PyFlink DataFrame Dian Fu (Jira)
• [jira] [Created] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40196) Add missing-value handling to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40195) Flink kubernetes operator certificate secret name should be configurable Jira
• [jira] [Created] (FLINK-40194) Add drop_duplicates to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40193) Add join_lateral support to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40191) Add aggregation support to DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40190) Add data creation and conversion APIs to PyFlink DataFrame Dian Fu (Jira)
• [RESULT][VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4 Yuepeng Pan
• [RESULT][VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4 Yuepeng Pan
• [jira] [Created] (FLINK-40189) Found Security Vunerability in IndexGeneratorFactory.java Taranpreet Kaur (Jira)
• [jira] [Created] (FLINK-40188) Check connection string at the start of job for opensearch distributor Taranpreet Kaur (Jira)
• [jira] [Created] (FLINK-40187) Introduce DataType class in DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40186) Support the basic functionality of DataFrame API Dian Fu (Jira)
• [jira] [Created] (FLINK-40185) Introduce DataFrame API in PyFlink Dian Fu (Jira)
• [jira] [Created] (FLINK-40184) Remove inconsistency checks from DynamoDB Connector Abhi Gupta (Jira)
• [jira] [Created] (FLINK-40183) Add regression coverage for CheckpointCoordinator scheduling amirhossein deljouyi (Jira)
• [jira] [Created] (FLINK-40182) ArrayToArray and MapToMap generate code which might fail with NPE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40181) Make spotless checking changes since last green build in ci Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40180) Non-keyed state support in StateCatalog Gyula Fora (Jira)
• [jira] [Created] (FLINK-40179) Support windowed states in state catalog Gyula Fora (Jira)
• [jira] [Created] (FLINK-40178) Keyed state cataloging integration test Gyula Fora (Jira)
• [jira] [Created] (FLINK-40177) Support reading Keyed and Flattened Keyed states Gyula Fora (Jira)
• [jira] [Created] (FLINK-40176) Introduce basic StateCatalog functionality Gyula Fora (Jira)
• [jira] [Created] (FLINK-40175) FLIP-599: State Catalog Gyula Fora (Jira)
• [RESULT][VOTE] FLIP-599: State Catalog Gyula Fóra
• [jira] [Created] (FLINK-40173) Add restore coverage for early-fire interval join Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40174) Document the EARLY_FIRE hint for interval joins Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40171) Emit and retract early-fire results in the interval join operator Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40172) Support processing-time early fire on a row-time interval join Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40169) Add target option to the EARLY_FIRE hint Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40167) Add EARLY_FIRE join hint surface and option validation Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join Weiqing Yang (Jira)
• [RESULT][VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink Dian Fu
• [jira] [Created] (FLINK-40166) SQL query parsing fails if current catalog is unreachable Dale Lane (Jira)
• [jira] [Created] (FLINK-40165) Add docs check to Github Actions pipeline for pull requests Dale Lane (Jira)
• [jira] [Created] (FLINK-40164) FlinkSessionJob's lifecycleState stays "UPGRADING" even after it's suspended successfully Milind L (Jira)
• [jira] [Created] (FLINK-40163) Add a new baseline nightly build to the Github Actions pipeline Dale Lane (Jira)
• [jira] [Created] (FLINK-40162) Fast-running FlinkSessionJob does not reflect actual state of the job Milind L (Jira)
• Flip-587 David Radley
  • Re: Flip-587 gyula . fora
• [jira] [Created] (FLINK-40161) Log original MySQL DDL events before parsing Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40160) Casting 'NaN' to Float or Double throws CompileException Ramin Gharib (Jira)
• Re: Reviewers for Kafka Connector Projection Pushdown Farooq Qaiser via dev
• Re: Possible race in MapState#asyncPutAll on ForSt: chained reads see keys but null values Zakelly Lan
• [jira] [Created] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Bread S (Jira)
• [jira] [Created] (FLINK-40158) Add translation rules for SNAPSHOT function in batch mode Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40157) MapState#asyncPutAll on ForSt: reads chained on the returned StateFuture see the new keys but null values Francis (Jira)
• [jira] [Created] (FLINK-40156) FLIP-600: Independent Checkpoint Based On Pipeline Region raoraoxiong (Jira)
• [jira] [Created] (FLINK-40155) Kubernetes Operator: support and end-to-end test Helm 4 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40154) Upgrade Parquet dependency to 1.16.0 David Chaava (Jira)
• [jira] [Created] (FLINK-40153) CREATE TABLE LIKE cannot resolve inherited metadata columns in a derived watermark expression lincoln lee (Jira)
• [jira] [Created] (FLINK-40152) PostgreSQL CDC connector captures case-variant tables when only one is specified Xin Chen (Jira)
• [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gyula Fóra
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Dominik.Buenzli
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Michal Stutzmann
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) Gustavo de Morais
  • Re: [DISCUSS] FLIP-XXXX: Higher-Order Functions in Flink SQL (TRANSFORM and ARRAY_FILTER) David Anderson
• [jira] [Created] (FLINK-40151) Align YAML Transform BETWEEN, IN, and LIKE semantics with Flink SQL Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40150) Remove assumeTrue with cluster rebuild from RescaleTimelineITCase Matthias Pohl (Jira)
• [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Jim Hughes via dev
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Timo Walther
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-XXX: Add support for GROUP BY <ordinal>, GROUP BY ALL, and ORDER BY ALL Tisya Bhatia via dev
• [jira] [Created] (FLINK-40149) Rename lookup option asyncPolling to async-polling for Flink naming consistency Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40148) TableIdRouter resolves wrong sink table when source regex has multi-digit suffix and sink-table has no back-reference peiyu (Jira)
• [jira] [Created] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation Fred Teunissen (Jira)
• [jira] [Created] (FLINK-40146) Support AlterTableCommentEvent in StarRocks sink Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40145) flink-model-triton javadoc fails on JDK 11: kotlin.stdlib split-package Martijn Visser (Jira)
• [jira] [Created] (FLINK-40144) Avoid query database when only get table column ouyangwulin (Jira)
• [jira] [Created] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options caosurong (Jira)
• [jira] [Created] (FLINK-40142) [Table SQL / API] Support partition transform expressions in PARTITIONED BY clause liting liu (Jira)
• [jira] [Created] (FLINK-40141) Make IS_DECIMAL, IS_DIGIT, and IS_ALPHA return NULL for NULL input dylanhz (Jira)
• [jira] [Created] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40138) Migration test snapshot generator does not drive the JUnit 5 lifecycle, breaking snapshot generation for JUnit-5-migrated tests in flink-tests David Anderson (Jira)
• [jira] [Created] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown Bowen Li (Jira)

• Earlier messages
• Later messages