issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/08/29
Re: [PR] [FLINK-36173][docs] Fix invalid link in checkpoint documentation [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-36173][docs] Fix invalid link in checkpoint documentation [flink]
via GitHub
2024/08/29
[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata
ASF GitHub Bot (Jira)
2024/08/29
[PR] [FLINK-36001][state] Store operator name and UID in state metadata [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-35886] Leave a note for future Flink 2.0 upgrade [flink-connector-kafka]
via GitHub
2024/08/29
Re: [PR] [FLINK-36174][hotfix] CDC yaml without pipeline should not throw exception. [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-35886] Leave a note for future Flink 2.0 upgrade [flink-connector-kafka]
via GitHub
2024/08/29
Re: [PR] [FLINK-35886] Leave a note for future Flink 2.0 upgrade [flink-connector-kafka]
via GitHub
2024/08/29
Re: [PR] [hotfix][transform] Fix transform operator swallows schema changes from tables not present in transform rules [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-36175][python] Remove `register_table_source` and `register_table_sink` in python module [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-36116] Update Javadoc plugin [flink]
via GitHub
2024/08/29
[PR] [FLINK-36175][python] Remove `register_table_source` and `register_table_sink` in python module [flink]
via GitHub
2024/08/29
[jira] [Updated] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
ASF GitHub Bot (Jira)
2024/08/29
[jira] [Updated] (FLINK-36116) Javadocs aren't visible anymore for Flink 1.17 and above
ASF GitHub Bot (Jira)
2024/08/29
[jira] [Created] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module
xuyang (Jira)
2024/08/29
[PR] [FLINK-36116] Update Javadoc plugin [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]
via GitHub
2024/08/29
[jira] [Updated] (FLINK-36174) CDC yaml without pipeline will throw NullPointException
ASF GitHub Bot (Jira)
2024/08/29
[jira] [Assigned] (FLINK-36116) Javadocs aren't visible anymore for Flink 1.17 and above
Martijn Visser (Jira)
2024/08/29
[jira] [Created] (FLINK-36174) CDC yaml without pipeline will throw NullPointException
Hongshun Wang (Jira)
2024/08/29
Re: [PR] [tests] Reorganize test cases to accelerate CI workflow [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-36090][Runtime / State Backends] Fix bug with IngestDB restore operation for priority queue state in backend. [flink]
via GitHub
2024/08/29
[PR] [tests] Reorganize test cases to accelerate CI workflow [flink-cdc]
via GitHub
2024/08/29
[jira] [Commented] (FLINK-35581) Remove comments from the code related to ingestDB
Yue Ma (Jira)
2024/08/29
[PR] [FLINK-35886] Leave a note for future Flink 2.0 upgrade [flink-connector-kafka]
via GitHub
2024/08/29
Re: [PR] [FLINK-33678][streaming-java] Remove CheckpointStorage related public API. [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-35581] Remove comments from the code related to ingestDB [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-35581] Remove comments from the code related to ingestDB [flink]
via GitHub
2024/08/29
[PR] [FLINK-33678][streaming-java] Remove CheckpointStorage related public API. [flink]
via GitHub
2024/08/29
[jira] [Updated] (FLINK-35581) Remove comments from the code related to ingestDB
ASF GitHub Bot (Jira)
2024/08/29
[PR] [FLINK-35581] Remove comments from the code related to ingestDB [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-36173][docs] Fix invalid link in checkpoint documentation [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-33678][streaming-java] Remove RestartStrategies related public API. [flink]
via GitHub
2024/08/29
[jira] [Updated] (FLINK-36173) Invalid link in checkpoint documentation
ASF GitHub Bot (Jira)
2024/08/29
[PR] [FLINK-36173][docs] Fix invalid link in checkpoint documentation [flink]
via GitHub
2024/08/29
Re: [PR] [FLINK-34688][cdc-connector] CDC framework split snapshot chunks asynchronously [flink-cdc]
via GitHub
2024/08/29
Re: [PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]
via GitHub
2024/08/29
[jira] [Assigned] (FLINK-36173) Invalid link in checkpoint documentation
Gabor Somogyi (Jira)
2024/08/29
[jira] [Created] (FLINK-36173) Invalid link in checkpoint documentation
Gabor Somogyi (Jira)
2024/08/28
Re: [PR] Refactor tests [flink-cdc]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs
Junrui Li (Jira)
2024/08/28
[jira] [Created] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs
Junrui Li (Jira)
2024/08/28
Re: [PR] [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-14068][core] Removes deprecated org.apache.flink.api.common.time.Time [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc]
via GitHub
2024/08/28
[PR] [BP-3.2][hotfix] Fix lenient schema evolution failure with route blocks [flink-cdc]
via GitHub
2024/08/28
[PR] [hotfix] Fix lenient schema evolution failure with route blocks [flink-cdc]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-35579) Update the FrocksDB version in FLINK
Zakelly Lan (Jira)
2024/08/28
[jira] [Resolved] (FLINK-35579) Update the FrocksDB version in FLINK
Zakelly Lan (Jira)
2024/08/28
[jira] [Commented] (FLINK-35579) Update the FrocksDB version in FLINK
Zakelly Lan (Jira)
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc]
via GitHub
2024/08/28
Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5 [flink]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-35177) Datagen examples in documentation do not compile
Zhongqiang Gong (Jira)
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
Zhongqiang Gong (Jira)
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-36171) Remove APIs about ManagedTable
xuyang (Jira)
2024/08/28
[jira] [Created] (FLINK-36171) Remove APIs about ManagedTable
xuyang (Jira)
2024/08/28
Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36009) Change configs to use CondigOptions
ASF GitHub Bot (Jira)
2024/08/28
[PR] [FLINK-36009] Architecture tests refactor and fixes [flink-connector-jdbc]
via GitHub
2024/08/28
Re: [PR] [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5 [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36170) Bump assertj-core version
ASF GitHub Bot (Jira)
2024/08/28
[PR] [FLINK-36170] bump assert4j version [flink-kubernetes-operator]
via GitHub
2024/08/28
[jira] [Created] (FLINK-36170) Bump assertj-core version
Siddharth R (Jira)
2024/08/28
Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
2024/08/28
[PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]
via GitHub
2024/08/28
Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data
Feng Jin (Jira)
2024/08/28
[jira] [Assigned] (FLINK-36169) Support namespace level resource check before scaling up
Gyula Fora (Jira)
2024/08/28
[jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up
Zhenqiu Huang (Jira)
2024/08/28
Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc]
via GitHub
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.
lincoln lee (Jira)
2024/08/28
[jira] [Assigned] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.
lincoln lee (Jira)
2024/08/28
[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.
lincoln lee (Jira)
2024/08/28
Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]
via GitHub
2024/08/28
Re: [PR] [minor][tests] Fix `testDanglingDroppingTableDuringBinlogMode` tests case due to imprecise timestamp startup [flink-cdc]
via GitHub
2024/08/28
Re: [PR] [BP-3.2][hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][table] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36018) Support lazy scale down to avoid frequent rescaling
ASF GitHub Bot (Jira)
2024/08/28
[PR] [FLINK-36018][autoscaler] Support lazy scale down to avoid frequent rescaling [flink-kubernetes-operator]
via GitHub
2024/08/28
Re: [PR] [FLINK-36149][table] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]
via GitHub
2024/08/28
[PR] [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle
ASF GitHub Bot (Jira)
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
Re: [PR] [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/28
[jira] [Closed] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference
Gyula Fora (Jira)
2024/08/28
Re: [PR] [FLINK-36145][snapshot] Rename flinkStateSnapshotReference to snapshotReference [flink-kubernetes-operator]
via GitHub
2024/08/28
Re: [PR] [FLINK-36145][snapshot] Rename flinkStateSnapshotReference to snapshotReference [flink-kubernetes-operator]
via GitHub
2024/08/28
[jira] [Resolved] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule
Sergey Nuyanzin (Jira)
2024/08/28
[jira] [Commented] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule
Sergey Nuyanzin (Jira)
2024/08/28
[jira] [Assigned] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule
Sergey Nuyanzin (Jira)
2024/08/28
Re: [PR] [FLINK-35751][table] Migrate SplitPythonConditionFromCorrelateRule to java [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-31380][table] Support enhanced show catalogs syntax [flink]
via GitHub
2024/08/28
[jira] [Closed] (FLINK-35266) Add e2e tests for FlinkStateSnapshot CRs
Gyula Fora (Jira)
2024/08/28
Re: [PR] [FLINK-35266][snapshot] Add E2E tests for FlinkStateSnapshot [flink-kubernetes-operator]
via GitHub
2024/08/28
[jira] [Resolved] (FLINK-34896) Migrate CorrelateSortToRankRule
Sergey Nuyanzin (Jira)
2024/08/28
[jira] [Commented] (FLINK-34896) Migrate CorrelateSortToRankRule
Sergey Nuyanzin (Jira)
2024/08/28
Re: [PR] [FLINK-35054][table] Migrate TemporalJoinRewriteWithUniqueKeyRule to … [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]
via GitHub
2024/08/28
[PR] [FLINK-36162] Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference [flink-kubernetes-operator]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference
ASF GitHub Bot (Jira)
2024/08/28
Re: [PR] [FLINK-33678][streaming-java] Remove configuration getters/setters that return/set complex Java objects. [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java. [flink]
via GitHub
2024/08/28
[jira] [Commented] (FLINK-28554) Kubernetes-Operator allow readOnlyRootFilesystem via operatorSecurityContext
pgodowski (Jira)
2024/08/28
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/28
Re: [PR] fixup! (1.20 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-35739) FLIP-444: Native file copy support
Piotr Nowojski (Jira)
2024/08/28
[jira] [Closed] (FLINK-35739) FLIP-444: Native file copy support
Piotr Nowojski (Jira)
2024/08/28
[jira] [Closed] (FLINK-35773) Document s5cmd
Piotr Nowojski (Jira)
2024/08/28
Re: [PR] [FLINK-35773][docs] Document s5cmd [flink]
via GitHub
2024/08/28
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/28
[PR] [BP-3.2][hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/28
[jira] [Created] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle
Matthias Pohl (Jira)
2024/08/28
Re: [PR] [FLINK-35894][Follow] fix Elasticsearch dependency version [flink-cdc]
via GitHub
2024/08/28
[PR] [FLINK-35894][Follow] fix Elasticsearch dependency version [flink-cdc]
via GitHub
2024/08/28
[jira] [Updated] (FLINK-36167) testSinkDisorderChangeLog failed on AZP
Weijie Guo (Jira)
2024/08/28
[jira] [Created] (FLINK-36167) testSinkDisorderChangeLog failed on AZP
Weijie Guo (Jira)
2024/08/28
[jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails
Weijie Guo (Jira)
2024/08/28
[jira] [Created] (FLINK-36166) testJoinDisorderChangeLog failed on AZP
Weijie Guo (Jira)
2024/08/28
[jira] [Updated] (FLINK-36166) testJoinDisorderChangeLog failed on AZP
Weijie Guo (Jira)
2024/08/27
Re: [PR] [FLINK-35773][docs] Document s5cmd [flink]
via GitHub
2024/08/27
Re: [PR] [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/27
[jira] [Comment Edited] (FLINK-35992) NettyShuffleMaster not close tiered-storage resources
Weijie Guo (Jira)
2024/08/27
Re: [PR] [BP-1.20][FLINK-35992][runtime] Close the TieredStorageMasterClient w… [flink]
via GitHub
2024/08/27
Re: [PR] [minor][tests] Fix `testDanglingDroppingTableDuringBinlogMode` tests case due to imprecise timestamp startup [flink-cdc]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[jira] [Created] (FLINK-36165) Support obtaining snapshot data of the scope
Thorne (Jira)
2024/08/27
[PR] [hotfix][tests] Fix `testDanglingDroppingTableDuringBinlogMode` tests case due to imprecise timestamp startup [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/27
Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]
via GitHub
2024/08/27
Re: [PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]
via GitHub
2024/08/27
[PR] [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
[PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
[jira] [Updated] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
[jira] [Created] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table
tchivs (Jira)
2024/08/27
Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]
via GitHub
2024/08/27
[jira] [Created] (FLINK-36163) Kafka cdc pipeline source supports protobuf format.
Hongshun Wang (Jira)
2024/08/27
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
[jira] [Resolved] (FLINK-35177) Datagen examples in documentation do not compile
Zhongqiang Gong (Jira)
2024/08/27
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-35599) Add JDBC Sink Plugin to Flink-CDC-Pipeline
ASF GitHub Bot (Jira)
2024/08/27
Re: [PR] [FLINK-35599][cdc-connector][jdbc-mysql]Flink cdc pipeline sink jdbc mysql [flink-cdc]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-35917) Failed to deserialize data of EventHeaderV4
wangkang (Jira)
2024/08/27
Re: [PR] [e2e][tests] Improve the stability of pipeline e2e tests [flink-cdc]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-35917) Failed to deserialize data of EventHeaderV4
wangkang (Jira)
2024/08/27
Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [e2e][tests] Improve the stability of pipeline e2e tests [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [FLINK-35277][cdc-connector][db2] Fix the error in the `asncdcaddremove.sql` script for the DB2 test container. [flink-cdc]
via GitHub
2024/08/27
[jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException.
ASF GitHub Bot (Jira)
2024/08/27
Re: [PR] [FLINK-35718][mysql] cherry pick DBZ-5333 from debezium MySqlErrorHandler and add logs. [flink-cdc]
via GitHub
2024/08/27
Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]
via GitHub
2024/08/27
Re: [PR] [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]
via GitHub
2024/08/27
Re: [PR] [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]
via GitHub
2024/08/27
[jira] [Commented] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference
Thomas Weise (Jira)
Earlier messages
Later messages