issues  

Messages by Thread

• • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
  • Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] via GitHub
• [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Qilong Wang (Jira)
• [jira] [Updated] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled Jira
  • [jira] [Updated] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled Jira
  • [jira] [Updated] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40302) Periodic materialization permanently stops after taking a native-format savepoint when the changelog state backend is enabled Jira
• [PR] [FLINK-40301][table] Merge Calc nodes before ChangelogNormalize projection pushdown [flink] via GitHub
  • Re: [PR] [FLINK-40301][table] Merge Calc nodes before ChangelogNormalize projection pushdown [flink] via GitHub
  • Re: [PR] [FLINK-40301][table] Merge Calc nodes before ChangelogNormalize projection pushdown [flink] via GitHub
• [PR] [integrations][openai] Preserve provider refusals in the Python message converter [flink-agents] via GitHub
  • Re: [PR] [integrations][openai] Preserve provider refusals in the Python message converter [flink-agents] via GitHub
  • Re: [PR] [integrations][openai] Preserve provider refusals in the Python message converter [flink-agents] via GitHub
  • Re: [PR] [integrations][openai] Preserve provider refusals in the Python message converter [flink-agents] via GitHub
  • Re: [PR] [integrations][openai] Preserve provider refusals in the Python message converter [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
  • [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize Qilong Wang (Jira)
• Re: [I] [Tech Debt] Warn when an action declares a return value [flink-agents] via GitHub
• Re: [PR] [python] warn when an action declares a return value [flink-agents] via GitHub
  • Re: [PR] [python] warn when an action declares a return value [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40297) Route TTL-aware value migration through the TypeSerializerSnapshot migrate hook ASF GitHub Bot (Jira)
• [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• [jira] [Closed] (FLINK-40187) Introduce DataType class in DataFrame API Dian Fu (Jira)
• [jira] [Updated] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types Liu Liu (Jira)
  • [jira] [Updated] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types Dian Fu (Jira)
  • [jira] [Updated] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40300) PyFlink Table API lit does not convert Python values to the required Java literal types Liu Liu (Jira)
• [jira] [Comment Edited] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE Qiu Yanjun (Jira)
• [jira] [Updated] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot ASF GitHub Bot (Jira)
• [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink] via GitHub
  • Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink] via GitHub
  • Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink] via GitHub
  • Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink] via GitHub
• [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)
• [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
  • Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
• [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
  • Re: [PR] [FLINK-40292][table-runtime] Add UdfMetrics helper for UDF metrics [flink] via GitHub
• [jira] [Created] (FLINK-40295) Document UDF metrics Weiqing Yang (Jira)
• [jira] [Updated] (FLINK-40295) Document UDF metrics Weiqing Yang (Jira)
• [jira] [Updated] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Weiqing Yang (Jira)
• [jira] [Created] (FLINK-40294) Instrument async scalar and table UDF calls with metrics Weiqing Yang (Jira)
• [jira] [Updated] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Weiqing Yang (Jira)
  • [jira] [Updated] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Weiqing Yang (Jira)
• [jira] [Updated] (FLINK-40292) Add UdfMetrics helper for UDF metrics Weiqing Yang (Jira)
  • [jira] [Updated] (FLINK-40292) Add UdfMetrics helper for UDF metrics Weiqing Yang (Jira)
  • [jira] [Updated] (FLINK-40292) Add UdfMetrics helper for UDF metrics ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40292) Add UdfMetrics helper for UDF metrics Weiqing Yang (Jira)
• [jira] [Updated] (FLINK-40170) Infer update-producing changelog mode for early-fire interval join ASF GitHub Bot (Jira)
• [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
  • Re: [PR] [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join [flink] via GitHub
• Re: [PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink] via GitHub
  • Re: [PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink] via GitHub
  • Re: [PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink] via GitHub
  • Re: [PR] [FLINK-38071][table] Add opt-in UDF metrics (FLIP-485) [flink] via GitHub
• [PR] [hotfix][java][python] Release skill repositories on any load failure and remove dead code [flink-agents] via GitHub
  • Re: [PR] [hotfix][java][python] Release skill repositories on any load failure and remove dead code [flink-agents] via GitHub
  • Re: [PR] [hotfix][java][python] Release skill repositories on any load failure and remove dead code [flink-agents] via GitHub
  • Re: [PR] [hotfix][java][python] Release skill repositories on any load failure and remove dead code [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-40168) Thread the EARLY_FIRE hint into the interval join Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-40215) AvroSerializer is not adhering to pojo rules of avro generation Bettle (Jira)
• [jira] [Commented] (FLINK-39505) Add Python-side tests for recently added Table API methods Bettle (Jira)
• [jira] [Updated] (FLINK-40291) instrumentation scope in otel metric adaptor is wrongly hardcoded ASF GitHub Bot (Jira)
• [PR] [FLINK-40291][metrics-otel] Fix instrumentation scope hardcoded [flink] via GitHub
  • Re: [PR] [FLINK-40291][metrics] Fix instrumentation scope hardcoded [flink] via GitHub
• [jira] [Created] (FLINK-40291) instrumentation scope in otel metric adaptor is wrongly hardcoded Kaiqi Dong (Jira)
• [jira] [Updated] (FLINK-40290) Histogram summary emits duplicate quantile 1.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-40290][metrics] Fix duplicate quantile 1.0 in OpenTelemetry histogram summary [flink] via GitHub
  • Re: [PR] [FLINK-40290][metrics] Fix duplicate quantile 1.0 in OpenTelemetry histogram summary [flink] via GitHub
  • Re: [PR] [FLINK-40290][metrics] Fix duplicate quantile 1.0 in OpenTelemetry histogram summary [flink] via GitHub
• [jira] [Created] (FLINK-40290) Histogram summary emits duplicate quantile 1.0 Kaiqi Dong (Jira)
• [jira] [Updated] (FLINK-40289) Window Top-N examples are not reproducible in streaming mode ASF GitHub Bot (Jira)
• [PR] [FLINK-40289][docs] Clarify watermark requirements in Window Top-N examples [flink] via GitHub
  • Re: [PR] [FLINK-40289][docs] Clarify watermark requirements in Window Top-N examples [flink] via GitHub
• [jira] [Created] (FLINK-40289) Window Top-N examples are not reproducible in streaming mode Hancheng Deng (Jira)
• [PR] Feature/476 auto resolve memory ref [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
  • Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40288) Multiple JoinSemanticTests fail ASF GitHub Bot (Jira)
• [PR] [FLINK-40288][table] Use correct type in `ExprCodeGenerator#visitFieldAccess` [flink] via GitHub
  • Re: [PR] [FLINK-40288][table] Use correct type in `ExprCodeGenerator#visitFieldAccess` [flink] via GitHub
  • Re: [PR] [FLINK-40288][table] Use correct type in `ExprCodeGenerator#visitFieldAccess` [flink] via GitHub
• [jira] [Created] (FLINK-40288) Multiple JoinSemanticTests fail Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39095][docs] Document EXPLAIN CHANGELOG_MODE for streaming queries [flink] via GitHub
• Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink] via GitHub
• Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] via GitHub
  • Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] via GitHub
• [PR] [BP-2.3][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
• [PR] [BP-2.1][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
• [PR] [BP-2.0][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
• [PR] [BP-2.2][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
• [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
  • Re: [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
  • Re: [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
  • Re: [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
  • Re: [PR] [hotfix][runtime] Close the Kafka consumer when the producer fails to close [flink-agents] via GitHub
• [PR] [BP-1.20][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40272][build] Add cache file for checkstyle [flink] via GitHub
• Re: [PR] [FLINK-39986][table-planner][python] Support Common Sub-expression Elimination (CSE) for Python UDFs [flink] via GitHub
• [jira] [Updated] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink vaquar khan (Jira)
  • [jira] [Updated] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink vaquar khan (Jira)
• [jira] [Created] (FLINK-40287) Provide a first-party, governed MCP server for Apache Flink vaquar khan (Jira)
• [jira] [Updated] (FLINK-40017) Introduce Seaweedfs in native-s3-fs ASF GitHub Bot (Jira)
• [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
  • Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
  • Re: [PR] [java][python] IBM watsonx.ai chat model integration [flink-agents] via GitHub
• Re: [PR] [FLINK-38522][cdc connector mysql] use ssl for BinaryLogClient when searching for binlog offset for starting mysql cdc from timestamp [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40286) Adapt keyless upsert sink should fall back to retract to MiscSemanticTests ASF GitHub Bot (Jira)
• [PR] [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests` [flink] via GitHub
  • Re: [PR] [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests` [flink] via GitHub
  • Re: [PR] [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests` [flink] via GitHub
• [jira] [Created] (FLINK-40286) Adapt keyless upsert sink should fall back to retract to MiscSemanticTests Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader Edson Wang (Jira)
  • [jira] [Commented] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader Arvid Heise (Jira)

• Earlier messages
• Later messages