commits@flink.apache.org, 2025-02

You are viewing a plain text version of this content. The canonical link for it is here.

- (flink) branch master updated: [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile - posted by sn...@apache.org on 2025/02/02 19:59:02 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0-rc2 updated (fcf07df5 -> d27ea30e) - posted by sn...@apache.org on 2025/02/02 22:56:12 UTC, 0 replies.
- svn commit: r74649 - in /dev/flink/flink-connector-hive-3.0.0-rc2: ./ flink-connector-hive-3.0.0-src.tgz flink-connector-hive-3.0.0-src.tgz.asc flink-connector-hive-3.0.0-src.tgz.sha512 - posted by sn...@apache.org on 2025/02/02 22:56:59 UTC, 0 replies.
- svn commit: r74651 - in /dev/flink: flink-connector-hive-3.0.0-rc1/ flink-connector-hive-3.0.0-rc2/ - posted by sn...@apache.org on 2025/02/02 23:10:35 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0-rc2 deleted (was d27ea30e) - posted by sn...@apache.org on 2025/02/02 23:14:17 UTC, 0 replies.
- svn commit: r74652 - in /dev/flink/flink-connector-hive-3.0.0-rc2: ./ flink-connector-hive-3.0.0-src.tgz flink-connector-hive-3.0.0-src.tgz.asc flink-connector-hive-3.0.0-src.tgz.sha512 - posted by sn...@apache.org on 2025/02/02 23:15:41 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0-rc2 updated (6342c11a -> 8b9b83f4) - posted by sn...@apache.org on 2025/02/02 23:20:59 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0-rc1 deleted (was a404c9f0) - posted by sn...@apache.org on 2025/02/02 23:21:25 UTC, 0 replies.
- (flink) branch master updated (51f9417e029 -> 64bff89f242) - posted by dw...@apache.org on 2025/02/03 10:32:54 UTC, 0 replies.
- (flink) 01/03: [FLINK-37175][table] Support JSON built-in function - posted by dw...@apache.org on 2025/02/03 10:32:55 UTC, 0 replies.
- (flink) 02/03: [FLINK-37175][table] use runtimeProvided instead of runtimeClass - posted by dw...@apache.org on 2025/02/03 10:32:56 UTC, 0 replies.
- (flink) 03/03: [FLINK-37175][docs] Complement documentation for json function - posted by dw...@apache.org on 2025/02/03 10:32:57 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37239][docs] Add examples for unhex, btrim, translate, elt and percentile - posted by sn...@apache.org on 2025/02/03 14:43:11 UTC, 0 replies.
- (flink) branch master updated (64bff89f242 -> b1eb1406504) - posted by sn...@apache.org on 2025/02/03 18:28:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37213][table-runtime] Improve performance of unbounded OVER aggregations - posted by pn...@apache.org on 2025/02/04 13:53:37 UTC, 0 replies.
- (flink) branch master updated (77edff62032 -> cb6c06d7f98) - posted by ma...@apache.org on 2025/02/04 16:21:23 UTC, 0 replies.
- (flink) 01/02: [FLINK-37232][runtime] Fix for broken synchronization assumption on the AdaptiveScheduler's side introduced by FLIP-272 - posted by ma...@apache.org on 2025/02/04 16:21:24 UTC, 1 replies.
- (flink) 02/02: [hotfix] Disable cooldown period to speed up test in UpdateJobResourceRequirementsITCase - posted by ma...@apache.org on 2025/02/04 16:21:25 UTC, 1 replies.
- (flink-connector-mongodb) branch main updated (0e31aa8 -> bdcc9ba) - posted by ji...@apache.org on 2025/02/05 01:29:58 UTC, 0 replies.
- (flink-connector-mongodb) 01/02: [FLINK-35139][Connectors/MongoDB] Drop support for Flink 1.18 - posted by ji...@apache.org on 2025/02/05 01:29:59 UTC, 0 replies.
- (flink-connector-mongodb) 02/02: [FLINK-35139][Connectors/MongoDB] Updating development version to 2.0-SNAPSHOT - posted by ji...@apache.org on 2025/02/05 01:30:00 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37206][Runtime] Fix initialization of batching timer service in async state operators (#26092) - posted by za...@apache.org on 2025/02/05 02:17:33 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated (bdcc9ba -> d3ed24a) - posted by ji...@apache.org on 2025/02/05 02:22:11 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [hotfix] Set copyright year to 2025 (#50) - posted by ji...@apache.org on 2025/02/05 03:04:22 UTC, 0 replies.
- (flink-connector-mongodb) branch v2.0 created (now ee145a5) - posted by ji...@apache.org on 2025/02/05 04:56:28 UTC, 0 replies.
- svn commit: r74711 - in /dev/flink/flink-connector-mongodb-2.0.0-rc1: ./ flink-connector-mongodb-2.0.0-src.tgz flink-connector-mongodb-2.0.0-src.tgz.asc flink-connector-mongodb-2.0.0-src.tgz.sha512 - posted by ji...@apache.org on 2025/02/05 05:04:33 UTC, 0 replies.
- (flink-connector-mongodb) annotated tag v2.0.0-rc1 updated (b2d4ade -> 64f4cab) - posted by ji...@apache.org on 2025/02/05 05:34:49 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37233][docs] Update supported flink versions and sinks (#3899) - posted by ru...@apache.org on 2025/02/05 05:58:25 UTC, 0 replies.
- (flink-cdc) branch release-3.3 updated: [FLINK-37233][docs] Update supported flink versions and sinks (#3899) (#3905) - posted by ru...@apache.org on 2025/02/05 06:13:37 UTC, 0 replies.
- (flink) branch release-2.0 updated (3b2f94ecf2b -> 4fbed74d111) - posted by ma...@apache.org on 2025/02/05 07:06:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37021][state/forst] Fix incorrect paths when reusing and creating files. (#26040) - posted by za...@apache.org on 2025/02/05 08:45:20 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36929][table] Add SQL connector for keyed savepoint data - posted by ga...@apache.org on 2025/02/05 09:14:39 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-37255] Fix unable to configure scan.partition.record-size option (#51) - posted by ji...@apache.org on 2025/02/05 09:46:19 UTC, 0 replies.
- (flink-connector-mongodb) branch v2.0 updated: [FLINK-37255] Fix unable to configure scan.partition.record-size option - posted by ji...@apache.org on 2025/02/05 11:10:17 UTC, 0 replies.
- svn commit: r74718 - in /dev/flink/flink-connector-mongodb-2.0.0-rc2: ./ flink-connector-mongodb-2.0.0-src.tgz flink-connector-mongodb-2.0.0-src.tgz.asc flink-connector-mongodb-2.0.0-src.tgz.sha512 - posted by ji...@apache.org on 2025/02/05 11:32:08 UTC, 0 replies.
- (flink-connector-mongodb) annotated tag v2.0.0-rc2 updated (0192c95 -> 1d5456d) - posted by ji...@apache.org on 2025/02/05 11:36:43 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37021][state/forst] Fix incorrect paths when reusing and creating files. (#26106) - posted by za...@apache.org on 2025/02/05 11:38:12 UTC, 0 replies.
- (flink) branch master updated (a4eb67642a8 -> ac4f5952d5d) - posted by za...@apache.org on 2025/02/05 11:39:56 UTC, 0 replies.
- (flink) 01/02: [FLINK-37222][Test] Introduce simple test submitting nexmark sql via sql client - posted by za...@apache.org on 2025/02/05 11:39:57 UTC, 1 replies.
- (flink) 02/02: [FLINK-37222] Do not reuse views across TableEnvironments in SQL client - posted by za...@apache.org on 2025/02/05 11:39:58 UTC, 1 replies.
- (flink) branch release-2.0 updated (5512299630e -> 12493ead11f) - posted by za...@apache.org on 2025/02/05 11:41:30 UTC, 0 replies.
- (flink) branch master updated (ac4f5952d5d -> c3c7f0c3a85) - posted by li...@apache.org on 2025/02/05 13:47:46 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated (379c6906 -> 3dfa820c) - posted by gy...@apache.org on 2025/02/05 13:57:59 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37242] Add labels for flink-operator-webhook-service - posted by gy...@apache.org on 2025/02/05 16:06:09 UTC, 0 replies.
- (flink) branch master updated (c3c7f0c3a85 -> aef8c868545) - posted by di...@apache.org on 2025/02/06 01:33:28 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37192][python] Replace deprecated avro-python3 with avro - posted by di...@apache.org on 2025/02/06 01:38:27 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34729][docs] Translate "Core Concept" Pages of Flink CDC into Chinese - posted by le...@apache.org on 2025/02/06 02:33:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37252][doc] Align Postgres CDC Connector Chinese docs with English version - posted by le...@apache.org on 2025/02/06 02:38:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37224][docs] Add the missing documents and parameters of MongoDB CDC - posted by le...@apache.org on 2025/02/06 02:46:19 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37218][network] Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. - posted by ju...@apache.org on 2025/02/06 03:23:27 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37251][doc] Add pipeline connectors' download link in overview.md - posted by le...@apache.org on 2025/02/06 03:30:59 UTC, 0 replies.
- (flink) branch revert-26020-doc-patch1 deleted (was b209635ff64) - posted by ju...@apache.org on 2025/02/06 03:41:48 UTC, 0 replies.
- (flink) branch release-2.0 updated: [hotfix][table-planner] Use equals instead of '==' to compare digests in FlinkCalcMergeRule - posted by li...@apache.org on 2025/02/06 05:32:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37231][docs] Add documentation for CDC Source metrics - posted by le...@apache.org on 2025/02/06 06:07:41 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [FLINK-37234][test] Add test timeout to avoid infinite waiting - posted by le...@apache.org on 2025/02/06 06:31:00 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37205][python] Correct the state cache behavior during bump beam version (#26058) - posted by di...@apache.org on 2025/02/06 07:21:35 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37205][python] Correct the state cache behavior during bump be… (#26059) - posted by di...@apache.org on 2025/02/06 07:23:08 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37205][python] Correct the state cache behavior during bump be… (#26060) - posted by di...@apache.org on 2025/02/06 07:23:39 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37205][python] Correct the state cache behavior during bump beam version (#26058) - posted by di...@apache.org on 2025/02/06 07:25:10 UTC, 0 replies.
- (flink-docker) branch dev-2.1 created (now 86629ab) - posted by gu...@apache.org on 2025/02/06 08:56:17 UTC, 0 replies.
- (flink-docker) 01/02: [FLINK-37035][release] Update dev-master point to 2.1 - posted by gu...@apache.org on 2025/02/06 08:56:18 UTC, 0 replies.
- (flink-docker) 02/02: testing - posted by gu...@apache.org on 2025/02/06 08:56:19 UTC, 0 replies.
- (flink-docker) branch dev-2.1 updated (86629ab -> 877ebde) - posted by gu...@apache.org on 2025/02/06 08:57:58 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35687] JSON_QUERY should return a well formatted nested objects/arrays for ARRAY (#24976) - posted by dw...@apache.org on 2025/02/06 09:34:52 UTC, 0 replies.
- (flink) branch master updated (a498cf2c228 -> 414516ad2d3) - posted by ma...@apache.org on 2025/02/06 10:35:59 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34227][runtime] Fixes IO thread leaking into owner of the scheduler instance (i.e. the JobMaster) - posted by ma...@apache.org on 2025/02/06 10:40:50 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37180][table] Support running stateless PTFs - posted by tw...@apache.org on 2025/02/06 16:35:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37264][datastream] Fix bugs in JoinExtension for ds v2 - posted by gu...@apache.org on 2025/02/07 01:59:06 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37264][datastream] Fix bugs in JoinExtension for ds v2 - posted by gu...@apache.org on 2025/02/07 02:02:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37154] Introduce ByteArraySchema (#26080) - posted by di...@apache.org on 2025/02/07 02:06:21 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37154] Introduce ByteArraySchema (#26080) - posted by di...@apache.org on 2025/02/07 02:09:08 UTC, 0 replies.
- (flink-connector-jdbc) branch main updated: [minor][improvement][connector/jdbc] Optimize the Postgresql upsert query to avoid unnecessary execution effort - posted by le...@apache.org on 2025/02/07 03:46:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Sink supports index sharding - posted by le...@apache.org on 2025/02/07 03:56:53 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [FLINK-37212] Skip relocating some region related exceptions - posted by fc...@apache.org on 2025/02/07 05:41:45 UTC, 0 replies.
- (flink-docker) branch dev-master updated (877ebde -> bc2f24e) - posted by gu...@apache.org on 2025/02/07 09:20:22 UTC, 0 replies.
- (flink-docker) 01/02: [FLINK-37035][release] Migrate testing job from SourceFunction to FLIP-27 based Source - posted by gu...@apache.org on 2025/02/07 09:20:23 UTC, 0 replies.
- (flink-docker) 02/02: [FLINK-37035][release] Update dev-master point to 2.1. - posted by gu...@apache.org on 2025/02/07 09:20:24 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37253] Add state size in application status and deployment metrics (#941) - posted by mx...@apache.org on 2025/02/07 09:49:09 UTC, 0 replies.
- Re: [I] com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1631767918000, eventType=UPDATE_ROWS, serverId=2121124478, headerLength=19, dataLength=7701, nextPosition=217369687, flags=0} [flink-cdc] - posted by "tcluzhe (via GitHub)" <gi...@apache.org> on 2025/02/07 10:31:18 UTC, 0 replies.
- (flink) branch release-2.0 updated (78ea6747f81 -> 6335f75486b) - posted by ma...@apache.org on 2025/02/07 10:37:20 UTC, 0 replies.
- (flink) 01/02: [FLINK-34227][runtime] Fixes concurrency issue in JobMaster shutdown (#24489) - posted by ma...@apache.org on 2025/02/07 10:37:21 UTC, 2 replies.
- (flink) 02/02: [FLINK-34227][runtime] Fixes IO thread leaking into owner of the scheduler instance (i.e. the JobMaster) - posted by ma...@apache.org on 2025/02/07 10:37:22 UTC, 2 replies.
- (flink) branch release-1.20 updated (1b5fc06d9d4 -> 9689af6a88a) - posted by ma...@apache.org on 2025/02/07 10:37:31 UTC, 0 replies.
- (flink) branch release-1.19 updated (af041a2a883 -> 216d3923380) - posted by ma...@apache.org on 2025/02/07 10:37:37 UTC, 0 replies.
- Re: [I] [Bug] update flink version to 1.16.2and CDC version to 2.3.0:NoSuchMethodError [flink-cdc] - posted by "w1023563646 (via GitHub)" <gi...@apache.org> on 2025/02/08 06:46:04 UTC, 1 replies.
- (flink) branch master updated (5a1ef84ffe5 -> f3fe66df08f) - posted by za...@apache.org on 2025/02/08 11:12:59 UTC, 0 replies.
- (flink) branch release-2.0 updated: [hotfix] Remove inappropriate annotation in `flink-statebackend-forst` (#26124) - posted by za...@apache.org on 2025/02/08 11:13:05 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37087][doc] Add docs for alter materialized table as query (#26064) - posted by ro...@apache.org on 2025/02/10 01:51:48 UTC, 0 replies.
- (flink) branch master updated (35df68585b9 -> f2ef99a6664) - posted by za...@apache.org on 2025/02/10 03:07:02 UTC, 0 replies.
- (flink) branch release-2.0 updated (3f8aadc1e01 -> bfdc6db0955) - posted by za...@apache.org on 2025/02/10 03:07:20 UTC, 0 replies.
- (flink) 01/02: [hotfix] Add constructors for state v2 descriptors that accept type class - posted by za...@apache.org on 2025/02/10 03:07:21 UTC, 0 replies.
- (flink) 02/02: [FLINK-37276] Add missing state v2 access interfaces in `RuntimeContext` - posted by za...@apache.org on 2025/02/10 03:07:22 UTC, 0 replies.
- svn commit: r74808 - /dev/flink/flink-connector-hive-3.0.0-rc2/ /release/flink/flink-connector-hive-3.0.0/ - posted by le...@apache.org on 2025/02/10 03:34:41 UTC, 0 replies.
- (flink) branch master updated (f2ef99a6664 -> 9535f753d7f) - posted by go...@apache.org on 2025/02/10 03:36:24 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0 updated (6342c11a -> a71ba017) - posted by sn...@apache.org on 2025/02/10 07:50:19 UTC, 0 replies.
- (flink-connector-hive) branch v3.0 created (now c8aa0ccd) - posted by sn...@apache.org on 2025/02/10 07:58:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37258][Runtime] Return Ordered Job list on Disptacher#requestMultipleJobDetails - posted by ma...@apache.org on 2025/02/10 09:52:12 UTC, 0 replies.
- (flink) branch master updated (94007ff679e -> f2568dee631) - posted by za...@apache.org on 2025/02/10 10:42:31 UTC, 0 replies.
- (flink) 01/02: [hotfix] Improve TtlAwareSerializer/TtlAwareSerializerSnapshot/TtlAwareSerializerSnapshotWrapper - posted by za...@apache.org on 2025/02/10 10:42:32 UTC, 0 replies.
- (flink) 02/02: [FLINK-35780][state] Support state migration between disabling and enabling state ttl in RocksDBKeyedStateBackend (#25035) - posted by za...@apache.org on 2025/02/10 10:42:33 UTC, 0 replies.
- (flink) branch release-2.0 updated (bfdc6db0955 -> 5dd6497f74c) - posted by ro...@apache.org on 2025/02/10 12:04:26 UTC, 0 replies.
- (flink) branch master updated (f2568dee631 -> be5fcaf180d) - posted by ju...@apache.org on 2025/02/10 12:40:34 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37287][docs] Add missed Apache Paimon 0.9 and Fixing typo on overview.md - posted by le...@apache.org on 2025/02/10 14:31:53 UTC, 0 replies.
- (flink) branch master updated (be5fcaf180d -> 14b5d53472e) - posted by sh...@apache.org on 2025/02/11 01:25:05 UTC, 0 replies.
- (flink) branch master updated (14b5d53472e -> 064bfe4c4d7) - posted by ro...@apache.org on 2025/02/11 02:00:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37268][example] Use async state in flink-examples-streaming (#26117) - posted by le...@apache.org on 2025/02/11 02:08:33 UTC, 0 replies.
- (flink) branch release-2.0 updated (5dd6497f74c -> f13c1d842e0) - posted by ju...@apache.org on 2025/02/11 02:10:14 UTC, 0 replies.
- (flink) 01/02: [hotfix] Do not reuse StreamGraph in AdaptiveGraphManagerTest when comparing the results of the adaptive graph generator and the static graph generator. - posted by ju...@apache.org on 2025/02/11 02:10:15 UTC, 0 replies.
- (flink) 02/02: [FLINK-37284][runtime] Fix ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. - posted by ju...@apache.org on 2025/02/11 02:10:16 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37268][example] Use async state in flink-examples-streaming (#26136) - posted by le...@apache.org on 2025/02/11 02:18:12 UTC, 0 replies.
- Re: [I] Towards Flink CDC 3.0 [flink-cdc] - posted by "umerwhu (via GitHub)" <gi...@apache.org> on 2025/02/11 02:41:54 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][license] Update legacy license - posted by le...@apache.org on 2025/02/11 03:09:47 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37272][python] Minor fix of FlinkAvroBufferWrapper - posted by di...@apache.org on 2025/02/11 04:02:53 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37272][python] Minor fix of FlinkAvroBufferWrapper - posted by di...@apache.org on 2025/02/11 04:03:22 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-36976] Upgrade jackson from 2.15.3 to 2.18.2 - posted by sn...@apache.org on 2025/02/11 05:46:33 UTC, 0 replies.
- (flink) branch master updated (21e30869d65 -> dc4518fec6e) - posted by za...@apache.org on 2025/02/11 06:55:33 UTC, 0 replies.
- (flink) 01/05: [FLINK-36439][docs] Documents for State V2 APIs - posted by za...@apache.org on 2025/02/11 06:55:34 UTC, 1 replies.
- (flink) 02/05: [FLINK-36439][docs] Documents for ForSt State Backend - posted by za...@apache.org on 2025/02/11 06:55:35 UTC, 1 replies.
- (flink) 03/05: [hotfix] Make ForSt state backend use checkpoint directory as its primary storage by default - posted by za...@apache.org on 2025/02/11 06:55:36 UTC, 1 replies.
- (flink) 04/05: [hotfix] Rename the buffer config options for async state processing - posted by za...@apache.org on 2025/02/11 06:55:37 UTC, 1 replies.
- (flink) 05/05: [FLINK-36439][docs] Documents for Disaggregated State - posted by za...@apache.org on 2025/02/11 06:55:38 UTC, 1 replies.
- (flink) branch release-2.0 updated (979fe75ce88 -> 54227039dea) - posted by za...@apache.org on 2025/02/11 06:55:50 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37187][doc] Add doc for submitting Materialized Table refresh job to Yarn/K8s (#26137) - posted by ro...@apache.org on 2025/02/11 06:58:33 UTC, 0 replies.
- (flink-connector-kafka) branch main updated (f6a077a9 -> 707ec4c1) - posted by ar...@apache.org on 2025/02/11 07:55:47 UTC, 0 replies.
- (flink) branch master updated (dc4518fec6e -> 9ea61824372) - posted by ju...@apache.org on 2025/02/11 11:18:24 UTC, 0 replies.
- (flink-cdc) branch master updated: [tests][ci] Miscellaneous improvements on CI robustness - posted by le...@apache.org on 2025/02/11 12:16:43 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37262][pipeline-connector/mysql] Fix missing PARSE_ONLINE_SCHEMA_CHANGES option in MySqlDataSourceFactory - posted by le...@apache.org on 2025/02/11 12:19:14 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37191][cdc-connector/mysql] Avoid back filling when lowWatermark is equal to highWatermark in BinlogSplit - posted by le...@apache.org on 2025/02/11 12:24:16 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs - posted by le...@apache.org on 2025/02/11 12:26:26 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36945][cdc-connector/mysql] Support parsing rename multiple tables in one statement - posted by le...@apache.org on 2025/02/11 12:35:32 UTC, 0 replies.
- (flink) branch release-2.0 updated (596648c3577 -> 88d32a07c6f) - posted by ju...@apache.org on 2025/02/11 14:29:49 UTC, 0 replies.
- (flink) 01/02: [hotfix][doc] Replace flink-conf.yaml with config.yaml in the docs. - posted by ju...@apache.org on 2025/02/11 14:29:50 UTC, 0 replies.
- (flink) 02/02: [FLINK-37150][doc] Update flink configuration file documentation. - posted by ju...@apache.org on 2025/02/11 14:29:51 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37219][table] Support value state in PTFs - posted by tw...@apache.org on 2025/02/11 15:06:34 UTC, 0 replies.
- svn commit: r74850 - /dev/flink/flink-1.19.2-rc1/ /release/flink/flink-1.19.2/ - posted by gy...@apache.org on 2025/02/11 15:25:50 UTC, 0 replies.
- svn commit: r74852 - /dev/flink/flink-1.20.1-rc1/ /release/flink/flink-1.20.1/ - posted by gy...@apache.org on 2025/02/11 15:27:22 UTC, 0 replies.
- (flink) annotated tag release-1.19.2 updated (7d9f0e043b4 -> a7921fe0b17) - posted by af...@apache.org on 2025/02/11 16:04:01 UTC, 0 replies.
- (flink-web) branch asf-site updated (83e0ab92b -> eddcb0e44) - posted by sn...@apache.org on 2025/02/11 22:05:59 UTC, 0 replies.
- (flink-web) 01/02: Add Hive 3.0.0 connector - posted by sn...@apache.org on 2025/02/11 22:06:00 UTC, 0 replies.
- (flink-web) 02/02: Rebuild website - posted by sn...@apache.org on 2025/02/11 22:06:01 UTC, 0 replies.
- (flink-connector-hive) annotated tag v3.0.0-rc2 deleted (was 8b9b83f4) - posted by sn...@apache.org on 2025/02/11 23:01:50 UTC, 0 replies.
- (flink) branch master updated (24f18975c72 -> 4aacf33e870) - posted by fa...@apache.org on 2025/02/12 01:55:07 UTC, 0 replies.
- (flink) branch master updated (4aacf33e870 -> e299645bf5c) - posted by za...@apache.org on 2025/02/12 02:26:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` (#26143) - posted by za...@apache.org on 2025/02/12 02:27:36 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.2 created (now a1d4812) - posted by gu...@apache.org on 2025/02/12 02:38:36 UTC, 0 replies.
- (flink-connector-elasticsearch) 01/02: Update version to 3.2-SNAPSHOT - posted by gu...@apache.org on 2025/02/12 02:38:37 UTC, 0 replies.
- (flink-connector-elasticsearch) 02/02: [FLINK-35134][Connectors/Elasticsearch] Update website data for 3.2.0 - posted by gu...@apache.org on 2025/02/12 02:38:38 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.2 updated: [FLINK-35134][Connectors/Elasticsearch] Change flink.version to 1.19.1 - posted by gu...@apache.org on 2025/02/12 02:43:20 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [hotfix] upgrade v3.0 branch testing flink version to 1.19.1 - posted by gu...@apache.org on 2025/02/12 05:46:29 UTC, 0 replies.
- (flink-connector-elasticsearch) branch test created (now 4348dba) - posted by gu...@apache.org on 2025/02/12 06:09:51 UTC, 0 replies.
- (flink-connector-elasticsearch) 01/01: [test] Run test for 1.19.1 to v3.1 - posted by gu...@apache.org on 2025/02/12 06:09:52 UTC, 0 replies.
- (flink-connector-elasticsearch) branch test deleted (was 4348dba) - posted by gu...@apache.org on 2025/02/12 06:31:53 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.0 updated: [hotfix] Make tests passing for jdk 17+ - posted by gu...@apache.org on 2025/02/12 07:04:27 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.2 updated (a556c6d -> ea34b2a) - posted by gu...@apache.org on 2025/02/12 07:16:07 UTC, 0 replies.
- (flink-connector-elasticsearch) 01/03: Update version to 3.2.0 - posted by gu...@apache.org on 2025/02/12 07:16:08 UTC, 0 replies.
- (flink-connector-elasticsearch) 02/03: [FLINK-35134][Connectors/Elasticsearch] Change flink.version to 1.19.1 - posted by gu...@apache.org on 2025/02/12 07:16:09 UTC, 0 replies.
- (flink-connector-elasticsearch) 03/03: [FLINK-35134][Connectors/Elasticsearch] Update website data for 3.2.0 - posted by gu...@apache.org on 2025/02/12 07:16:10 UTC, 0 replies.
- svn commit: r74861 - in /dev/flink/flink-connector-elasticsearch--rc1: ./ flink-connector-elasticsearch--src.tgz flink-connector-elasticsearch--src.tgz.asc flink-connector-elasticsearch--src.tgz.sha512 - posted by gu...@apache.org on 2025/02/12 07:20:00 UTC, 0 replies.
- svn commit: r74862 - /dev/flink/flink-connector-elasticsearch--rc1/ - posted by gu...@apache.org on 2025/02/12 07:31:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36900][Test Infrastructure] Migrate from conda to uv for managing Python environments for PyFlink (#26065) - posted by ma...@apache.org on 2025/02/12 07:47:04 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode. (#26147) - posted by za...@apache.org on 2025/02/12 09:10:32 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` (#26146) - posted by za...@apache.org on 2025/02/12 09:10:41 UTC, 0 replies.
- (flink) branch master updated: [hotfix][state/forst] Make file cache options recognize size type (#26148) - posted by za...@apache.org on 2025/02/12 09:17:05 UTC, 0 replies.
- svn commit: r74865 - in /dev/flink/flink-connector-elasticsearch-3.2.0-rc1: ./ flink-connector-elasticsearch-3.2.0-src.tgz flink-connector-elasticsearch-3.2.0-src.tgz.asc flink-connector-elasticsearch-3.2.0-src.tgz.sha512 - posted by gu...@apache.org on 2025/02/12 09:49:27 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-37303] Bump guava from 32.1.3 to 33.4.0 - posted by sn...@apache.org on 2025/02/12 09:55:04 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37312][doc] Add missing closing tab in state_v2.md - posted by ga...@apache.org on 2025/02/12 15:53:18 UTC, 0 replies.
- (flink) annotated tag release-1.20.1 updated (cb1e7b5571b -> e976b142d88) - posted by af...@apache.org on 2025/02/12 18:30:18 UTC, 0 replies.
- (flink) branch master updated (25444ac3a5f -> 05a3e9c578e) - posted by ju...@apache.org on 2025/02/13 05:52:38 UTC, 0 replies.
- (flink) 01/02: [hotfix][runtime] Fix the intra-input correlation of ForwardForUnspecifiedPartitioner - posted by ju...@apache.org on 2025/02/13 05:52:39 UTC, 1 replies.
- (flink) 02/02: [FLINK-37309][table-planner] Fix skewed join optimization not working as expected - posted by ju...@apache.org on 2025/02/13 05:52:40 UTC, 1 replies.
- (flink) branch release-2.0 updated: [hotfix][state/forst] Make file cache options recognize size type (#26151) - posted by za...@apache.org on 2025/02/13 06:21:08 UTC, 0 replies.
- (flink) branch release-2.0 updated (0898eb58255 -> 3cc86bdbf48) - posted by ju...@apache.org on 2025/02/13 08:33:15 UTC, 0 replies.
- (flink-docker) branch dev-1.20 updated: Add GPG key for 1.20.1 release - posted by af...@apache.org on 2025/02/13 11:04:12 UTC, 0 replies.
- (flink) branch master updated (05a3e9c578e -> cd0cfe42c15) - posted by dm...@apache.org on 2025/02/13 11:29:00 UTC, 0 replies.
- (flink) branch release-1.20 updated (9689af6a88a -> 6dcda117d04) - posted by dm...@apache.org on 2025/02/13 13:06:40 UTC, 0 replies.
- (flink-docker) branch dev-1.20 updated: Add GPG key for 1.20.1 release (#214) - posted by mb...@apache.org on 2025/02/13 13:13:03 UTC, 0 replies.
- (flink-docker) branch master updated: Update Dockerfiles for 1.20.1 release - posted by mb...@apache.org on 2025/02/13 13:14:54 UTC, 0 replies.
- (flink-playgrounds) branch master updated: update docker setup - posted by da...@apache.org on 2025/02/13 16:08:47 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase. - posted by dm...@apache.org on 2025/02/13 17:35:11 UTC, 0 replies.
- (flink-docker) branch dev-1.19 updated: Align entrypoint with what was used for 1.19.1 - posted by mb...@apache.org on 2025/02/14 08:42:19 UTC, 0 replies.
- (flink) branch master updated (cd0cfe42c15 -> 9bcc41dc233) - posted by ga...@apache.org on 2025/02/14 08:50:05 UTC, 0 replies.
- (flink-docker) branch master updated: Align entrypoint with what was used for 1.19.1 - posted by af...@apache.org on 2025/02/14 10:26:33 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-hive/io.netty-netty-common-4.1.118.Final created (now b0b225b10a6) - posted by gi...@apache.org on 2025/02/14 15:07:26 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-hive/io.netty-netty-common-4.1.115.Final deleted (was 5d2a8f40649) - posted by gi...@apache.org on 2025/02/14 15:07:33 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37109][state] Improve state processor API key iteration speed - posted by ga...@apache.org on 2025/02/14 15:33:42 UTC, 0 replies.
- (flink) branch master updated (9bcc41dc233 -> 4efbc913878) - posted by ga...@apache.org on 2025/02/14 15:35:53 UTC, 0 replies.
- (flink) branch master updated (4efbc913878 -> 20d5eb0a8cc) - posted by gu...@apache.org on 2025/02/17 03:46:58 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37194][tests] Fix NPE issue in WatermarkITCase - posted by gu...@apache.org on 2025/02/17 03:50:18 UTC, 0 replies.
- (flink) branch master updated (20d5eb0a8cc -> a95046f2c33) - posted by gu...@apache.org on 2025/02/17 04:05:25 UTC, 0 replies.
- (flink) 01/02: [FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readFile()/readTextFile(*) methods in documentations - posted by gu...@apache.org on 2025/02/17 04:05:26 UTC, 0 replies.
- (flink) 02/02: [FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readFile()/readTextFile(*) methods in chinese documentations - posted by gu...@apache.org on 2025/02/17 04:05:27 UTC, 0 replies.
- svn commit: r74932 - /dev/flink/flink-connector-elasticsearch-3.2.0-rc1/ - posted by gu...@apache.org on 2025/02/17 06:16:22 UTC, 0 replies.
- (flink) branch master updated (a95046f2c33 -> 0b99f169ff2) - posted by sn...@apache.org on 2025/02/17 19:57:44 UTC, 0 replies.
- (flink) branch master updated (0b99f169ff2 -> 931178ea4fa) - posted by sn...@apache.org on 2025/02/17 20:09:53 UTC, 0 replies.
- (flink) branch master updated (931178ea4fa -> 3e3d556e0bb) - posted by gu...@apache.org on 2025/02/18 01:32:20 UTC, 0 replies.
- (flink) 01/03: [hotfix][datastream] Add throwing signature to ProcessFunction methods - posted by gu...@apache.org on 2025/02/18 01:32:21 UTC, 1 replies.
- (flink) 02/03: [FLINK-37316][datastream] Add getStateOptional and getState methods in StateManager for DataStream V2 - posted by gu...@apache.org on 2025/02/18 01:32:22 UTC, 1 replies.
- (flink) 03/03: [FLINK-37274][datastream] Add examples for DataStream V2 - posted by gu...@apache.org on 2025/02/18 01:32:23 UTC, 1 replies.
- (flink-cdc) branch master updated: [FLINK-37306][tests] Fix MySQLSourceITCase failure in non-UTC timezone - posted by le...@apache.org on 2025/02/18 01:40:29 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.2 deleted (was ea34b2a) - posted by gu...@apache.org on 2025/02/18 06:18:59 UTC, 0 replies.
- (flink-connector-elasticsearch) branch ElasticsearchEmitter created (now e04b74b) - posted by le...@apache.org on 2025/02/18 06:46:26 UTC, 0 replies.
- (flink-connector-elasticsearch) branch ElasticsearchEmitter deleted (was e04b74b) - posted by le...@apache.org on 2025/02/18 06:47:01 UTC, 0 replies.
- (flink) branch master updated (3e3d556e0bb -> 6362ad1086d) - posted by li...@apache.org on 2025/02/18 07:07:00 UTC, 0 replies.
- (flink) branch FLINK-35810-debug created (now 0fd63018dd1) - posted by gu...@apache.org on 2025/02/18 08:31:57 UTC, 0 replies.
- (flink) 01/01: increase unittest Xmx - posted by gu...@apache.org on 2025/02/18 08:31:58 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss - posted by li...@apache.org on 2025/02/18 10:05:48 UTC, 0 replies.
- (flink-connector-hive) branch main updated: [FLINK-34961] Use dedicated CI name for Hive connector to differentiate it in infra-reports - posted by sn...@apache.org on 2025/02/18 10:14:35 UTC, 0 replies.
- (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.hive-hive-exec-4.0.1 created (now b347a987) - posted by gi...@apache.org on 2025/02/18 10:15:31 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-37342][table] Add `smile` format - posted by sn...@apache.org on 2025/02/18 12:05:48 UTC, 0 replies.
- (flink-shaded) branch master updated: [FLINK-33703] Use maven 3.8.6 for release profile - posted by sn...@apache.org on 2025/02/18 16:40:24 UTC, 0 replies.
- svn commit: r74971 - in /dev/flink/flink-shaded-20.0-rc1: ./ flink-shaded-20.0-src.tgz flink-shaded-20.0-src.tgz.asc flink-shaded-20.0-src.tgz.sha512 - posted by sn...@apache.org on 2025/02/18 17:21:27 UTC, 0 replies.
- (flink-shaded) annotated tag release-20.0-rc1 updated (8b3972e -> c720c14) - posted by sn...@apache.org on 2025/02/18 17:50:37 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-36998][table-planner] Keep same behavior about the RowKind of data in globalUpsertResult for KeyedUpsertingSinkFunction while being inserted or being restored - posted by li...@apache.org on 2025/02/19 01:35:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37201] [transform] Transform arithmetic function support nullable parameters and more numerical types - posted by le...@apache.org on 2025/02/19 01:58:41 UTC, 0 replies.
- (flink) branch master updated (9a1e9868bdd -> 18c6cafe7f4) - posted by sn...@apache.org on 2025/02/19 10:21:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37335][state/forst] Handle the first full checkpoint for ForStIncrementalSnapshotStrategy (#26165) - posted by za...@apache.org on 2025/02/19 12:12:18 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37335][state/forst] Handle the first full checkpoint for ForStIncrementalSnapshotStrategy (#26176) - posted by za...@apache.org on 2025/02/19 12:13:44 UTC, 0 replies.
- (flink-web) branch asf-site updated (eddcb0e44 -> 366fb5bfd) - posted by af...@apache.org on 2025/02/19 12:51:15 UTC, 0 replies.
- (flink-web) 01/02: Add Flink 1.19.2 release - posted by af...@apache.org on 2025/02/19 12:51:16 UTC, 0 replies.
- (flink-web) 02/02: Rebuild site - posted by af...@apache.org on 2025/02/19 12:51:17 UTC, 1 replies.
- (flink-web) branch asf-site updated (366fb5bfd -> 40b54ffd7) - posted by af...@apache.org on 2025/02/19 13:00:40 UTC, 0 replies.
- (flink-web) 01/02: Add Flink 1.20.1 release - posted by af...@apache.org on 2025/02/19 13:00:41 UTC, 0 replies.
- (flink-connector-kafka) branch main updated (707ec4c1 -> f4015d17) - posted by ar...@apache.org on 2025/02/19 14:07:45 UTC, 0 replies.
- (flink-connector-kafka) 01/07: [FLINK-37282] Introduce internal package to sink - posted by ar...@apache.org on 2025/02/19 14:07:46 UTC, 0 replies.
- (flink-connector-kafka) 02/07: [hotfix] Fix leaks in FlinkKafkaProducerTest - posted by ar...@apache.org on 2025/02/19 14:07:47 UTC, 0 replies.
- (flink-connector-kafka) 03/07: [FLINK-37282] Split KafkaWriter into EOS/non-EOS - posted by ar...@apache.org on 2025/02/19 14:07:48 UTC, 0 replies.
- (flink-connector-kafka) 04/07: [FLINK-37282] Add Backchannel - posted by ar...@apache.org on 2025/02/19 14:07:49 UTC, 0 replies.
- (flink-connector-kafka) 05/07: [FLINK-37282] Add ProducerPool - posted by ar...@apache.org on 2025/02/19 14:07:50 UTC, 0 replies.
- (flink-connector-kafka) 06/07: [FLINK-37282] Force colocation of kafka writer and kafka committer. - posted by ar...@apache.org on 2025/02/19 14:07:51 UTC, 0 replies.
- (flink-connector-kafka) 07/07: [FLINK-37282] Incorporate Backchannel and ProducerPool into EOSWriter - posted by ar...@apache.org on 2025/02/19 14:07:52 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. (#25569) - posted by jq...@apache.org on 2025/02/19 16:15:18 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. (#25569) - posted by jq...@apache.org on 2025/02/19 16:18:09 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-35810][test] increase unittest Xmx to debug FLINK-35810 - posted by gu...@apache.org on 2025/02/20 01:52:28 UTC, 0 replies.
- (flink) branch master updated (fdf9b292b0d -> 38c35bb65a7) - posted by zh...@apache.org on 2025/02/20 02:47:52 UTC, 0 replies.
- (flink) 01/02: [FLINK-37333][runtime] Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect. - posted by zh...@apache.org on 2025/02/20 02:47:53 UTC, 1 replies.
- (flink) 02/02: [hotfix][runtime] Add log for adaptive broadcast join strategy. - posted by zh...@apache.org on 2025/02/20 02:47:54 UTC, 1 replies.
- (flink) branch master updated: [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method - posted by ju...@apache.org on 2025/02/20 04:00:10 UTC, 0 replies.
- (flink) branch master updated: [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. - posted by ju...@apache.org on 2025/02/20 04:54:26 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-28047][docs] Remove deprecated StreamExecutionEnvironment#readTextFile method in documentation - posted by gu...@apache.org on 2025/02/20 08:10:28 UTC, 0 replies.
- (flink) branch master updated (aa2281387ce -> 1c759337fd9) - posted by ju...@apache.org on 2025/02/20 08:59:58 UTC, 0 replies.
- (flink) branch bp-adaptive-batch-docs created (now f5ea5d1375c) - posted by ju...@apache.org on 2025/02/20 09:02:42 UTC, 0 replies.
- (flink) 01/01: [FLINK-37149][doc] Add documents for adaptive batch execution. - posted by ju...@apache.org on 2025/02/20 09:02:43 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss - posted by li...@apache.org on 2025/02/20 11:24:49 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36549][formats] Fix using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss - posted by li...@apache.org on 2025/02/20 11:25:02 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37149][doc] Add documents for adaptive batch execution. - posted by ju...@apache.org on 2025/02/20 11:56:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-37152][build] Update Flink version to 1.20 - posted by le...@apache.org on 2025/02/20 13:10:21 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37359] Pin qemu image to 7.0.0 - posted by gy...@apache.org on 2025/02/20 13:25:24 UTC, 0 replies.
- (flink-connector-shared-utils) branch ci_utils updated: [FLINK-36900] Migrate from conda to uv for managing Python environments - posted by sn...@apache.org on 2025/02/20 14:10:09 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix] Fix post-release japicmp update script for macOS - posted by af...@apache.org on 2025/02/20 15:34:03 UTC, 0 replies.
- (flink) branch release-2.0 updated: [hotfix] Fix post-release japicmp update script for macOS - posted by af...@apache.org on 2025/02/20 15:35:14 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] Fix post-release japicmp update script for macOS - posted by af...@apache.org on 2025/02/20 15:35:51 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37360][release] Update japicmp configuration post 1.20.1 - posted by af...@apache.org on 2025/02/20 17:42:10 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-37361][release] Update japicmp configuration post 1.19.2 - posted by af...@apache.org on 2025/02/20 17:42:30 UTC, 0 replies.
- Re: [I] [Bug] Failed to deserialize data of EventHeaderV4 [flink-cdc] - posted by "xj90713 (via GitHub)" <gi...@apache.org> on 2025/02/21 02:07:50 UTC, 0 replies.
- (flink) branch release-2.0 updated (94c0ae9a4e0 -> b9734cf768a) - posted by ju...@apache.org on 2025/02/21 02:24:52 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35724][oss] Bump OSS SDK to 3.17.4 - posted by ju...@apache.org on 2025/02/21 02:28:52 UTC, 0 replies.
- (flink) branch master updated: [FLINK-35622][runtime] Filter out noisy 'Coordinator of operator xxxx does not exist' exceptions in CollectResultFetcher - posted by ju...@apache.org on 2025/02/21 02:53:00 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36409] Publish some autoscaler metrics during stabilisation period - posted by mo...@apache.org on 2025/02/21 04:13:41 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly being set to RECONCILING - posted by gy...@apache.org on 2025/02/21 06:08:10 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-33265] Support source parallelism setting for Kafka connector - posted by li...@apache.org on 2025/02/21 09:11:36 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-35724][oss] Bump OSS SDK to 3.17.4 - posted by ju...@apache.org on 2025/02/21 11:44:28 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37236] Bump the flink version from 1.20.0 to 1.20.1 - posted by gy...@apache.org on 2025/02/21 13:02:29 UTC, 0 replies.
- (flink-kubernetes-operator) branch release-1.11 created (now be8e8996) - posted by gy...@apache.org on 2025/02/21 15:04:13 UTC, 0 replies.
- (flink-kubernetes-operator) 01/01: [release] Update docs config for release branch - posted by gy...@apache.org on 2025/02/21 15:04:14 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37267][table] Add support for UNNEST WITH ORDINALITY - posted by tw...@apache.org on 2025/02/21 15:13:58 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated (d54c8df2 -> e636a000) - posted by gy...@apache.org on 2025/02/21 15:15:58 UTC, 0 replies.
- (flink-kubernetes-operator) 01/02: [release] Update version to 1.12-SNAPSHOT - posted by gy...@apache.org on 2025/02/21 15:15:59 UTC, 0 replies.
- (flink-kubernetes-operator) 02/02: [release] Docs, ci and config updates after release cut - posted by gy...@apache.org on 2025/02/21 15:16:00 UTC, 0 replies.
- (flink) branch release-1.19 updated: [hotfix][docs] Update docs to the latest 1.19 version - posted by af...@apache.org on 2025/02/21 16:37:08 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix][docs] Update docs to the latest 1.20 version - posted by af...@apache.org on 2025/02/21 16:37:21 UTC, 0 replies.
- (flink-cdc) branch master updated (0211a136c -> e7964b160) - posted by go...@apache.org on 2025/02/22 07:04:58 UTC, 0 replies.
- (flink-cdc) 01/03: [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot - posted by go...@apache.org on 2025/02/22 07:04:59 UTC, 0 replies.
- (flink-cdc) 02/03: [FLINK-36086] Add test for sqlserver restart during one transaction and add new version SourceSplitSerializer - posted by go...@apache.org on 2025/02/22 07:05:00 UTC, 0 replies.
- (flink-cdc) 03/03: [FLINK-36086] Add EVENT_SERIAL_NO_KEY for record event processed in state for fix repeat read event after restart during one transaction - posted by go...@apache.org on 2025/02/22 07:05:01 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder (#26139) - posted by ji...@apache.org on 2025/02/24 01:48:35 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder (#26138) - posted by ji...@apache.org on 2025/02/24 01:48:56 UTC, 0 replies.
- [I] flink-kubernetes-operator v1.11.0 Not Found [flink-cdc] - posted by "liuxuzxx (via GitHub)" <gi...@apache.org> on 2025/02/24 08:13:41 UTC, 5 replies.
- svn commit: r75103 - /dev/flink/flink-shaded-20.0-rc1/ /release/flink/flink-shaded-20.0/ - posted by dw...@apache.org on 2025/02/24 08:59:58 UTC, 0 replies.
- (flink-shaded) annotated tag release-20.0 updated (8b3972e -> 3fd3afa) - posted by sn...@apache.org on 2025/02/24 09:25:51 UTC, 0 replies.
- (flink-web) branch asf-site updated: Add flink-shaded 20.0 release - posted by sn...@apache.org on 2025/02/24 09:38:28 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild site - posted by sn...@apache.org on 2025/02/24 09:47:51 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37372] Fix infinite loop bug in savepoint error handling - posted by gy...@apache.org on 2025/02/24 13:22:28 UTC, 0 replies.
- (flink) branch master updated: Revert "[FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. (#25569)" - posted by sn...@apache.org on 2025/02/24 13:22:30 UTC, 0 replies.
- (flink-kubernetes-operator) branch release-1.11 updated: [FLINK-37372] Fix infinite loop bug in savepoint error handling - posted by gy...@apache.org on 2025/02/24 13:30:25 UTC, 0 replies.
- (flink) branch master updated (77b03d94ab3 -> 835c64b66a5) - posted by sn...@apache.org on 2025/02/24 16:43:09 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37363][state] Make state.backend.type config optional for state SQL connector - posted by ga...@apache.org on 2025/02/24 19:09:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36352][doc] Remove Scala DataStream API related doc - posted by gu...@apache.org on 2025/02/25 02:06:28 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-36352][doc] Remove Scala DataStream API related doc - posted by gu...@apache.org on 2025/02/25 02:07:54 UTC, 0 replies.
- (flink) branch master updated (0cb39f99523 -> 8bc7f7a50b6) - posted by ju...@apache.org on 2025/02/25 02:09:55 UTC, 0 replies.
- (flink) 01/04: [hotfix][runtime] Optimize the calculation logic of AllToAllBlockingResultInfo#getNumBytesProduced - posted by ju...@apache.org on 2025/02/25 02:09:56 UTC, 1 replies.
- (flink) 02/04: [hotfix][runtime] Optimize logs in DefaultVertexParallelismAndInputInfosDecider and AdaptiveSkewedJoinOptimizationStrategy - posted by ju...@apache.org on 2025/02/25 02:09:57 UTC, 1 replies.
- (flink) 03/04: [hotfix][table-planner] Fix skewed join optimization not working as expected in forced mode - posted by ju...@apache.org on 2025/02/25 02:09:58 UTC, 1 replies.
- (flink) 04/04: [FLINK-37350][table-planner] Fix memory leak in skewed join optimization strategy - posted by ju...@apache.org on 2025/02/25 02:09:59 UTC, 1 replies.
- (flink) branch release-2.0 updated (804ce5722e6 -> 44c84620a59) - posted by ju...@apache.org on 2025/02/25 03:37:24 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37339][doc] Update java_compatibility doc - posted by gu...@apache.org on 2025/02/25 06:09:45 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37339][doc] Update java_compatibility doc - posted by gu...@apache.org on 2025/02/25 06:12:24 UTC, 0 replies.
- (flink) branch master updated (dc73c6ab483 -> 3fb231e9bd6) - posted by gu...@apache.org on 2025/02/25 06:13:43 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-36336][docs] Remove deprecated DataSet API related contents in documentations - posted by gu...@apache.org on 2025/02/25 06:15:33 UTC, 0 replies.
- (flink) branch master updated (3fb231e9bd6 -> 25f0cf306c6) - posted by le...@apache.org on 2025/02/25 06:27:10 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-37370] [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR - posted by gy...@apache.org on 2025/02/25 07:27:55 UTC, 0 replies.
- (flink-kubernetes-operator) branch release-1.11 updated: [FLINK-37370] [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR - posted by gy...@apache.org on 2025/02/25 07:35:06 UTC, 0 replies.
- svn commit: r75131 - /dev/flink/flink-kubernetes-operator-1.11.0-rc1/ - posted by gy...@apache.org on 2025/02/25 07:47:34 UTC, 0 replies.
- (flink-kubernetes-operator) annotated tag release-1.11.0-rc1 updated (cc9c6cb8 -> 22d8865b) - posted by gy...@apache.org on 2025/02/25 07:48:21 UTC, 0 replies.
- (flink) branch master updated (25f0cf306c6 -> e8354665a28) - posted by sn...@apache.org on 2025/02/25 11:27:58 UTC, 0 replies.
- (flink-shaded) branch master updated: [hoftix] Update 21.0 version - posted by sn...@apache.org on 2025/02/25 16:42:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37382][runtime] Early optimization for adaptive join when either input is below broadcast threshold. - posted by ju...@apache.org on 2025/02/26 06:48:30 UTC, 0 replies.
- (flink) branch release-2.0 updated (ae5fc93a693 -> 05325ccade1) - posted by gu...@apache.org on 2025/02/26 07:04:46 UTC, 0 replies.
- (flink) branch master updated (69559fb5d23 -> 2f172c113c2) - posted by dw...@apache.org on 2025/02/26 13:16:48 UTC, 0 replies.
- (flink) 01/04: [FLINK-37374][table] Add the built-in function JSON for JSON_ARRAY - posted by dw...@apache.org on 2025/02/26 13:16:49 UTC, 0 replies.
- (flink) 02/04: [FLINK-37374][table] Add tests for JSON in JSON_ARRAY - posted by dw...@apache.org on 2025/02/26 13:16:50 UTC, 0 replies.
- (flink) 03/04: [FLINK-37374][docs] Add documentation for JSON in JSON_ARRAY - posted by dw...@apache.org on 2025/02/26 13:16:51 UTC, 0 replies.
- (flink) 04/04: [FLINK-37374][table] Adjust error message in tests for stability + docs - posted by dw...@apache.org on 2025/02/26 13:16:52 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Update failureaccess in order to fix java 11 license check - posted by sn...@apache.org on 2025/02/26 14:06:13 UTC, 0 replies.
- (flink-benchmarks) branch master updated: [FLINK-37376] Upgrade flink-shaded to 20.0 - posted by sn...@apache.org on 2025/02/26 15:12:08 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-37394] Update CI Flink versions to 1.19 and 1.20 - posted by fc...@apache.org on 2025/02/26 15:16:24 UTC, 0 replies.
- (flink) branch master updated (14a5375a0e0 -> fa2d02bf59f) - posted by dw...@apache.org on 2025/02/26 17:06:05 UTC, 0 replies.
- (flink) 01/02: [hotfix] Rename SparkJoinReorderRule to FlinkJoinReorderRule - posted by dw...@apache.org on 2025/02/26 17:06:06 UTC, 0 replies.
- (flink) 02/02: Update flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinReorderRule.java - posted by dw...@apache.org on 2025/02/26 17:06:07 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37337][sql-client] No need to add sql-client jar as job dependencies (#26213) - posted by sh...@apache.org on 2025/02/27 01:26:45 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37162][docs] Add sinks.md to describe Flink's Data Sink API - posted by le...@apache.org on 2025/02/27 05:51:01 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37337][sql-client] No need to add sql-client jar as job dependencies (#26222) - posted by xu...@apache.org on 2025/02/27 06:06:44 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix] Integrate hive connector docs - posted by sn...@apache.org on 2025/02/27 10:45:58 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-37396][build] Use multiple top-level packages discovered in a flat-layout in setup.py - posted by le...@apache.org on 2025/02/27 11:53:25 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-37380][connector/kafka] Change TransactionalIdPrefix as required option when Exactly-Once enabled - posted by le...@apache.org on 2025/02/27 13:05:00 UTC, 0 replies.
- (flink) branch master updated: [hotfix] fix NOTICE file in order to fix java 11 license check - posted by sn...@apache.org on 2025/02/27 13:44:02 UTC, 0 replies.
- (flink) branch master updated (fd47c3f3850 -> 356f5bb8e2e) - posted by tw...@apache.org on 2025/02/27 14:40:46 UTC, 0 replies.
- (flink) branch master updated (356f5bb8e2e -> cd62c6cf678) - posted by tw...@apache.org on 2025/02/27 16:17:03 UTC, 0 replies.
- (flink) branch master updated (cd62c6cf678 -> b633f9851eb) - posted by sn...@apache.org on 2025/02/27 17:53:24 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37398][state] Add proper message when state processor API is used with changelog - posted by ga...@apache.org on 2025/02/27 18:24:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37385][table] Add support for smile format - posted by sn...@apache.org on 2025/02/27 20:06:14 UTC, 0 replies.
- (flink) branch release-2.0 updated (87dd9c726d3 -> f967ff8b9a4) - posted by ju...@apache.org on 2025/02/28 02:53:22 UTC, 0 replies.
- (flink) 01/02: [hotfix][runtime] Fix vertex initialization timing does not meet expectations when the parallelism is decided - posted by ju...@apache.org on 2025/02/28 02:53:23 UTC, 1 replies.
- (flink) 02/02: [FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise - posted by ju...@apache.org on 2025/02/28 02:53:24 UTC, 1 replies.
- (flink) branch master updated (5c80e80abd6 -> 741ff29b675) - posted by ju...@apache.org on 2025/02/28 02:56:01 UTC, 0 replies.
- Re: [I] [Bug] flink-connector-oracle-cdc.version：2.4.0监听了oracle所有的schema的表数据变更？而不是我指定的schema [flink-cdc] - posted by "chenguosnake (via GitHub)" <gi...@apache.org> on 2025/02/28 03:13:04 UTC, 0 replies.
- (flink) branch master updated (741ff29b675 -> fe1b77785fc) - posted by za...@apache.org on 2025/02/28 03:37:42 UTC, 0 replies.
- (flink) branch release-2.0 updated: [FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states (#26228) - posted by za...@apache.org on 2025/02/28 03:37:47 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36997] Add Log4j JSONTemplateLayout to flink-dist (#25888) - posted by za...@apache.org on 2025/02/28 04:29:20 UTC, 0 replies.
- (flink) branch master updated (85a9fc8a016 -> 6b56f20bddc) - posted by dw...@apache.org on 2025/02/28 12:11:49 UTC, 0 replies.
- (flink) branch master updated: [FLINK-37390] Push filter into ChangelogNormalize - posted by dw...@apache.org on 2025/02/28 17:31:13 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36585][connector/common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. (#26205) - posted by jq...@apache.org on 2025/02/28 18:00:38 UTC, 0 replies.
- (flink) branch release-2.0 updated: [hotfix][FLINK-36585][connector/common] Fix the accidentally changed timeout unit of the SplitFetcherManager close timeout. And improve the test stability. (#26205) - posted by jq...@apache.org on 2025/02/28 21:50:48 UTC, 0 replies.