issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/04/10
[jira] [Closed] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration
Jira
2024/04/10
Re: [PR] [FLINK-35015][formats] allow passing hadoop config into parquet reader [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-35015][formats] allow passing hadoop config into parquet reader [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages [flink-cdc]
via GitHub
2024/04/10
[jira] [Updated] (FLINK-35038) Bump test dependency org.yaml:snakeyaml to 2.2
ASF GitHub Bot (Jira)
2024/04/10
Re: [PR] [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` [flink-connector-kafka]
via GitHub
2024/04/10
[PR] [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` [flink-connector-kafka]
via GitHub
2024/04/10
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/10
[jira] [Comment Edited] (FLINK-35040) The performance of serializerHeavyString regresses since April 3
Rui Fan (Jira)
2024/04/10
Re: [PR] [MySQL] Fix for DBZ-7037 and 2217 to not clear tableMapEventByTableId for fake Rotates Event [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-35007] Add support for Flink 1.19 and test 1.20-SNAPSHOT [flink-connector-kafka]
via GitHub
2024/04/10
[jira] [Commented] (FLINK-35002) GitHub action/upload-artifact@v4 can timeout
Ryan Skraba (Jira)
2024/04/10
[jira] [Commented] (FLINK-35023) YARNApplicationITCase failed on Azure
Ryan Skraba (Jira)
2024/04/10
[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Ryan Skraba (Jira)
2024/04/10
[PR] [upgrade] fink to 1.18.1 and pulsar to 3.0.4 [flink-connector-pulsar]
via GitHub
2024/04/10
[jira] [Commented] (FLINK-34514) e2e (1) times out because of an error that's most likely caused by a networking issue
Ryan Skraba (Jira)
2024/04/10
[jira] [Created] (FLINK-35074) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted
Ryan Skraba (Jira)
2024/04/10
Re: [PR] [FLINK-34905][cdc][cdc-connector][mysql] Fix the default length of CHAR/BINARY data type of Add column DDL [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/10
[jira] [Comment Edited] (FLINK-34694) Delete num of associations for streaming outer join
Shuai Xu (Jira)
2024/04/10
[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join
Shuai Xu (Jira)
2024/04/10
Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/10
[PR] [minor][docs] Optimize markdown styles in quickstart doc [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/10
[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3
Rui Fan (Jira)
2024/04/10
[jira] [Commented] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Commented] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Aleksandr Pilipenko (Jira)
2024/04/10
[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
Re: [PR] [FLINK-34962] Use client.getPartitionsForTopic instead of lookup.getPartitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/10
Re: [PR] [FLINK-34962] Use client.getPartitionsForTopic instead of lookup.getPartitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/10
Re: [PR] [FLINK-34962] Use client.getPartitionsForTopic instead of lookup.getPartitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/10
[PR] [FLINK-35702][cdc][doris] Support applying compatible `AlterColumnTypeEvent` to Doris sink [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [pipeline-connector][kafka] add kafka pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/10
[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join
Shuai Xu (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Updated] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Created] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Julien Tournay (Jira)
2024/04/10
[jira] [Created] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent
Xiqian YU (Jira)
2024/04/10
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]
via GitHub
2024/04/10
Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]
via GitHub
2024/04/10
[jira] [Resolved] (FLINK-35023) YARNApplicationITCase failed on Azure
Sergey Nuyanzin (Jira)
2024/04/10
[jira] [Commented] (FLINK-35023) YARNApplicationITCase failed on Azure
Sergey Nuyanzin (Jira)
2024/04/10
Re: [PR] [FLINK-35023][tests] Use surefire.module.config in yarn-test [flink]
via GitHub
2024/04/10
[jira] [Assigned] (FLINK-35023) YARNApplicationITCase failed on Azure
Sergey Nuyanzin (Jira)
2024/04/10
[jira] [Closed] (FLINK-35023) YARNApplicationITCase failed on Azure
Sergey Nuyanzin (Jira)
2024/04/10
Re: [PR] [FLINK-35023][tests] Use surefire.module.config in yarn-test [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34250][docs] add new option for avro format docs [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34250] add config docs for formats [flink]
via GitHub
2024/04/10
Re: [PR] [FLINK-34250] add config docs for formats [flink]
via GitHub
2024/04/10
[PR] [FLINK-34250][docs] add new option for avro format docs [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective
Kevin Mingtarja (Jira)
2024/04/09
Re: [PR] [FLINK-34690] Cast decimal to VARCHAR as primary key in starrocks sink [flink-cdc]
via GitHub
2024/04/09
[PR] chore: fix typo [flink-kubernetes-operator]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Commented] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
[jira] [Created] (FLINK-35071) Remove dependency on flink-shaded from cdc source connector
Hongshun Wang (Jira)
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-34694) Delete num of associations for streaming outer join
Roman Boyko (Jira)
2024/04/09
Re: [PR] [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions [flink]
via GitHub
2024/04/09
Re: [PR] [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions [flink]
via GitHub
2024/04/09
Re: [PR] [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-35009) Change on getTransitivePredecessors breaks connectors
Zhu Zhu (Jira)
2024/04/09
Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
[PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35066] Fix the unwrap from IterationRecord during keyBy [flink-ml]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
[jira] [Comment Edited] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/09
[jira] [Resolved] (FLINK-35044) Introduce statebackend-forst module
Hangxiang Yu (Jira)
2024/04/09
[jira] [Resolved] (FLINK-35043) Release beta version of ForSt
Hangxiang Yu (Jira)
2024/04/09
Re: [PR] [FLINK-35044][state] Init flink-statebackend-forst module [flink]
via GitHub
2024/04/09
Re: [PR] [pipeline-connector][kafka] add kafka pipeline data sink connector. [flink-cdc]
via GitHub
2024/04/09
[jira] [Comment Edited] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/09
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
2024/04/09
Re: [PR] [FLINK-28440][State/changelog] Hotfix! Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
[jira] [Comment Edited] (FLINK-34887) Data lost after rename table
Vallari Rastogi (Jira)
2024/04/09
[jira] [Commented] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.
Vallari Rastogi (Jira)
2024/04/09
[jira] [Commented] (FLINK-34887) Data lost after rename table
Vallari Rastogi (Jira)
2024/04/09
[jira] [Comment Edited] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression
Sergey Nuyanzin (Jira)
2024/04/09
[jira] [Updated] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression
Sergey Nuyanzin (Jira)
2024/04/09
Re: [PR] [BP-1.19][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
[jira] [Closed] (FLINK-35065) Add numFiredTimers and numFiredTimersPerSecond metrics
Piotr Nowojski (Jira)
2024/04/09
Re: [PR] [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34962] Remove unnecessary call Pulsar API: LookupService.getPrtitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression
Sergey Nuyanzin (Jira)
2024/04/09
[jira] [Updated] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression
Sergey Nuyanzin (Jira)
2024/04/09
Re: [PR] [BP-1.18][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
Re: [PR] [BP-1.18][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]
via GitHub
2024/04/09
Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
Etienne Chauchot (Jira)
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-34953) Add github ci for flink-web to auto commit build files
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]
via GitHub
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
Re: [PR] Flk 1380 [flink-training]
via GitHub
2024/04/09
Re: [PR] Flk 1380 [flink-training]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
[jira] [Comment Edited] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
Re: [PR] [FLINK-35023][tests] Use surefire.module.config in yarn-test [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
Re: [PR] [FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
[jira] [Updated] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-35069][API/DataStream]ContinuousProcessingTimeTrigger avoids registering timers at the end of the window [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
[jira] [Updated] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
Re: [PR] [BP-1.18][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
Re: [PR] [BP-1.19][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34549][API] Introduce config, context and processingTimerService for DataStream API V2 [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-35070) remove unused duplicate code
niliushall (Jira)
2024/04/09
Re: [PR] [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks
Jan Kevin Dick (Jira)
2024/04/09
[PR] [BP-1.18][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
[PR] [BP-1.19][FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner [flink]
via GitHub
2024/04/09
[jira] [Created] (FLINK-35070) remove unused duplicate code
niliushall (Jira)
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-34936) Register reused state handles to FileMergingSnapshotManager
Zakelly Lan (Jira)
2024/04/09
[jira] [Assigned] (FLINK-34936) Register shared state files to FileMergingSnapshotManager
Zakelly Lan (Jira)
2024/04/09
[jira] [Created] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
2024/04/09
[jira] [Commented] (FLINK-34936) Register shared state files to FileMergingSnapshotManager
Zakelly Lan (Jira)
2024/04/09
[jira] [Updated] (FLINK-34936) Register shared state files to FileMergingSnapshotManager
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]
via GitHub
2024/04/09
[jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set
Zhanghao Chen (Jira)
2024/04/09
[jira] [Created] (FLINK-35068) Introduce built-in serialization support for Set
Zhanghao Chen (Jira)
2024/04/09
[jira] [Updated] (FLINK-34123) Introduce built-in serialization support for Map and List
Zhanghao Chen (Jira)
2024/04/09
Re: [PR] [FLINK-34239][core] Add copy() method for SerializerConfig [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35065) Add numFiredTimers and numFiredTimersPerSecond metrics
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35062) Migrate RewriteMultiJoinConditionRule
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-34123][core][type] Introduce built-in serialization support for map and lists [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35060][Test/Connector] Provide compatibility of old CheckpointMode for connector testing framework [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35066] Fix the unwrap from IterationRecord during keyBy [flink-ml]
via GitHub
2024/04/09
Re: [PR] [FLINK-35023][tests] Use surefire.module.config in yarn-test [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35023) YARNApplicationITCase failed on Azure
ASF GitHub Bot (Jira)
2024/04/09
[jira] [Commented] (FLINK-35023) YARNApplicationITCase failed on Azure
Ryan Skraba (Jira)
2024/04/09
[jira] [Updated] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-35066] Fix the unwrap from IterationRecord during keyBy [flink-ml]
via GitHub
2024/04/09
[PR] [FLINK-35023][tests] Use surefire.module.config in yarn-test [flink]
via GitHub
2024/04/09
[jira] [Created] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.
Hongshun Wang (Jira)
2024/04/09
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-32080) Restoration of FileMergingSnapshotManager
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy
Yunfeng Zhou (Jira)
2024/04/09
[jira] [Created] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy
Yunfeng Zhou (Jira)
2024/04/09
[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging
Muhammet Orazov (Jira)
2024/04/09
[jira] [Created] (FLINK-35065) Add numFiredTimers and numFiredTimersPerSecond metrics
Piotr Nowojski (Jira)
2024/04/09
[jira] [Commented] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc
Sergey Nuyanzin (Jira)
2024/04/09
[jira] [Closed] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc
Sergey Nuyanzin (Jira)
2024/04/09
[jira] [Resolved] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc
Sergey Nuyanzin (Jira)
2024/04/09
[jira] [Updated] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc
ASF GitHub Bot (Jira)
2024/04/09
Re: [PR] [FLINK-35059] Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc [flink-connector-jdbc]
via GitHub
2024/04/09
[jira] [Closed] (FLINK-35063) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
chendaping (Jira)
2024/04/09
Re: [PR] Merge pull request #1 from apache/main [flink-connector-jdbc]
via GitHub
2024/04/09
[jira] [Created] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
chendaping (Jira)
2024/04/09
[jira] [Created] (FLINK-35063) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
chendaping (Jira)
2024/04/09
Re: [PR] [FLINK-34962] Remove unnecessary call Pulsar API: LookupService.getPrtitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/09
Re: [PR] [FLINK-34962] Remove unnecessary call Pulsar API: LookupService.getPrtitionedTopicMetadata [flink-connector-pulsar]
via GitHub
2024/04/09
Re: [PR] [FLINK-28440][State/changelog] Hotfix! Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization [flink]
via GitHub
2024/04/09
Re: [PR] [FLINK-35037][table-planner]Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER. [flink]
via GitHub
2024/04/09
[PR] [FLINK-28440][State/changelog] Hotfix! Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization [flink]
via GitHub
2024/04/09
[jira] [Updated] (FLINK-35037) Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER
ASF GitHub Bot (Jira)
2024/04/09
[PR] [FLINK-35037][table-planner]Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER. [flink]
via GitHub
Earlier messages
Later messages