dev  

Messages by Thread

• [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)
• [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
  • Re: Flink operator stuck with "Job not found" Filippo Ghibellini via dev
• [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
  • 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)

• Earlier messages
• Later messages