issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36905] Update Chinese doc on serialization to reflect the latest changes in Flink 2.0 [flink]
via GitHub
2025/01/18
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-35282][python] Upgrade Apache Beam > 2.54 [flink]
via GitHub
2025/01/18
[jira] [Updated] (FLINK-37133) Support Submitting Refresh Job of Materialized Table to Yarn/K8s
Feng Jin (Jira)
2025/01/18
[jira] [Updated] (FLINK-36905) Update Chinese document to reflect the changes of FLIP-398
ASF GitHub Bot (Jira)
2025/01/18
[PR] [FLINK-36905] Update Chinese doc on serialization to reflect the latest changes in Flink 2.0 [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/18
[jira] [Resolved] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API
Weijie Guo (Jira)
2025/01/18
[jira] [Updated] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API
Weijie Guo (Jira)
2025/01/18
Re: [PR] [FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/18
Re: [PR] [FLINK-23139][state] Add TaskStateRegistry [flink]
via GitHub
2025/01/18
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/18
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37045] Remove useless StateDescriptor of state v2 [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3
Ruan Hang (Jira)
2025/01/17
[jira] [Updated] (FLINK-37152) Update Flink version to 1.20 in Flink CDC
Ruan Hang (Jira)
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
[jira] [Commented] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics
Zhenqiu Huang (Jira)
2025/01/17
[jira] [Closed] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics
Zhenqiu Huang (Jira)
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
[PR] [FLINK-37045] Remove useless StateDescriptor of state v2 [flink]
via GitHub
2025/01/17
[jira] [Commented] (FLINK-37164) Speed up state v2 synchronous methods execution
Zakelly Lan (Jira)
2025/01/17
[jira] [Resolved] (FLINK-37164) Speed up state v2 synchronous methods execution
Zakelly Lan (Jira)
2025/01/17
Re: [PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]
via GitHub
2025/01/17
[jira] [Closed] (FLINK-37084) NullPointerException occurs during handling timer of window in PyFlink
Dian Fu (Jira)
2025/01/17
Re: [PR] [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs. [flink-cdc]
via GitHub
2025/01/17
Re: [PR] [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs. [flink-cdc]
via GitHub
2025/01/17
Re: [PR] upgrade-tikv-client [flink-cdc]
via GitHub
2025/01/17
Re: [PR] upgrade-tikv-client [flink-cdc]
via GitHub
2025/01/17
[jira] [Commented] (FLINK-37084) NullPointerException occurs during handling timer of window in PyFlink
Dian Fu (Jira)
2025/01/17
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException
sehaj pal singh sandhu (Jira)
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-19059]: Support non-time retract mode for OverAggregate operator [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-35282][python] Upgrade Apache Beam > 2.54 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-TODO] [pyflink] Replace deprecated avro-python3 with avro [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix compile error in EventTimeWatermarkHandlerTest [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix compile error in EventTimeWatermarkHandlerTest [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix compile error in EventTimeWatermarkHandlerTest [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37021][state/forst] Make Forst remote dir share with checkpoint [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37166] Use concurrenthashmap in flink config manager [flink-kubernetes-operator]
via GitHub
2025/01/17
Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc]
via GitHub
2025/01/17
[PR] [FLINK-TODO] [pyflink] Replace deprecated avro-python3 with avro [flink]
via GitHub
2025/01/17
[jira] [Closed] (FLINK-37098) Can not select time attribute from a view
Dawid Wysakowicz (Jira)
2025/01/17
Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] [docs] Fix typo in Flink Overview [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37166] Use concurrenthashmap in flink config manager [flink-kubernetes-operator]
via GitHub
2025/01/17
[PR] [FLINK-37166] Use concurrenthashmap in flink config manager [flink-kubernetes-operator]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37166) FlinkConfigManager version prefix logic not thread safe
ASF GitHub Bot (Jira)
2025/01/17
[PR] [hotfix] Fix compile error in EventTimeWatermarkHandlerTest [flink]
via GitHub
2025/01/17
[PR] [FLINK-37021][state/forst] Make Forst remote dir share with checkpoint [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37166) FlinkConfigManager version prefix logic not thread safe
Gyula Fora (Jira)
2025/01/17
[jira] [Created] (FLINK-37167) Fix operand reordering in SqlValidatorImpl for tableCharacteristics
Timo Walther (Jira)
2025/01/17
[jira] [Created] (FLINK-37166) FlinkConfigManager version prefix logic not safe
Gyula Fora (Jira)
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37028] Datastream Window operator with async state processing [flink]
via GitHub
2025/01/17
[jira] [Closed] (FLINK-36837) Introduce RowTimeDeduplicateFunction with Async State API
lincoln lee (Jira)
2025/01/17
Re: [PR] [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] [docs] fix link URL to DataStream operators [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37140][runtime] Create async timer service when restore async operator [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37140][runtime] Create async timer service when restore async operator [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] [docs] fix link URL to DataStream operators [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]
via GitHub
2025/01/17
Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37158][tests] Introduce ForSt to existing ITCases [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37165) The starrocks connector is found to be missing some options.
sukang (Jira)
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
[jira] [Commented] (FLINK-37165) The starrocks connector is found to be missing some options.
sukang (Jira)
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
[jira] [Created] (FLINK-37165) The starrocks connector is found to be missing some options.
sukang (Jira)
2025/01/17
[jira] [Commented] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding
Yanquan Lv (Jira)
2025/01/17
Re: [PR] [FLINK-35405][runtime] Add metrics for AsyncExecutionController [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37164) Speed up state v2 synchronous methods execution
ASF GitHub Bot (Jira)
2025/01/17
Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]
via GitHub
2025/01/17
[PR] [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]
via GitHub
2025/01/17
Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]
via GitHub
2025/01/17
Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]
via GitHub
2025/01/17
[jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution
Zakelly Lan (Jira)
2025/01/17
[jira] [Assigned] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3
Leonard Xu (Jira)
2025/01/17
[jira] [Assigned] (FLINK-37162) Add Data Sink Documentation
Leonard Xu (Jira)
2025/01/17
Re: [PR] [FLINK-35152][pipeline-connector/doris] Support create doris auto partition table [flink-cdc]
via GitHub
2025/01/17
Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/17
Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/17
Re: [PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]
via GitHub
2025/01/17
[jira] [Updated] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3
ASF GitHub Bot (Jira)
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/17
[PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/17
[jira] [Commented] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP
Luke Chen (Jira)
2025/01/17
[jira] [Updated] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP
ASF GitHub Bot (Jira)
2025/01/17
Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink]
via GitHub
2025/01/17
[PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink]
via GitHub
2025/01/17
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/17
Re: [PR] [hotfix] Fix the issue related to mounting the Logback configuration … [flink]
via GitHub
2025/01/17
[jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3
Yanquan Lv (Jira)
2025/01/16
[jira] [Commented] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module
dalongliu (Jira)
2025/01/16
[jira] [Resolved] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module
dalongliu (Jira)
2025/01/16
Re: [PR] [FLINK-37001][table] Remove code related to registerTableSinkInternal in tests and remove this method in TableEnvironmentInternal [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37133][table] Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s [flink]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-37162) Add Data Sink Documentation
Yanquan Lv (Jira)
2025/01/16
[jira] [Created] (FLINK-37162) Add Data Sources Documentation
Yanquan Lv (Jira)
2025/01/16
[jira] [Updated] (FLINK-37162) Add Data Sources Documentation
Yanquan Lv (Jira)
2025/01/16
Re: [PR] [FLINK-37158][tests] Introduce ForSt to existing ITCases [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37098] Fix selecting time attribute from a view [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37084][python] fix TimerRegistration concurrency bug in pyflink [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-37136) FLIP-501: Support Window Extension in DataStream V2 API
ASF GitHub Bot (Jira)
2025/01/16
[PR] [WIP][FLINK-37136] Support Window extension for DataStream V2 [flink]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs"
Junrui Lee (Jira)
2025/01/16
[jira] [Updated] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs"
Junrui Lee (Jira)
2025/01/16
[jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs"
Junrui Lee (Jira)
2025/01/16
[jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs"
Junrui Lee (Jira)
2025/01/16
[jira] [Updated] (FLINK-37113) Introduce documentation for datastream api v2
Weijie Guo (Jira)
2025/01/16
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/16
[jira] [Created] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP
Weijie Guo (Jira)
2025/01/16
Re: [PR] [FLINK-36074][Connectors/mongodb] Support insert overwrite semantics for mongodb table sink [flink-connector-mongodb]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-37158) Introduce ForSt to existing ITCases
ASF GitHub Bot (Jira)
2025/01/16
[PR] [FLINK-37158][tests] Introduce ForSt to existing ITCases [flink]
via GitHub
2025/01/16
[jira] [Commented] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.
Vinh Pham (Jira)
2025/01/16
[jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases
Yanfei Lei (Jira)
2025/01/16
Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource at runtime
Mohsen Rezaei (Jira)
2025/01/16
Re: [PR] [FLINK-20886] Support printing the thread dump when checkpoint expired [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37008] [runtime-web] Flink UI should show the type of checkpoint (full vs incremental) [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-32753] Print JVM flags on AZP [flink]
via GitHub
2025/01/16
Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc]
via GitHub
2025/01/16
[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Ruan Hang (Jira)
2025/01/16
[jira] [Resolved] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35684) Add missing option for DataSource and DataSink
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35589) Support MemorySize type in FlinkCDC ConfigOptions
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35718) Cherrypick DBZ-5333 to fix frequently failover by EOFException.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35888) Add e2e test for paimon DataSink
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-36218) Documentations clean up before CDC 3.2.0 release
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-36220) Clean up typo and stale links in docs
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-35090) Doris sink fails to create table when database does not exist
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.
Ruan Hang (Jira)
2025/01/16
[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.
Ruan Hang (Jira)
Earlier messages
Later messages