You are viewing a plain text version of this content. The canonical link for it is here.
- (flink) branch master updated: [FLINK-36172][runtime] Optimize transient metric cleanup - posted by ju...@apache.org on 2025/03/01 06:01:27 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-36172][runtime] Optimize transient metric cleanup - posted by ju...@apache.org on 2025/03/01 06:23:40 UTC, 0 replies.
- (flink) branch master updated (65772142fda -> a12c9b34a5a) - posted by gu...@apache.org on 2025/03/03 01:42:49 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37148][docs] Update DataStream V2 documents for StateManager#getState and StateManager#getStateOptional methods - posted by gu...@apache.org on 2025/03/03 01:45:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37387][build] Enable license check for jdk17 and jdk21 - posted by sn...@apache.org on 2025/03/03 08:27:01 UTC, 0 replies.
- (flink) branch master updated (f1a5add443d -> a08e6021423) - posted by pn...@apache.org on 2025/03/03 10:27:34 UTC, 0 replies.
- (flink) 01/05: [hotfix] Fix DeduplicateFunctionHelper#isDuplicate name - posted by pn...@apache.org on 2025/03/03 10:27:35 UTC, 0 replies.
- (flink) 02/05: [FLINK-37005][table] Add RowTimeDeduplicateKeepFirstRowFunction - posted by pn...@apache.org on 2025/03/03 10:27:36 UTC, 0 replies.
- (flink) 03/05: [FLINK-37005][table] Adjust planner to output inserts only from row time and proc time deduplicate when keeping first row - posted by pn...@apache.org on 2025/03/03 10:27:37 UTC, 0 replies.
- (flink) 04/05: [FLINK-37280] Workaround bug disabling mini batch combined with append-only deduplication - posted by pn...@apache.org on 2025/03/03 10:27:38 UTC, 0 replies.
- (flink) 05/05: [FLINK-37005][hotfix] Unify all DeduplicateTest cases to check for changelog mode - posted by pn...@apache.org on 2025/03/03 10:27:39 UTC, 0 replies.
- svn commit: r75235 - /dev/flink/flink-kubernetes-operator-1.11.0-rc1/ /release/flink/flink-kubernetes-operator-1.11.0/ - posted by gy...@apache.org on 2025/03/03 12:24:49 UTC, 0 replies.
- svn commit: r75236 - in /release/flink: flink-kubernetes-operator-1.8.0/ flink-kubernetes-operator-1.9.0/ - posted by gy...@apache.org on 2025/03/03 12:26:51 UTC, 0 replies.
- (flink-kubernetes-operator) annotated tag release-1.11.0 updated (cc9c6cb8 -> 5a1a9744) - posted by gy...@apache.org on 2025/03/03 12:28:51 UTC, 0 replies.
- (flink-kubernetes-operator) annotated tag release-1.11.0-rc1 deleted (was 22d8865b) - posted by gy...@apache.org on 2025/03/03 12:29:38 UTC, 0 replies.
- (flink-web) branch asf-site updated (3ee0001eb -> a9fead86b) - posted by gy...@apache.org on 2025/03/03 12:41:55 UTC, 0 replies.
- (flink-web) 01/02: Kubernetes Operator 1.11.0 release - posted by gy...@apache.org on 2025/03/03 12:41:56 UTC, 0 replies.
- (flink-web) 02/02: Rebuild website - posted by gy...@apache.org on 2025/03/03 12:41:57 UTC, 2 replies.
- (flink) branch master updated: [FLINK-37402][table] Emit watermarks after record in TestSourceFunction and TestValuesRuntimeFunctions - posted by tw...@apache.org on 2025/03/03 13:31:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned. - posted by gy...@apache.org on 2025/03/04 08:45:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-21912][pyflink] Introduce ResolvedSchema in Python Table API - posted by tw...@apache.org on 2025/03/04 09:28:42 UTC, 0 replies.
- (flink) branch master updated (ea9c8be883e -> 66104a3fbbc) - posted by za...@apache.org on 2025/03/04 11:52:11 UTC, 0 replies.
- (flink) 01/04: [FLINK-37379][state/forst] Double list LRU in ForSt state and cache reload - posted by za...@apache.org on 2025/03/04 11:52:12 UTC, 1 replies.
- (flink) 02/04: [FLINK-37379][state/forst] Enable forst file cache by default - posted by za...@apache.org on 2025/03/04 11:52:13 UTC, 1 replies.
- (flink) 03/04: [FLINK-37379][state/forst] Enrich the interfaces of `CacheLimitPolicy` to make cache run smooth - posted by za...@apache.org on 2025/03/04 11:52:14 UTC, 1 replies.
- (flink) 04/04: [hotfix] Bump forst version to 0.1.7 - posted by za...@apache.org on 2025/03/04 11:52:15 UTC, 1 replies.
- (flink) branch master updated (66104a3fbbc -> 0d1b5aa1cdd) - posted by za...@apache.org on 2025/03/04 11:55:22 UTC, 0 replies.
- (flink) 01/07: [FLINK-33734][checkpointing] Introduce interface ChannelState,InputStateHandle,OutputStateHandle - posted by za...@apache.org on 2025/03/04 11:55:23 UTC, 0 replies.
- (flink) 02/07: [FLINK-33734][checkpointing] Use interface replace InputChannelStateHandle and ResultSubpartitionStateHandle in OperatorSubtaskState - posted by za...@apache.org on 2025/03/04 11:55:24 UTC, 0 replies.
- (flink) 03/07: [FLINK-33734][checkpointing] Extract interface ChannelStateHandleSerializer - posted by za...@apache.org on 2025/03/04 11:55:25 UTC, 0 replies.
- (flink) 04/07: [FLINK-33734][checkpointing] Introduce merged channel state handle - posted by za...@apache.org on 2025/03/04 11:55:26 UTC, 0 replies.
- (flink) 05/07: [hotfix] Make some improper static method become instance method - posted by za...@apache.org on 2025/03/04 11:55:27 UTC, 0 replies.
- (flink) 06/07: [FLINK-33734][checkpointing] Introduce MetadataV6Serializer for merged channel state handle - posted by za...@apache.org on 2025/03/04 11:55:28 UTC, 0 replies.
- (flink) 07/07: [FLINK-33734][checkpointing] Compact and serialize original channel state handle before send checkpoint ack to JobManager - posted by za...@apache.org on 2025/03/04 11:55:29 UTC, 0 replies.
- (flink-shaded) branch dependabot/maven/flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/org.apache.zookeeper-zookeeper-3.7.2 deleted (was 3843171) - posted by gi...@apache.org on 2025/03/04 12:48:21 UTC, 0 replies.
- (flink-shaded) branch dependabot/maven/flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36/org.apache.zookeeper-zookeeper-3.7.2 deleted (was b9f8e4a) - posted by gi...@apache.org on 2025/03/04 12:49:07 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-3154][API] Upgrade from Kryo 2.x to Kryo 5.x. Removed twitter chill companion library which is abandoned. - posted by gy...@apache.org on 2025/03/04 13:15:23 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-35810][test] Fix AsyncWaitOperatorTest missing endInput bug - posted by gu...@apache.org on 2025/03/05 02:03:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35810][test] Fix AsyncWaitOperatorTest missing endInput bug (#26242) - posted by gu...@apache.org on 2025/03/05 02:04:00 UTC, 0 replies.
- (flink) branch release-2.0 updated (56a1dcb75a2 -> 315046b171b) - posted by ju...@apache.org on 2025/03/05 02:09:29 UTC, 0 replies.
- (flink) 01/02: [hotfix] fix NOTICE file in order to fix java 11 license check - posted by ju...@apache.org on 2025/03/05 02:09:30 UTC, 0 replies.
- (flink) 02/02: [FLINK-37387][build] Enable license check for jdk17 and jdk21 - posted by ju...@apache.org on 2025/03/05 02:09:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37348][pipeline-paimon] Fix paimon ArrayIndexOutOfBoundsException when add column first - posted by le...@apache.org on 2025/03/05 03:53:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37119][pipeline-paimon] Bump the version of Paimon version to 1.0.1 - posted by le...@apache.org on 2025/03/05 03:56:22 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild website - posted by gy...@apache.org on 2025/03/05 06:54:22 UTC, 3 replies.
- (flink) branch release-2.0 updated (315046b171b -> 0cb17adb0ba) - posted by za...@apache.org on 2025/03/05 08:51:27 UTC, 0 replies.
- (flink-cdc) branch master updated (ba282700c -> 8040622de) - posted by le...@apache.org on 2025/03/05 11:35:07 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37409][cdc-connector/mysql] Catch throwable to exit reading binlog when error occurs - posted by le...@apache.org on 2025/03/05 11:40:03 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37278][cdc-runtime] Optimize regular schema evolution topology's performance - posted by le...@apache.org on 2025/03/05 11:46:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37420] Fix AbstractAggregatingState#add that may return wrong result (#26246) - posted by za...@apache.org on 2025/03/05 12:55:53 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37120][cdc-connector] Introduce config to control assign unbounded splits firstly to avoid buffering too much data - posted by le...@apache.org on 2025/03/05 14:31:20 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37364][build] Bump Flink 1.19 and 1.20 to their latest patch versions - posted by le...@apache.org on 2025/03/05 15:08:16 UTC, 0 replies.
- (flink) branch master updated: [hotfix][docs] URL for test-filesystem is wrong in materialized table quickstart - posted by li...@apache.org on 2025/03/06 02:22:17 UTC, 0 replies.
- (flink) branch master updated (283550289f6 -> 1d17557913e) - posted by za...@apache.org on 2025/03/06 03:27:18 UTC, 0 replies.
- (flink) branch release-2.0 updated (0cb17adb0ba -> 1ce168d94ac) - posted by za...@apache.org on 2025/03/06 03:27:37 UTC, 0 replies.
- (flink) 01/02: [FLINK-37312][doc] Add missing closing tab in state_v2.md - posted by za...@apache.org on 2025/03/06 03:27:38 UTC, 0 replies.
- (flink) 02/02: [hotfix][docs] Fix label format in docs for state v2 - posted by za...@apache.org on 2025/03/06 03:27:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37424][release] Using JDK11 for the binary convenience release - posted by gu...@apache.org on 2025/03/06 03:49:26 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37424][release] Using JDK11 for the binary convenience release - posted by gu...@apache.org on 2025/03/06 03:54:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37120][minor] Rename ending chunk to unbounded chunk - posted by le...@apache.org on 2025/03/06 07:47:23 UTC, 0 replies.
- (flink-docker) branch dev-master updated (bc2f24e -> 02dacae) - posted by gu...@apache.org on 2025/03/06 09:00:04 UTC, 0 replies.
- (flink-docker) 01/02: [FLINK-32482][docker] Add Java 21 to build matrix - posted by gu...@apache.org on 2025/03/06 09:00:05 UTC, 1 replies.
- (flink-docker) 02/02: [FLINK-32482][docker] Change default docker image tag to jdk17 - posted by gu...@apache.org on 2025/03/06 09:00:06 UTC, 1 replies.
- (flink-docker) branch dev-2.0 updated (b50a61b -> ea16842) - posted by gu...@apache.org on 2025/03/06 09:01:48 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup (#133) - posted by fp...@apache.org on 2025/03/06 09:56:30 UTC, 0 replies.
- (flink) branch master updated (0a30a65c1a0 -> 6e8d219775f) - posted by gu...@apache.org on 2025/03/06 11:20:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37419] Align the map value serialization in ForSt sync and async states (#26245) - posted by za...@apache.org on 2025/03/06 11:39:23 UTC, 0 replies.
- (flink) branch master updated (ff70dd68395 -> 45fcd56bbe4) - posted by za...@apache.org on 2025/03/06 11:45:38 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37367][state/forst] Make ForSt inherit uploaded SST files after restorations. (#26259) - posted by za...@apache.org on 2025/03/06 11:46:13 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37424][release] Using JDK11 for the nightly binary release - posted by gu...@apache.org on 2025/03/06 11:46:49 UTC, 0 replies.
- (flink) branch release-2.0 updated (e6a94b50d70 -> ceb6aa69e80) - posted by za...@apache.org on 2025/03/06 15:15:04 UTC, 0 replies.
- (flink) 01/02: [FLINK-37420] Fix AbstractAggregatingState#add that may return wrong result (#26246) - posted by za...@apache.org on 2025/03/06 15:15:05 UTC, 0 replies.
- (flink) 02/02: [FLINK-37419] Align the map value serialization in ForSt sync and async states (#26245) - posted by za...@apache.org on 2025/03/06 15:15:06 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37425] Sanity check before ForSt cache created (#26253) - posted by za...@apache.org on 2025/03/06 15:17:59 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37425] Sanity check before ForSt cache created (#26254) - posted by za...@apache.org on 2025/03/06 15:18:08 UTC, 0 replies.
- (flink-docker) branch dev-2.0 updated: [FLINK-37035][release] Migrate testing job from SourceFunction to FLIP-27 based Source - posted by gu...@apache.org on 2025/03/07 03:03:06 UTC, 0 replies.
- (flink-docker) branch dev-2.1 updated (877ebde -> 92abcba) - posted by gu...@apache.org on 2025/03/07 03:05:28 UTC, 0 replies.
- (flink-docker) 01/04: [FLINK-37035][release] Migrate testing job from SourceFunction to FLIP-27 based Source - posted by gu...@apache.org on 2025/03/07 03:05:29 UTC, 0 replies.
- (flink-docker) 02/04: [FLINK-37035][release] Update dev-master point to 2.1. - posted by gu...@apache.org on 2025/03/07 03:05:30 UTC, 0 replies.
- (flink-docker) 03/04: [FLINK-32482][docker] Add Java 21 to build matrix - posted by gu...@apache.org on 2025/03/07 03:05:31 UTC, 0 replies.
- (flink-docker) 04/04: [FLINK-32482][docker] Change default docker image tag to jdk17 - posted by gu...@apache.org on 2025/03/07 03:05:32 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated (123334b -> 2abed8e) - posted by ji...@apache.org on 2025/03/07 05:34:12 UTC, 0 replies.
- (flink-connector-mongodb) 01/02: [hotfix] add missing license header - posted by ji...@apache.org on 2025/03/07 05:34:13 UTC, 0 replies.
- (flink-connector-mongodb) 02/02: [hotfix][docs] fix lookup.partial-cache.cache-missing-key option name in docs - posted by ji...@apache.org on 2025/03/07 05:34:14 UTC, 0 replies.
- (flink) annotated tag release-2.0.0-rc1 updated (a57024cd3d0 -> 58f4110ffd6) - posted by gu...@apache.org on 2025/03/07 06:12:58 UTC, 0 replies.
- (flink) annotated tag release-2.0.0-rc1 deleted (was 58f4110ffd6) - posted by gu...@apache.org on 2025/03/07 06:25:07 UTC, 0 replies.
- (flink) branch release-2.0 updated: [hotfix] Remove unnecessary exclude in japicmp plugin (#26261) - posted by sx...@apache.org on 2025/03/07 06:44:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend (#26267) - posted by le...@apache.org on 2025/03/07 07:39:05 UTC, 0 replies.
- (flink) branch release-2.0 updated: [BP-2.0][FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend (#26269) - posted by le...@apache.org on 2025/03/07 07:48:45 UTC, 0 replies.
- svn commit: r75344 - in /dev/flink/flink-2.0.0-rc1: ./ python/ - posted by gu...@apache.org on 2025/03/07 09:20:01 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls for DDB connector - posted by ho...@apache.org on 2025/03/07 11:15:49 UTC, 0 replies.
- (flink) branch master updated (c3190b7bce5 -> bb5ab2e20e0) - posted by ro...@apache.org on 2025/03/07 15:10:03 UTC, 0 replies.
- (flink) 01/05: [FLINK-37401] Extract the private test method into a new utility class - posted by ro...@apache.org on 2025/03/07 15:10:04 UTC, 0 replies.
- (flink) 02/05: [FLINK-37401] Support several expected log events values - posted by ro...@apache.org on 2025/03/07 15:10:05 UTC, 0 replies.
- (flink) 03/05: [FLINK-37401] Extract logic related to slot allocation to a separate method - posted by ro...@apache.org on 2025/03/07 15:10:06 UTC, 0 replies.
- (flink) 04/05: [FLINK-37401] Migrate JobMasterTriggerSavepointITCase from JUnit4 to JUnit5 and Jupiter - posted by ro...@apache.org on 2025/03/07 15:10:07 UTC, 0 replies.
- (flink) 05/05: [FLINK-37401] Add JobID to MDC in JobMaster, ResourceManager, DefaultSlotStatusSyncer, FineGrainedSlotManager - posted by ro...@apache.org on 2025/03/07 15:10:08 UTC, 0 replies.
- (flink) branch master updated: [hotfix][doc] Fix link in Chinese version of sourcesSinks.md (#25977) - posted by za...@apache.org on 2025/03/08 11:46:26 UTC, 0 replies.
- (flink) branch master updated (6a2b511f15f -> 9da1e10699b) - posted by za...@apache.org on 2025/03/08 13:50:55 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37437][state/forst] Fix #exist and #getFileStatus to give the information of writing files (#26272) - posted by za...@apache.org on 2025/03/08 13:51:48 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36402] edgeRemapings typo fixed to edgeRemappings (#26220) - posted by za...@apache.org on 2025/03/08 13:56:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36402] edgeRemapings typo fixed to edgeRemappings - posted by sn...@apache.org on 2025/03/09 07:39:58 UTC, 0 replies.
- (flink) branch master updated (a0f07fef4e5 -> c7aa1748cfe) - posted by za...@apache.org on 2025/03/10 05:59:03 UTC, 0 replies.
- (flink) 01/06: [FLINK-37437][state/forst] Support file override in wrapped file system - posted by za...@apache.org on 2025/03/10 05:59:04 UTC, 1 replies.
- (flink) 02/06: [FLINK-37437][state/forst] Unguarded file system to enable stream sharing between threads. - posted by za...@apache.org on 2025/03/10 05:59:05 UTC, 1 replies.
- (flink) 03/06: [FLINK-37437][state/forst] Avoid the deletion of primary directory in ForSt - posted by za...@apache.org on 2025/03/10 05:59:06 UTC, 1 replies.
- (flink) 04/06: [FLINK-37437][state/forst] Store misc files in local for rescaling - posted by za...@apache.org on 2025/03/10 05:59:07 UTC, 1 replies.
- (flink) 05/06: [FLINK-37437][state/forst] Bundle file cache entry with mapping entry and release properly - posted by za...@apache.org on 2025/03/10 05:59:08 UTC, 1 replies.
- (flink) branch release-2.0 updated (458529f6aa8 -> 9baec0bc14c) - posted by za...@apache.org on 2025/03/10 05:59:08 UTC, 0 replies.
- (flink) 06/06: [FLINK-37437][state/forst] Bump forstjni version to 0.1.8 - posted by za...@apache.org on 2025/03/10 05:59:09 UTC, 1 replies.
- (flink-cdc) branch master updated: [FLINK-37352][pipeline-connector/paimon] Supports write full change log to Paimon table - posted by le...@apache.org on 2025/03/10 07:37:06 UTC, 0 replies.
- svn commit: r75466 - in /dev/flink/flink-2.0.0-rc2: ./ python/ - posted by xt...@apache.org on 2025/03/10 08:41:57 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37381] [doc] Fix typo in Join document (#26209) - posted by rm...@apache.org on 2025/03/10 08:47:41 UTC, 0 replies.
- (flink) annotated tag release-2.0.0-rc2 updated (cc017da9ae1 -> 39e67480a67) - posted by xt...@apache.org on 2025/03/10 09:03:27 UTC, 0 replies.
- [I] flink-cdc考虑归档问题 [flink-cdc] - posted by "chenrenfei (via GitHub)" <gi...@apache.org> on 2025/03/10 09:24:09 UTC, 1 replies.
- (flink) branch master updated: [FLINK-37302][table] Support PTFs with time and timer services - posted by tw...@apache.org on 2025/03/10 10:05:24 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-33525] Move ImpulseSource to new Source API (#950) - posted by af...@apache.org on 2025/03/10 17:27:08 UTC, 0 replies.
- Re: [I] flink-cdc实时同步表时考虑过滤归档删除问题 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/03/11 00:04:22 UTC, 2 replies.
- (flink-cdc) branch master updated: [FLINK-37429][transform] Map each column name to a new name in generated expression - posted by le...@apache.org on 2025/03/11 04:09:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37158][tests] Introduce ForSt to existing ITCases (#26000) - posted by le...@apache.org on 2025/03/12 05:29:31 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][minor] Correct variables name according to SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED option name - posted by le...@apache.org on 2025/03/12 05:39:55 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37386][cdc-runtime] Emit CreateTableEvent only when met the related SourceRecord - posted by le...@apache.org on 2025/03/12 07:58:14 UTC, 0 replies.
- Re: [I] Flink-CDC 2.3.0 consumes data based on SPECIFIC_OFFSETS. If the table structure is changed after the starting offset, it will not be able to consume the data correctly. [flink-cdc] - posted by "AdvancingStone (via GitHub)" <gi...@apache.org> on 2025/03/12 11:19:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators (#26283) - posted by le...@apache.org on 2025/03/12 11:58:13 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37204][pipeline-connector/starrocks] Add missing StarRocks connector options for 1.2.10 - posted by le...@apache.org on 2025/03/12 13:21:14 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37449][cdc-connector/postgres] Fix Postgres CDC source doesn't commit lsn when TaskManager failover - posted by le...@apache.org on 2025/03/12 13:25:12 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37452][pipeline-connector/paimon] Support writing to Paimon append-only table - posted by le...@apache.org on 2025/03/12 13:30:20 UTC, 0 replies.
- (flink) branch master updated (932f17da6cb -> 66913489fb3) - posted by tw...@apache.org on 2025/03/12 13:55:52 UTC, 0 replies.
- (flink) branch master updated: Revert "[FLINK-37158][tests] Introduce ForSt to existing ITCases (#26000)" (#26291) - posted by le...@apache.org on 2025/03/13 08:00:48 UTC, 0 replies.
- (flink) branch master updated (0d0c185c7c2 -> 3dde2552e84) - posted by tw...@apache.org on 2025/03/13 09:41:35 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36784][docs][pipeline-connector/mysql] Add op_ts metadata docs for MySQL pipeline connector - posted by le...@apache.org on 2025/03/13 14:08:31 UTC, 0 replies.
- (flink) branch master updated (3dde2552e84 -> 21d7a03f973) - posted by sn...@apache.org on 2025/03/13 14:37:01 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37460][state] Make state processor API checkpoint ID configurable - posted by ga...@apache.org on 2025/03/14 07:11:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-25986][python] Add remaining FLIP-190 API methods to Python Table API - posted by tw...@apache.org on 2025/03/14 09:20:53 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-897dbe58e8 created (now 1ec855a7cb6) - posted by gi...@apache.org on 2025/03/14 09:22:55 UTC, 0 replies.
- Re: [I] 支持 FlinkDeployment 部署 [flink-cdc] - posted by "potterhe (via GitHub)" <gi...@apache.org> on 2025/03/14 11:59:43 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-36855] Source API implementation - posted by fc...@apache.org on 2025/03/14 14:52:32 UTC, 0 replies.
- svn commit: r75585 - /dev/flink/flink-connector-mongodb-2.0.0-rc2/ /release/flink/flink-connector-mongodb-2.0.0/ - posted by le...@apache.org on 2025/03/15 03:44:59 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37370] [Observer] Fix exception caught when handling checkpointing not enabled for batch jobs and add batch e2e test - posted by gy...@apache.org on 2025/03/16 18:25:37 UTC, 0 replies.
- (flink-connector-mongodb) annotated tag v2.0.0 updated (0192c95 -> 510bc1c) - posted by ji...@apache.org on 2025/03/17 01:31:38 UTC, 0 replies.
- (flink-docker) branch dev-master updated: [hotfix] re-add jdk11 to test matrix - posted by gu...@apache.org on 2025/03/17 01:58:13 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-37197][Connectors/MongoDB] Updating development version to 2.1-SNAPSHOT - posted by ji...@apache.org on 2025/03/17 02:23:56 UTC, 0 replies.
- (flink-web) branch asf-site updated: Adding MongoDB Connector v2.0.0 - posted by ji...@apache.org on 2025/03/17 02:42:19 UTC, 0 replies.
- (flink-connector-mongodb) branch v2.0 updated (e9d484b -> efe5d4a) - posted by ji...@apache.org on 2025/03/17 04:26:36 UTC, 0 replies.
- (flink-connector-mongodb) 01/01: [hotfix][Connectors/MongoDB] Updating website data for 2.0.0 - posted by ji...@apache.org on 2025/03/17 04:26:37 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37432][release] Add release note for release 2.0 - posted by gu...@apache.org on 2025/03/17 06:10:36 UTC, 0 replies.
- (flink) branch master updated (0570c229979 -> 3891fe8c13d) - posted by li...@apache.org on 2025/03/17 06:46:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37438][refactor] Improve the createLocalEnvironment by reduce duplicate operation on Configuration (#26273) - posted by fa...@apache.org on 2025/03/17 06:47:47 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [hotfix] Update weekly bulds against the latest released v2.0 branch - posted by ji...@apache.org on 2025/03/17 09:44:33 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-30687][table] Fix wrong result of agg with fiter which references first input column - posted by li...@apache.org on 2025/03/17 11:56:53 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-30687][table] Fix wrong result of agg with fiter which references first input column - posted by li...@apache.org on 2025/03/17 11:57:17 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37480][build] Bump japicmp to avoid false positives - posted by ga...@apache.org on 2025/03/17 12:17:03 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37480][build] Bump japicmp to avoid false positives - posted by ga...@apache.org on 2025/03/17 12:17:45 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-37265][docs] Document of python elasticsearch connector exeample has a little mistake - posted by gu...@apache.org on 2025/03/18 03:55:33 UTC, 0 replies.
- (flink-docker) branch dev-2.0 updated: [FLINK-37500] Add GPG key for 2.0.0 release - posted by gu...@apache.org on 2025/03/18 06:23:47 UTC, 0 replies.
- (flink-docker) branch dev-master updated: [FLINK-37500] Add GPG key for 2.0.0 release - posted by gu...@apache.org on 2025/03/18 06:23:55 UTC, 0 replies.
- svn commit: r75623 - /dev/flink/flink-2.0.0-rc2/ /release/flink/flink-2.0.0/ - posted by xt...@apache.org on 2025/03/18 09:34:32 UTC, 0 replies.
- svn commit: r75624 - in /dev/flink: flink-2.0.0-rc0/ flink-2.0.0-rc1/ - posted by xt...@apache.org on 2025/03/18 09:43:43 UTC, 0 replies.
- (flink-docker) branch master updated: Update Dockerfiles for 2.0.0 release - posted by gu...@apache.org on 2025/03/18 11:08:40 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37243] Adds main thread callback to AsyncWaitOperator (#26122) - posted by pn...@apache.org on 2025/03/18 16:05:48 UTC, 0 replies.
- (flink) annotated tag release-2.0.0 updated (cc017da9ae1 -> 56611aba639) - posted by gu...@apache.org on 2025/03/19 05:36:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37463][state/forst] make serialzer in ForStMapState Threadlocal (#26286) - posted by le...@apache.org on 2025/03/19 06:02:52 UTC, 0 replies.
- (flink) branch master updated: [hotfix][doc] two modes instead of three - posted by ji...@apache.org on 2025/03/19 09:57:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37412] Add MIN_RESOURCES TaskManagerLoadBalanceMode to maximize TM usage - posted by ma...@apache.org on 2025/03/19 15:21:28 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-35350] Add Kudu connector documentation - posted by fc...@apache.org on 2025/03/19 18:46:32 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [hotfix] Move `data` dir to the proper place - posted by fc...@apache.org on 2025/03/19 18:50:50 UTC, 0 replies.
- (flink) branch release-1.20 updated (69d998f1614 -> 73c556c7568) - posted by sh...@apache.org on 2025/03/20 02:43:39 UTC, 0 replies.
- (flink) 01/03: [FLINK-37222] Do not reuse views across TableEnvironments in SQL client - posted by sh...@apache.org on 2025/03/20 02:43:40 UTC, 0 replies.
- (flink) 02/03: [FLINK-37222][Test] Introduce simple test submitting nexmark sql via sql client - posted by sh...@apache.org on 2025/03/20 02:43:41 UTC, 0 replies.
- (flink) 03/03: [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView - posted by sh...@apache.org on 2025/03/20 02:43:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [minor][hotfix] Clean unused code for schema operator&coordinator - posted by le...@apache.org on 2025/03/20 03:34:56 UTC, 0 replies.
- (flink) branch master updated: [refactor] Remove unnecessary implements for InternalPriorityQueue (#26315) - posted by fa...@apache.org on 2025/03/20 09:30:07 UTC, 0 replies.
- (flink) branch master updated (1d447895760 -> b1c3209769d) - posted by ga...@apache.org on 2025/03/20 11:38:40 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [hotfix] Add `KuduSource#builder()` instead of `KuduSourceBuilder` constructor - posted by fc...@apache.org on 2025/03/20 15:12:43 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37505][python] Add pyflink YAML based config support - posted by ga...@apache.org on 2025/03/20 15:52:40 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37460][state] Make state processor API checkpoint ID configurable - posted by ga...@apache.org on 2025/03/20 16:33:01 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-37527] Add `KuduSource` documentation - posted by fc...@apache.org on 2025/03/21 09:42:43 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37475] Drop ChangelogNormalize for piping from upsert source to sink - posted by dw...@apache.org on 2025/03/21 15:06:36 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView - posted by sh...@apache.org on 2025/03/24 01:19:31 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37222][table] Don't resolve the CatalogView to QueryOperationCatalogView - posted by sh...@apache.org on 2025/03/24 01:22:08 UTC, 0 replies.
- (flink-web) branch asf-site updated (3914636ce -> 7a905242e) - posted by xt...@apache.org on 2025/03/24 08:16:52 UTC, 0 replies.
- (flink-web) 01/02: Add Flink 2.0.0 release - posted by xt...@apache.org on 2025/03/24 08:16:53 UTC, 0 replies.
- (flink) branch master updated (df058589aff -> c151909d5a0) - posted by gu...@apache.org on 2025/03/24 08:31:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37423][table] Support PTFs in Table API - posted by tw...@apache.org on 2025/03/24 11:51:47 UTC, 0 replies.
- (flink-web) branch asf-site updated (f90b883a7 -> 7cb72b7f1) - posted by za...@apache.org on 2025/03/24 13:17:09 UTC, 0 replies.
- (flink-web) 01/02: [hotfix] Fix the broken TOC - posted by za...@apache.org on 2025/03/24 13:17:10 UTC, 0 replies.
- (flink) branch master updated: [hotfix] The checkState should follows the Flink code style - posted by xt...@apache.org on 2025/03/25 00:55:10 UTC, 0 replies.
- (flink-web) branch asf-site updated (7cb72b7f1 -> 629d8326d) - posted by fa...@apache.org on 2025/03/25 02:10:35 UTC, 0 replies.
- (flink-web) 01/03: corrected released version in the release doc. - posted by fa...@apache.org on 2025/03/25 02:10:36 UTC, 0 replies.
- (flink-web) 02/03: corrected released version in the release doc of 1.10 and 1.9 - posted by fa...@apache.org on 2025/03/25 02:10:37 UTC, 0 replies.
- (flink-web) 03/03: Rebuild website - posted by fa...@apache.org on 2025/03/25 02:10:38 UTC, 0 replies.
- [I] How to define a slotSharingGroup on pipeline? when using flink-cdc.sh [flink-cdc] - posted by "Taymindis (via GitHub)" <gi...@apache.org> on 2025/03/25 02:16:39 UTC, 3 replies.
- (flink-web) branch asf-site updated: Add LTS documentation link - posted by gu...@apache.org on 2025/03/25 02:46:56 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37432][release] Add release note for release 2.0 - posted by gu...@apache.org on 2025/03/25 02:55:08 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36573][cdc-connector][mysql] Print table names of binlog split when checkpointing - posted by le...@apache.org on 2025/03/25 06:06:58 UTC, 0 replies.
- (flink) branch master updated (34edc0322d4 -> 960a253e8bd) - posted by mx...@apache.org on 2025/03/25 08:17:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes - posted by dw...@apache.org on 2025/03/25 16:02:09 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-37517][[Connectors/Elasticsearch] Bump flink to 2.0.0 - posted by gu...@apache.org on 2025/03/26 02:11:30 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Remove redundant config operation for ADDRESS and PORT (#26342) - posted by fa...@apache.org on 2025/03/26 02:17:05 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Rename JobRestEndpointFactory to ApplicationRestEndpointFactory (#26347) - posted by fa...@apache.org on 2025/03/26 02:28:45 UTC, 0 replies.
- (flink) branch master updated (36111caf994 -> d39b8a61df3) - posted by fa...@apache.org on 2025/03/26 02:37:07 UTC, 0 replies.
- (flink) branch master updated (d39b8a61df3 -> a5d419427d7) - posted by fa...@apache.org on 2025/03/26 02:40:40 UTC, 0 replies.
- (flink) branch master updated: [hotfix][clients] Refactor PackagedProgram#getJobJarAndDependencies to reduce some redundant lines. (#26238) - posted by fa...@apache.org on 2025/03/26 02:45:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36443][table][test] Improve flaky tests related to partition specs (#26335) - posted by xu...@apache.org on 2025/03/26 03:38:20 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37539][pipeline-connector/paimon] Replace stream with parallelStream to optimize the performance - posted by le...@apache.org on 2025/03/26 05:53:40 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes - posted by dw...@apache.org on 2025/03/26 07:57:47 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37410][runtime/metrics] Split level Watermark metrics (#26276) - posted by pn...@apache.org on 2025/03/26 09:12:07 UTC, 0 replies.
- (flink-web) branch asf-site updated: [hotfix] Update Slack invite link - posted by ma...@apache.org on 2025/03/26 11:22:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37533][CI] Reduce the stale PR github action timouts to match typical apache values (90 days inactive with 30 to respond) (#26336) - posted by rm...@apache.org on 2025/03/26 12:53:29 UTC, 0 replies.
- (flink) branch master updated (df9db31010f -> 0091f39b4a7) - posted by pn...@apache.org on 2025/03/26 12:54:49 UTC, 0 replies.
- (flink-connector-aws) branch main updated: [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator - posted by ho...@apache.org on 2025/03/26 15:35:53 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37405] Validate config prefixes for Flink 2.0 - posted by gy...@apache.org on 2025/03/26 16:14:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37490][Docs] Add 2.0 to PreviousDocs list - posted by gu...@apache.org on 2025/03/27 01:40:14 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37493][release] Update japicmp configuration for 2.0.0 - posted by gu...@apache.org on 2025/03/27 01:40:50 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [ci] PRs should not cancel each others or traget branches CI runs - posted by gy...@apache.org on 2025/03/27 07:54:34 UTC, 0 replies.
- (flink) branch master updated (8c9d4ee5ab0 -> d5ecb07dab4) - posted by ju...@apache.org on 2025/03/27 08:53:41 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-35360][cli] Support Yarn application mode for yaml job - posted by le...@apache.org on 2025/03/27 10:18:15 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37533][CI] Add action: write permission to stale PR github action (#26360) - posted by rm...@apache.org on 2025/03/27 10:28:33 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37430] Operator hides the actual error on deployment issues - posted by gy...@apache.org on 2025/03/27 10:33:02 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37358][kafka] Support to pass format options - posted by le...@apache.org on 2025/03/27 12:02:43 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception - posted by le...@apache.org on 2025/03/27 12:05:58 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37371][cdc-connector/postgresql] Postgres CDC incremental source fails to handle upper-case table and column names - posted by le...@apache.org on 2025/03/27 12:11:49 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37571] Fix JobGraph removal for 2.0 last-state upgrades - posted by gy...@apache.org on 2025/03/27 16:01:00 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37562] Do not check all JM replicas in observer - posted by gy...@apache.org on 2025/03/27 16:43:21 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [hotfix] Do not leak autoscaler configs to jobs - posted by gy...@apache.org on 2025/03/27 16:58:16 UTC, 0 replies.
- (flink-connector-kafka) branch main updated (33d00224 -> c2805458) - posted by le...@apache.org on 2025/03/28 03:25:14 UTC, 0 replies.
- (flink-connector-kafka) 01/03: [FLINK-36848][Connectors/Kafka] Remove Deprecated class and relevant tests. - posted by le...@apache.org on 2025/03/28 03:25:15 UTC, 0 replies.
- (flink-connector-kafka) 02/03: [FLINK-36648][Connectors/Kafka] Bump Flink version to 2.0.0 - posted by le...@apache.org on 2025/03/28 03:25:16 UTC, 0 replies.
- (flink-connector-kafka) 03/03: [hotfix][build] Add stable version to weekly CI - posted by le...@apache.org on 2025/03/28 03:25:17 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-37144][Connectors/Kafka] Update version to 4.0-SNAPSHOT - posted by le...@apache.org on 2025/03/28 03:43:04 UTC, 0 replies.
- (flink) branch master updated (56e1e76a776 -> b506661a9d0) - posted by fc...@apache.org on 2025/03/28 05:35:33 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37556][metrics][otel] Add missing dependencies for OpenTelemetry - posted by fc...@apache.org on 2025/03/28 05:36:13 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37455] Create error Event when job goes into FAILED state - posted by gy...@apache.org on 2025/03/28 07:46:19 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [hotfix] Add shared release utils - posted by fc...@apache.org on 2025/03/28 09:17:08 UTC, 0 replies.
- (flink-connector-kudu) branch v2.0 created (now a79daca) - posted by fc...@apache.org on 2025/03/28 09:26:32 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37470] Improve JobManager Deployment / Pod error handling - posted by gy...@apache.org on 2025/03/28 10:01:52 UTC, 0 replies.
- (flink-connector-kudu) annotated tag v2.0.0-rc1 updated (ce1c85b -> ab6fda6) - posted by fc...@apache.org on 2025/03/28 12:07:09 UTC, 0 replies.
- svn commit: r75858 - in /dev/flink/flink-connector-kudu-2.0.0-rc1: ./ flink-connector-kudu-2.0.0-src.tgz flink-connector-kudu-2.0.0-src.tgz.asc flink-connector-kudu-2.0.0-src.tgz.sha512 - posted by fc...@apache.org on 2025/03/28 12:10:59 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37530] Record upgrade savepoint correctly in savepointInfo as well - posted by gy...@apache.org on 2025/03/28 15:17:04 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37408] Update all `docker-compose` references to `docker compose` - posted by fc...@apache.org on 2025/03/28 21:26:50 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Replacing manual comparison logic with `Long#compare` - posted by fc...@apache.org on 2025/03/28 21:31:18 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph. - posted by ju...@apache.org on 2025/03/31 01:50:27 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph. - posted by ju...@apache.org on 2025/03/31 01:51:05 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][ci] Prevent Nightly actions from being triggered by forks (#3969) - posted by ji...@apache.org on 2025/03/31 04:09:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37584][tests] Bump AssertJ version to 3.27.3 - posted by fc...@apache.org on 2025/03/31 12:11:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram - posted by dw...@apache.org on 2025/03/31 15:42:34 UTC, 0 replies.