issues  

Messages by Thread

• • [jira] [Commented] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Dawid Wysakowicz (Jira)
• [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
  • [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
  • [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
  • [jira] [Comment Edited] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Chesnay Schepler (Jira)
  • [jira] [Commented] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory ASF GitHub Bot (Jira)
• [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
  • Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
  • Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
  • Re: [PR] [FLINK-37955] Don't load all records into main memory to avoid OOM [flink] via GitHub
• [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38223) testConstraintsAfterRestart is flaky on master Gustavo de Morais (Jira)
• [PR] Remove redundant implementation of Namespaced [flink-kubernetes-operator] via GitHub
  • Re: [PR] Remove redundant implementation of Namespaced [flink-kubernetes-operator] via GitHub
  • Re: [PR] Remove redundant implementation of Namespaced [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-38198) Support WITH Clause in CREATE FUNCTION Statement in Flink SQL Dawid Wysakowicz (Jira)
• [PR] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
  • Re: [PR] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with java resource providers. [flink-agents] via GitHub
• [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
  • Re: [I] [Feature] [api][python][java] Support serialize and deserialize AgentPlan with python resource providers. [flink-agents] via GitHub
• [jira] [Created] (FLINK-38222) Upgrade HBase client version to 2.6 Mate Czagany (Jira)
• [PR] Fix usage of deprectaed method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix usage of deprecated method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix usage of deprecated method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix usage of deprecated method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix usage of deprecated method createOrUpdate from fabric8 [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names ASF GitHub Bot (Jira)
• [PR] [FLINK-38221][pipeline-connector][postgres] Fix critical partition table discovery bug causing CDC data loss [flink-cdc] via GitHub
• [PR] Add .vscode into .gitignore [flink-kubernetes-operator] via GitHub
  • Re: [PR] Add .vscode into .gitignore [flink-kubernetes-operator] via GitHub
  • Re: [PR] Add .vscode into .gitignore [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-38221) PostgreSQL CDC fails to capture data from partition tables when configured with parent table names tchivs (Jira)
• [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
  • Re: [PR] [Feature] [API] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] via GitHub
• [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] via GitHub
• Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37156] [cdc-composer/cli] pipeline supports collecting data once and writing it to multiple sinks. [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Dawid Wysakowicz (Jira)
  • [jira] [Updated] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Dawid Wysakowicz (Jira)
• [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
  • Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
  • Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
  • Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
  • Re: [PR] [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources [flink] via GitHub
• [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
  • [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
  • [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Timo Walther (Jira)
  • [jira] [Updated] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Dawid Wysakowicz (Jira)
• [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
  • Re: [PR] [FLINK-38219][table-runtime] Set row kind once before state manipulation [flink] via GitHub
• Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
  • Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
  • Re: [PR] [Flink-36980] [cdc-connect] Build a new introductory practice "Streaming ELT from MySQL to Kafka" [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38220) Adjust JoinToMultiJoinRule to support different types of source Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38219) Manipulate state in MultiJoin with fixed row kind Gustavo de Morais (Jira)
• Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] via GitHub
• [I] [Feature] [api] Support Event Logger and Event Listener in Java [flink-agents] via GitHub
• Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] via GitHub
• [PR] [Integration][ChatModel] Add reasoning extraction in OllamaChatModel [flink-agents] via GitHub
  • Re: [PR] [Integration][ChatModel] Add reasoning extraction in OllamaChatModel [flink-agents] via GitHub
• [I] [Feature][Ollama] Add `extract_reasoning` flag to `OllamaChatModel` to capture `<think>` blocks into extra_args [flink-agents] via GitHub
  • Re: [I] [Feature][Ollama] Add `extract_reasoning` flag to `OllamaChatModel` to capture `<think>` blocks into extra_args [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed Rui Fan (Jira)
• [jira] [Resolved] (FLINK-38142) Bump the version of Paimon flink to 1.2.0 Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-38191) [Document] Add document for Fluss pipeline connector JunboWang (Jira)
• [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38059][doc] Add fluss pipeline connector documentation [flink-cdc] via GitHub
• Re: [PR] [FLINK-34820][mysql] Not recycle but reuse fetcher for all data to improve performant [flink-cdc] via GitHub
• [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38218] Fix MySQL CDC binlog split metadata split transmission [flink-cdc] via GitHub
• [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE` `CATALOG`, `DATABASE`, `MODEL` is optional [flink] via GitHub
  • Re: [PR] [hotfix][docs] `WITH` in `CREATE DATABASE` is optional [flink] via GitHub
• [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38218) MySQL CDC source may ignore newly added tables while reading the binlog Sergei Morozov (Jira)
• [PR] Fix watermark documentation [flink] via GitHub
  • Re: [PR] Fix watermark documentation [flink] via GitHub
  • Re: [PR] Fix watermark documentation [flink] via GitHub
• [jira] [Assigned] (FLINK-38073) Add documentation for the MultiJoin Operator Gustavo de Morais (Jira)
• [jira] [Closed] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Timo Walther (Jira)
• [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
  • Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
  • Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• [jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows Dawid Wysakowicz (Jira)
• [jira] [Resolved] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• [jira] [Reopened] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service yuan (Jira)
• [jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg Cai Liuyang (Jira)
• [jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer Rui Fan (Jira)
• [jira] [Updated] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink wuzexian (Jira)
• [jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE wuzexian (Jira)
• [jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
  • [jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38194) Iceberg connector supports auto-creating namespace Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter Robert Metzger (Jira)
• [jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)
• [jira] [Updated] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed junzhong qin (Jira)
• [jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API Dian Fu (Jira)
• [jira] [Resolved] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38213) Failed case: FlussE2eITCase.testMySqlToFluss Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-38213) Failed case: FlussE2eITCase.testMySqlToFluss Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38213) Failed Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes Yanquan Lv (Jira)
• [PR] [FLINK-37959][postgres]Supported postgres sql 14 all field types. [flink-cdc] via GitHub
• [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-35907) Inconsistent handling of bit and bit(n) types in Flink CDC PostgreSQL Connector ASF GitHub Bot (Jira)
• [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc] via GitHub
• [PR] [hotfix][docs] README: fix variable name in Java Batch example [flink] via GitHub
  • Re: [PR] [hotfix][docs] README: fix variable name in Java Batch example [flink] via GitHub
• [jira] [Updated] (FLINK-38205) Discard unknown fields for Protobuf format ASF GitHub Bot (Jira)
• [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
  • Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink] via GitHub
• [jira] [Resolved] (FLINK-38135) Non-existent method for RAW type hashing Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal Timo Walther (Jira)
• [jira] [Closed] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal Timo Walther (Jira)
• [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
• [jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
  • [jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc Grzegorz Liter (Jira)
• [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator Gustavo de Morais (Jira)
• [jira] [Resolved] (FLINK-37700) SQL parse exception when creating a view with PTF Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-37700) SQL parse exception when creating a view with PTF Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor Sergey Nuyanzin (Jira)
• [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc] via GitHub
  • Re: [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management Timo Walther (Jira)
• [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub
  • Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink] via GitHub

• Earlier messages
• Later messages