Messages by Thread
-
-
[jira] (FLINK-37334) Fix mysql's add column after event becomes add column last
MOBIN (Jira)
-
[jira] [Reopened] (FLINK-37334) Fix mysql's add column after event becomes add column last
MOBIN (Jira)
-
[jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) may send data without AddPartitionsToTxnRequest
Hongshun Wang (Jira)
-
[jira] [Commented] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-37356) Recycle use of kafka producer(which commit error) maybe send data without AddPartitionsToTxnRequest
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest
Hongshun Wang (Jira)
-
[jira] [Updated] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint.
longwang0616 (Jira)
-
[jira] [Commented] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest
Sai Sharath Dandi (Jira)
-
Re: [PR] [FLINK-36579][cdc] Fix mysql cdc charset collation sort not equals ja… [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint
ASF GitHub Bot (Jira)
-
[PR] [FLINK-34554] Introduce transaction strategies [flink-connector-kafka]
via GitHub
-
[jira] [Commented] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Leonard Xu (Jira)
-
[jira] [Assigned] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Leonard Xu (Jira)
-
[jira] [Resolved] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.
Jiangjie Qin (Jira)
-
[jira] [Comment Edited] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows
David Radley (Jira)
-
[jira] [Commented] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows
David Radley (Jira)
-
[jira] [Resolved] (FLINK-37282) Add backchannel for producer recycling
Arvid Heise (Jira)
-
[jira] [Updated] (FLINK-37354) Kubernetes Operator HealthCheck compatibility
Anton Solovev (Jira)
-
[jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility
Anton Solovev (Jira)
-
[jira] [Created] (FLINK-37352) Write full changelog to Paimon Sink.
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Yanquan Lv (Jira)
-
[jira] [Commented] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode.
Zakelly Lan (Jira)
-
[jira] [Updated] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Yanquan Lv (Jira)
-
[jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs"
Zhu Zhu (Jira)
-
[jira] [Resolved] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs
Junrui Lee (Jira)
-
Re: [PR] [BP-2.0][FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]
via GitHub
-
Re: [PR] [BP-1.20][FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]
via GitHub
-
[jira] [Created] (FLINK-37351) Ensure writer and committer are colocated
Arvid Heise (Jira)
-
Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-37350) Memory leak caused by skewed join optimization strategy
Lei Yang (Jira)
-
[PR] [BP-2.0][FLINK-37335][state/forst] Handle the first full checkpoint for ForSt IncrementalSnapshotStrategy. [flink]
via GitHub
-
Re: [PR] [FLINK-37204] Add missing StarRocks connector options for 1.2.10. [flink-cdc]
via GitHub
-
[jira] [Closed] (FLINK-36253) Wordcount on Docker test failed due to mismatch output hash
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting
Yanquan Lv (Jira)
-
[jira] [Updated] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37348][pipeline-paimon] fix paimon ArrayIndexOutOfBoundsException when add column first [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column
MOBIN (Jira)
-
[jira] [Commented] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’
caixiaowei (Jira)
-
[jira] [Updated] (FLINK-35900) PyFlink: update version of Apache Beam dependency
Xintong Song (Jira)
-
[jira] [Closed] (FLINK-36867) flink on k8s operator could not create TM
Xintong Song (Jira)
-
[jira] [Assigned] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode.
Xintong Song (Jira)
-
[jira] [Closed] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"
Junrui Lee (Jira)
-
[PR] [FLINK-36203][Connectors/DynamoDB] Added polling delay between empty polls in getRecords calls [flink-connector-aws]
via GitHub
-
[jira] [Updated] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher
ASF GitHub Bot (Jira)
-
[PR] [FLINK-37347][DOCS] Support any column as chunk key column (postgres, orcale, db2, sqlserver) [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver)
ASF GitHub Bot (Jira)
-
[PR] [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method [flink]
via GitHub
-
[jira] [Created] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver)
Lee SeungMin (Jira)
-
[PR] [FLINK-35810][test] increase unittest Xmx to debug FLINK-35810 [flink]
via GitHub
-
[jira] [Updated] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Weijie Guo (Jira)
-
[jira] [Assigned] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry
Weijie Guo (Jira)
-
[jira] [Updated] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails
Weijie Guo (Jira)
-
[jira] [Closed] (FLINK-37334) Fix mysql's add column after event becomes add column last
MOBIN (Jira)
-
[jira] [Created] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m
Yanquan Lv (Jira)
-
[jira] [Commented] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m
Yanquan Lv (Jira)
-
[jira] [Resolved] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types.
Leonard Xu (Jira)
-
[jira] [Updated] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types.
Leonard Xu (Jira)
-
[jira] [Commented] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or being restored
lincoln lee (Jira)
-
[jira] [Updated] (FLINK-36409) Publish some autoscaler metrics during stabilisation period
ASF GitHub Bot (Jira)
-
[PR] [FLINK-36409] Publish some autoscaler metrics during stabilisation period [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [FLINK-36009] Architecture tests fixes [flink-connector-jdbc]
via GitHub
-
Re: [PR] [FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink]
via GitHub
-
[PR] Release flink-shaded 20.0 [flink-web]
via GitHub
-
[jira] [Commented] (FLINK-37344) setup_hugo.sh should install the hugo binary only
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-37320) [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING
Luca Castelli (Jira)
-
[PR] [FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING [flink-kubernetes-operator]
via GitHub
-
[jira] [Resolved] (FLINK-37344) setup_hugo.sh should install the hugo binary only
Maximilian Michels (Jira)
-
[jira] [Updated] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-33703) Use maven 3.8.6 for releasing of flink-shaded
Sergey Nuyanzin (Jira)
-
Re: [PR] [FLINK-33703] Use maven 3.8.6 for release profile [flink-shaded]
via GitHub
-
[jira] [Updated] (FLINK-37320) FINISHED finite streaming jobs incorrectly being set to RECONCILING
Luca Castelli (Jira)