issues
Thread
Date
Later messages
Messages by Date
2024/05/07
[jira] [Resolved] (FLINK-35161) Implement StateExecutor for ForStStateBackend
Zakelly Lan (Jira)
2024/05/07
[jira] [Commented] (FLINK-35161) Implement StateExecutor for ForStStateBackend
Zakelly Lan (Jira)
2024/05/07
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: util [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-34916][table] Support `ALTER CATALOG SET` syntax [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-35172]DDL statement is added to the Schema Change Event [flink-cdc]
via GitHub
2024/05/07
Re: [PR] [FLINK-35172]DDL statement is added to the Schema Change Event [flink-cdc]
via GitHub
2024/05/07
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/07
[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core
Jiabao Sun (Jira)
2024/05/07
Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]
via GitHub
2024/05/07
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/07
[jira] [Commented] (FLINK-35303) Support logical deletion of data
LvYanquan (Jira)
2024/05/07
[jira] [Resolved] (FLINK-32080) Restoration of FileMergingSnapshotManager
Zakelly Lan (Jira)
2024/05/07
[jira] [Commented] (FLINK-32080) Restoration of FileMergingSnapshotManager
Zakelly Lan (Jira)
2024/05/07
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/05/07
[jira] [Created] (FLINK-35304) Mongo ITCase fails due to duplicate records after resuming
yux (Jira)
2024/05/07
Re: [PR] [FLINK-35112][python] Fix membership for Row class PyFlink [flink]
via GitHub
2024/05/07
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Rui Fan (Jira)
2024/05/07
Re: [PR] [FLINK-20628] Port RabbitMQ Connector using unified Source [flink-connector-rabbitmq]
via GitHub
2024/05/07
Re: [PR] [FLINK-20628] Port RabbitMQ Connector using unified Source [flink-connector-rabbitmq]
via GitHub
2024/05/07
[jira] [Updated] (FLINK-35303) Support logical deletion of data
melin (Jira)
2024/05/07
[jira] [Created] (FLINK-35303) Support logical deletion of datax
melin (Jira)
2024/05/07
Re: [PR] [FLINK-35272][cdc][runtime] Transform projection & filter feature overhaul [flink-cdc]
via GitHub
2024/05/07
[jira] [Assigned] (FLINK-35030) Introduce Epoch Manager for async execution
Yanfei Lei (Jira)
2024/05/07
[jira] [Updated] (FLINK-35030) Introduce Epoch Manager for async execution
Yanfei Lei (Jira)
2024/05/07
[jira] [Assigned] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
Dian Fu (Jira)
2024/05/07
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/05/07
[jira] [Commented] (FLINK-35002) GitHub action request timeout to ArtifactService
Ryan Skraba (Jira)
2024/05/07
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/07
[jira] [Commented] (FLINK-33268) Flink REST API response parsing throws exception on new fields
Juntao Hu (Jira)
2024/05/07
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/07
[jira] [Commented] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
Juntao Hu (Jira)
2024/05/07
Re: [PR] [FLINK-35302][rest] Ignore unknown fields in REST request deserialization [flink]
via GitHub
2024/05/07
[jira] [Updated] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
ASF GitHub Bot (Jira)
2024/05/07
[PR] [FLINK-35302][rest] Ignore unknown fields in REST request deserialization [flink]
via GitHub
2024/05/07
[jira] [Updated] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
Juntao Hu (Jira)
2024/05/06
Re: [PR] [FLINK-33761][Connector/JDBC] Add Snowflake JDBC Dialect [flink-connector-jdbc]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
[jira] [Assigned] (FLINK-35193) Support drop materialized table syntax and execution in continuous refresh mode
dalongliu (Jira)
2024/05/06
[jira] [Assigned] (FLINK-35198) Support the execution of refresh materialized table
dalongliu (Jira)
2024/05/06
Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
[jira] [Resolved] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level
Rui Fan (Jira)
2024/05/06
[jira] [Commented] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level
Rui Fan (Jira)
2024/05/06
Re: [PR] [FLINK-35105][autoscaler] Support setting default Autoscaler options at autoscaler standalone level [flink-kubernetes-operator]
via GitHub
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
[jira] [Commented] (FLINK-35288) Flink Restart Strategy does not work as documented
Biao Geng (Jira)
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35296) Flink mysql-cdc connector stops reading data
Gang Yang (Jira)
2024/05/06
Re: [PR] [FLINK-35272][cdc][runtime] Transform projection & filter feature overhaul [flink-cdc]
via GitHub
2024/05/06
[jira] [Commented] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table
Rui Fan (Jira)
2024/05/06
[jira] [Resolved] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table
Rui Fan (Jira)
2024/05/06
Re: [PR] [FLINK-35176][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
Juntao Hu (Jira)
2024/05/06
[jira] [Created] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody
Juntao Hu (Jira)
2024/05/06
Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]
via GitHub
2024/05/06
[jira] [Commented] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual
lincoln lee (Jira)
2024/05/06
Re: [PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]
via GitHub
2024/05/06
[jira] [Resolved] (FLINK-32852) [JUnit5 Migration] The scheduler package of flink-runtime module
Rui Fan (Jira)
2024/05/06
[jira] [Comment Edited] (FLINK-32852) [JUnit5 Migration] The scheduler package of flink-runtime module
Rui Fan (Jira)
2024/05/06
[jira] [Commented] (FLINK-35193) Support drop materialized table syntax and execution in continuous refresh mode
xuyang (Jira)
2024/05/06
[jira] [Commented] (FLINK-35198) Support the execution of refresh materialized table
xuyang (Jira)
2024/05/06
[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35301][cdc] fix deadlock when loading driver classes [flink-cdc]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35301) Fix deadlock when loading driver classes
Xiao Huang (Jira)
2024/05/06
Re: [PR] [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35300][cdc][mysql] Improve MySqlStreamingChangeEventSource to skip null events in event deserializer [flink-cdc]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer
Xiao Huang (Jira)
2024/05/06
[jira] [Closed] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Jiabao Sun (Jira)
2024/05/06
Re: [PR] [FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-33212][runtime] add job status changed listener for lineage [flink]
via GitHub
2024/05/06
Re: [PR] [hotfix] [docs] Clarifying sentence on streaming queries [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-33211][table] support flink table lineage [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot
Hong Liang Teoh (Jira)
2024/05/06
[jira] [Created] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot
Hong Liang Teoh (Jira)
2024/05/06
Re: [PR] [FLINK-34883] Fix postgres uuid column as PK [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-34661][runtime] TaskExecutor supports retain partitions after JM crashed. [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35195][table] Support the execution of create materialized table in continuous refresh mode [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35270]Enrich information in logs, making it easier for debugging [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35270]Enrich information in logs, making it easier for debugging [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35298) Improve metric reporter logic
ASF GitHub Bot (Jira)
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35298) Improve metric reporter logic
Xiao Huang (Jira)
2024/05/06
[jira] [Created] (FLINK-35298) Improve metric reporter logic
Xiao Huang (Jira)
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]
via GitHub
2024/05/06
Re: [PR] [BP-3.1][hotfix][docs] Correct example configuration for Paimon warehouse path [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh… [flink-cdc]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Jiabao Sun (Jira)
2024/05/06
[jira] [Assigned] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Jiabao Sun (Jira)
2024/05/06
[jira] [Updated] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35243][cdc] Support table schema change events & PreSchema backfill [flink-cdc]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-35297) Add validation for option connect.timeout
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35297][mysql] Add validation for option connect.timeout [flink-cdc]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35297) Add validation for option connect.timeout
Xiao Huang (Jira)
2024/05/06
Re: [PR] [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework [flink]
via GitHub
2024/05/06
[jira] [Resolved] (FLINK-34980) Translate overview document into Chinese
Rui Fan (Jira)
2024/05/06
[jira] [Commented] (FLINK-34980) Translate overview document into Chinese
Rui Fan (Jira)
2024/05/06
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35296) Flink mysql-cdc connector stops reading data
Gang Yang (Jira)
2024/05/06
[jira] [Updated] (FLINK-35295) Improve jdbc connection pool initialization failure message
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35295][mysql] Improve jdbc connection pool initialization failure message [flink-cdc]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35295) Improve jdbc connection pool initialization failure message
Xiao Huang (Jira)
2024/05/06
[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-35294][mysql] Use source config to check if the filter should be applied in timestamp starting mode [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [FLINK-32084][checkpoint] Migrate current file merging of channel state snapshot into the unify file merging framework [flink]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode
Xiao Huang (Jira)
2024/05/06
Re: [PR] [FLINK-34980] Translate overview document into Chinese [flink-kubernetes-operator]
via GitHub
2024/05/06
Re: [PR] [FLINK-35112][python] Fix membership for Row class PyFlink [flink]
via GitHub
2024/05/06
[jira] [Closed] (FLINK-35155) Introduce TableRuntimeException
Dawid Wysakowicz (Jira)
2024/05/06
Re: [PR] [FLINK-35155] Introduce TableRuntimeException [flink]
via GitHub
2024/05/06
Re: [PR] Atlas changes [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
[jira] [Assigned] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource
Zhu Zhu (Jira)
2024/05/06
[jira] [Created] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource
xingbe (Jira)
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
[jira] [Created] (FLINK-35292) Set dummy savepoint path during last-state upgrade
Gyula Fora (Jira)
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager
Ryan Skraba (Jira)
2024/05/06
[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure
Ryan Skraba (Jira)
2024/05/06
[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails
Ryan Skraba (Jira)
2024/05/06
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/05/06
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/06
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/06
[jira] [Updated] (FLINK-34212) Autoscaler Standalone should clean up stopped jobs to prevent memory leaks
ASF GitHub Bot (Jira)
2024/05/06
[PR] [FLINK-34212][autoscaler] Autoscaler Standalone cleans up stopped jobs to prevent memory leaks [flink-kubernetes-operator]
via GitHub
2024/05/06
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/06
[jira] [Commented] (FLINK-33268) Flink REST API response parsing throws exception on new fields
Gabor Somogyi (Jira)
2024/05/06
Re: [PR] [FLINK-35272][cdc][runtime] Transform projection & filter feature overhaul [flink-cdc]
via GitHub
2024/05/06
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-35158][runtime] Error handling in StateFuture's callback [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]
via GitHub
2024/05/05
[jira] [Closed] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT
Jiabao Sun (Jira)
2024/05/05
[jira] [Resolved] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT
Jiabao Sun (Jira)
2024/05/05
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/05
[jira] [Assigned] (FLINK-35274) Occasional failure issue with Flink CDC Db2 UT
Jiabao Sun (Jira)
2024/05/05
Re: [PR] [FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
[jira] [Assigned] (FLINK-35232) Support for retry settings on GCS connector
Xintong Song (Jira)
2024/05/05
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Xintong Song (Jira)
2024/05/05
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
2024/05/05
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [FLINK-35262] Bridge between AsyncKeyedStateBackend and AsyncExecutionController [flink]
via GitHub
2024/05/05
[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector
Xintong Song (Jira)
2024/05/05
Re: [PR] [FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [fix] repair a snapshot-split bug: [flink-cdc]
via GitHub
2024/05/05
Re: [PR] [tidb] Add metrics for tidb connector [flink-cdc]
via GitHub
2024/05/05
[jira] [Closed] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test
Jiabao Sun (Jira)
2024/05/05
[jira] [Resolved] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test
Jiabao Sun (Jira)
2024/05/05
[jira] [Updated] (FLINK-35244) Correct the package for flink-connector-tidb-cdc test
Jiabao Sun (Jira)
2024/05/05
Re: [PR] [FLINK-35244][cdc-connector][tidb] Move package for flink-connector-tidb-cdc test [flink-cdc]
via GitHub
2024/05/05
[jira] [Resolved] (FLINK-34517) environment configs ignored when calling procedure operation
luoyuxia (Jira)
2024/05/05
[jira] [Comment Edited] (FLINK-34517) environment configs ignored when calling procedure operation
luoyuxia (Jira)
2024/05/05
Re: [PR] [BP-1.19][FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]
via GitHub
2024/05/05
Re: [PR] [BP-1.19][FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]
via GitHub
2024/05/05
[jira] [Resolved] (FLINK-32843) [JUnit5 Migration] The jobmaster package of flink-runtime module
Jiabao Sun (Jira)
2024/05/05
[jira] [Updated] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError
dalongliu (Jira)
2024/05/05
[jira] [Comment Edited] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError
dalongliu (Jira)
2024/05/05
Re: [PR] [BP-1.18][FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/05/05
Re: [PR] [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 [flink]
via GitHub
2024/05/05
Re: [PR] [BP-1.17][FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/05/05
Re: [PR] [BP-1.18][FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/05/05
Re: [PR] [BP-1.17][FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/05/05
Re: [PR] [BP-1.18][FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]
via GitHub
2024/05/05
[jira] [Updated] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme
LiuZeshan (Jira)
Later messages