issues  

Messages by Thread

• [PR] [BP-2.3][FLINK-40109][yarn][tests] Include rolled logs in the keytab log check [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40109][yarn][tests] Include rolled logs in the keytab log check [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40109][yarn][tests] Include rolled logs in the keytab log check [flink] via GitHub
• [jira] [Resolved] (FLINK-40744) Remove the dead InputFormat and OutputFormat classes from flink-connector-jdbc Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40742) Pin the JDBC Table sink's changelog behaviour with tests before the Sink V2 migration Martijn Visser (Jira)
• Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• [PR] [FLINK-40711][ci] Skip released-version weekly rows unchanged since their last green build [flink-connector-kafka] via GitHub
• [jira] [Resolved] (FLINK-35633) Early verification and clearer error message of pipeline YAML definition Xiqian Yu (Jira)
• Re: [PR] [FLINK-40398][connector/kafka] Inject a clock for retention expiry [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40682) ArchivedExecutionGraphTest fails in setup with "BUG: trying to schedule a region which is not in CREATED state" Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Martijn Visser (Jira)
• [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
  • Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• [jira] [Commented] (FLINK-37676) Add a cache for TableId in Selector to improve performance Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-40681) Streaming outer join drops the null-padded row after an inner-side update followed by delete when UPDATE_BEFORE is not required Timo Walther (Jira)
• [jira] [Commented] (FLINK-39329) [MySQL-CDC] Improve error message for tables without primary key in incremental snapshot Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-40682) ArchivedExecutionGraphTest fails in setup with "BUG: trying to schedule a region which is not in CREATED state" Martijn Visser (Jira)
• Re: [PR] [FLINK-28839][docs] Fix duplicate word in DataSet iterations example [flink] via GitHub
• [PR] [BP-2.2][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• [jira] [Created] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase Martijn Visser (Jira)
• [jira] [Created] (FLINK-40848) Derive FlinkDeployment resource usage from pod resource requests Rodrigo Meneses (Jira)
• [jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Martijn Visser (Jira)
• Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39417) YAML Pipeline could not [de]serialize GenericRecordData Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters Xiqian Yu (Jira)
• Re: [I] [Tech Debt][api] ContextRetrievalRequestEvent accepts a non-positive max_results [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40109) YARNSessionFIFOSecuredITCase misses the keytab login in rolled container logs Martijn Visser (Jira)
• [jira] [Commented] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots Martijn Visser (Jira)
• [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
  • Re: [PR] [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses [flink] via GitHub
• Re: [PR] [FLINK-40708][table] Support ValueView in PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40708][table] Support ValueView in PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40708][table] Support ValueView in PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40708][table] Support ValueView in PTFs [flink] via GitHub
• Re: [I] [Bug][api] VectorStoreQuery accepts a null or negative limit [flink-agents] via GitHub
• [I] [Bug][api] Java ToolResponseEvent reads a failed Python tool call as a success [flink-agents] via GitHub
  • Re: [I] [Bug][api] Java ToolResponseEvent reads a failed Python tool call as a success [flink-agents] via GitHub
• [PR] [api][java] Keep failed Python tool calls as errors in ToolResponseEvent [flink-agents] via GitHub
  • Re: [PR] [api][java] Keep failed Python tool calls as errors in ToolResponseEvent [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38072) EventTimeWindowCheckpointingITCase#testSlidingTimeWindow test failed in cron ci Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40337) Preserve operator precedence in generated Janino expressions Xiqian Yu (Jira)
• [jira] [Assigned] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-40682) ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest fail with "BUG: trying to schedule a region which is not in CREATED state" sepuri sai krishna (Jira)
• [jira] [Updated] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends Mate Czagany (Jira)
  • [jira] [Updated] (FLINK-40336) Avoid full state scans in event-time temporal join on sorted state backends Mate Czagany (Jira)
• [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality [flink-connector-kafka] via GitHub
• [jira] [Comment Edited] (FLINK-39103) BufferManager.recycle fails TM due to RemoteTransportException Martijn Visser (Jira)
• [PR] [BP-2.3][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• [jira] [Created] (FLINK-40847) KafkaDynamicSink#equals/hashCode ignore transactionNamingStrategy Aleksandr Savonin (Jira)
• [jira] [Closed] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
• Re: [PR] [FLINK-38727][test][BP-2.1]: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
  • Re: [PR] [FLINK-38727][test][BP-2.1]: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• Re: [PR] [FLINK-38727][test][BP-2.2]: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
  • Re: [PR] [FLINK-38727][test][BP-2.2]: fix flaky EventTimeWindowCheckpointingITCase / LocalRecoveryITCase via REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• [jira] [Commented] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• Re: [PR] [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
  • Re: [PR] [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• [jira] [Updated] (FLINK-40682) ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest fail with "BUG: trying to schedule a region which is not in CREATED state Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40682) ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest fail with "BUG: trying to schedule a region which is not in CREATED state" Martijn Visser (Jira)
• [jira] [Updated] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• [jira] [Created] (FLINK-40844) Planner inserting a ghost column when all rows are partition keys Vas Shabu (Jira)
• [jira] [Created] (FLINK-40845) VARIANT toString() and result printing still fail on an out-of-range TIME value Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-40844) Planner inserting a ghost column when all rows are partition keys Vas Shabu (Jira)
  • [jira] [Updated] (FLINK-40844) Planner inserting a ghost column when all rows are partition keys Vas Shabu (Jira)
• [jira] [Created] (FLINK-40843) Add StateCatalog documentation Gyula Fora (Jira)
• [jira] [Commented] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Xiqian Yu (Jira)
• [jira] [Created] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40841) Streaming outer join with a non-equi condition produces wrong results on upsert input Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-40595) Native S3 always aborts multipart uploads required for checkpoint recovery Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-40828) Make VARIANT toString() and result printing never fail Timo Walther (Jira)
• [jira] [Assigned] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties Xiqian Yu (Jira)
• [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
  • Re: [PR] [integration][java][python] Send user images to Ollama [flink-agents] via GitHub
• Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-40839) INSERT with a column list fails when an omitted column is of type VARIANT Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice Zhe Wang (Jira)
• [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
• [jira] [Created] (FLINK-40840) INSERT with a column list fails when an omitted column is of type BITMAP, RAW or STRUCTURED Ramin Gharib (Jira)
• [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
  • Re: [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
  • Re: [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
  • Re: [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
• Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
  • Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
  • Re: [PR] [FLINK-36456] feat: Add support to pass Datadog API Key as environment variable [flink] via GitHub
• [jira] [Commented] (FLINK-35633) Early verification and clearer error message of pipeline YAML definition Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40151) Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation Xiqian Yu (Jira)
• Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19. Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40159) Support Hive metastore sync for Hudi pipeline sink Xiqian Yu (Jira)
• Re: [I] [Tech Debt][API][Tool] Unify function-schema derivation and argument validation [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
• [jira] [Commented] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-34677) Refactor the structure of documentation for Flink CDC Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-34742) Translate "FAQ" Page for Flink CDC Chinese Documentation Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-35077) Add package license check for Flink CDC modules. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-35281) FlinkEnvironmentUtils#addJar add each jar only once Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38156) Pipeline E2E tests are currently bound to fail. Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39363) [Flaky Tests] PaimonSinkITCase.testDuplicateCommitAfterRestore Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-40740) Fluss source can assign the same splits more than once during periodic discovery Hongshun Wang (Jira)
• [jira] [Resolved] (FLINK-39144) fix IOManager not close Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38232) [docs] updates the connector documentation to reflect the new features in Flink CDC 3.5.0 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-40151) Support missing YAML Transform predicates and nullable BOOLEAN logical evaluation Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38723) Provide Flink Configuration in the Context when Building DataSink/DataSource Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38723) Provide Flink Configuration in the Context when Building DataSink/DataSource Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38806) Pipeline post-transform converters ineffective without a projection rule Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38737) Introducing fallback keys can cause validateFactoryOptions to fail Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-39329) [MySQL-CDC] Improve error message for tables without primary key in incremental snapshot Xiqian Yu (Jira)
• Re: [PR] [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40740][pipeline-connector/fluss] Prevent duplicate split initialization during discovery [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-37676) Add a cache for TableId in Selector to improve performance Xiqian Yu (Jira)
• [jira] [Resolved] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38808) Support partition transforms in Iceberg sink Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-39048) [iceberg] Bump iceberg-flink-runtime from 1.19 to 1.20 Xiqian Yu (Jira)

• Earlier messages
• Later messages