(flink) branch master updated (c3221a649b9 -> f860631c523)

2024-05-26 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from c3221a649b9 [hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context new

(flink) 02/02: [FLINK-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection

2024-05-26 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f860631c523c1d446c0d01046f0fbe6055174dc6 Author: Zhanghao Chen AuthorDate: Mon Apr 8 22:07:01 2024 +0800 [FLINK

(flink) 01/02: [FLINK-34123][core][type] Introduce built-in serialization support for Map, List, and Collection

2024-05-26 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 73676da59584f360c02d139a916033e8967583b3 Author: Zhanghao Chen AuthorDate: Mon Apr 8 21:21:21 2024 +0800 [FLINK

(flink) branch master updated (096b4a6bef9 -> c3221a649b9)

2024-05-26 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 096b4a6bef9 [FLINK-35446][checkpoint] Fix NPE when disabling file merging but restoring from merged files add

(flink) branch release-1.19 updated: [FLINK-35429][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context

2024-05-23 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new a450980de65 [FLINK-35429

(flink) 01/02: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git commit 192f692a5d072d72c24206bd194cd19b8030404d Author: David Radley AuthorDate: Mon Apr 29 12:07:23 2024 +0100

(flink) 02/02: [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git commit a5efed2c06c42186e376dd2ede18dc09986c0387 Author: David Radley AuthorDate: Wed May 22 17:39:37 2024 +0100

(flink) branch release-1.19 updated (ddccfb62dcb -> a5efed2c06c)

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git from ddccfb62dcb [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily new

(flink-connector-elasticsearch) branch v3.0 updated: [FLINK-33493][connectors/elasticsearch] Fix ElasticsearchWriterITCase test

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git The following commit(s) were added to refs/heads/v3.0 by this push: new 44ea967 [FLINK-33493

(flink-connector-elasticsearch) branch v3.0 updated: [FLINK-31696] ElasticSearch nightly CI failure

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git The following commit(s) were added to refs/heads/v3.0 by this push: new e879899 [FLINK-31696

(flink-connector-elasticsearch) 01/01: [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git commit 83cc4294c79abc18f1be2ce36e72bc87e26c026e Author: Weijie Guo AuthorDate: Wed May 22 13:36:28

(flink-connector-elasticsearch) branch v3.0 updated (4e122f7 -> 83cc429)

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git discard 4e122f7 fixup! [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink

(flink-connector-elasticsearch) 01/02: [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git commit 721efec250604159b58f9d8ad7e1ff6f0429ebd3 Author: Weijie Guo AuthorDate: Wed May 22 13:36:28

(flink-connector-elasticsearch) 02/02: fixup! [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git commit 4e122f7de0e5ad52d22dbe4d070baac7af927ba9 Author: Weijie Guo AuthorDate: Wed May 22 14:03:13

(flink-connector-elasticsearch) branch v3.0 updated (f94649a -> 4e122f7)

2024-05-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git from f94649a [hotfix] Set maximum supported Flink version to 1.17 for `v3.0` new 721efec

(flink-connector-elasticsearch) branch main updated: [FLINK-35287] Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git The following commit(s) were added to refs/heads/main by this push: new 0b6d9f8 [FLINK-35287

(flink) 11/11: [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e502d2371ffea52ebfa6b8a1b9d2b4a23bc9bbaa Author: Weijie Guo AuthorDate: Wed Apr 17 17:57:25 2024 +0800 [FLINK

(flink) 09/11: [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 545a0053ff2f0c467d405c3387e1a22b8723f6a4 Author: Weijie Guo AuthorDate: Tue Apr 9 17:56:11 2024 +0800 [FLINK

(flink) 10/11: [FLINK-34549][API] Expose MetricGroup via RuntimeContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ff93e2aaa0e958a974839a317db09a3a4bb7197e Author: Weijie Guo AuthorDate: Tue Apr 9 18:09:03 2024 +0800 [FLINK

(flink) 08/11: [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c431efefdb0341abb118e45480d94caea2f44263 Author: Weijie Guo AuthorDate: Tue Apr 9 11:58:51 2024 +0800 [FLINK

(flink) 04/11: [FLINK-34549][API] Introduce related components for runtime context

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c17440cbfa0e8e9f3c794296cedaae043491f6cd Author: Weijie Guo AuthorDate: Mon Apr 8 17:19:21 2024 +0800 [FLINK

(flink) 05/11: [FLINK-34549][API] Split partition-wise context from RuntimeContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2b0e30329559c61caccb3591c7b5a535f311f823 Author: Weijie Guo AuthorDate: Tue Apr 16 18:03:18 2024 +0800 [FLINK

(flink) 01/11: [hotfix] Temporarily revert the change that makes the v2 operator inherit from the async operator

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4d7aebaed1d4ca693eefa49ecb3bef87e87d0b5c Author: Weijie Guo AuthorDate: Wed May 15 16:59:27 2024 +0800 [hotfix

(flink) 02/11: [FLINK-34549][API] Introduce SlotSharingGroup for v2 and move MemorySize to flink-core-api

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 1d73510bc2e30d5352a8cbbafd7939197a32cedb Author: Weijie Guo AuthorDate: Tue Apr 16 14:42:48 2024 +0800 [FLINK

(flink) 06/11: [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ef7f1d03d790f329cf5da38bb3868810a8f0d97b Author: Weijie Guo AuthorDate: Mon Apr 8 17:25:39 2024 +0800 [FLINK

(flink) 03/11: [FLINK-34549][API] Introduces and implements ProcessConfigurable

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6691dc60019f25fe40babfdf82c1374842a65fe4 Author: Weijie Guo AuthorDate: Mon Apr 8 12:26:25 2024 +0800 [FLINK

(flink) 07/11: [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 0bc2041b23233eff9622753a0d4cfa3b03816421 Author: Weijie Guo AuthorDate: Tue Apr 9 11:47:35 2024 +0800 [FLINK

(flink) branch master updated (c1baf07d760 -> e502d2371ff)

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from c1baf07d760 [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 new 4d7aebaed1d [hotfix

(flink) branch master updated: [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-05-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 46aaea80830 [FLINK-35130][runtime] Simplify

(flink) branch master updated: [FLINK-35395][core] Fix the example code of KeyedStateStore#getState

2024-05-20 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 5f5722fe916 [FLINK-35395][core] Fix

(flink) 04/07: [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 3d31ff929591683172b984ddc9fbee3bbce2504e Author: Weijie Guo AuthorDate: Tue Apr 9 11:58:51 2024 +0800

(flink) 07/07: [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 90ebaa47f54b8e80e6d39b4b182fd7f604f52693 Author: Weijie Guo AuthorDate: Wed Apr 17 17:57:25 2024 +0800

(flink) 03/07: [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 7b1b29ae1ee3d534340927cca18c7ae5a6e5823f Author: Weijie Guo AuthorDate: Tue Apr 9 11:47:35 2024 +0800

(flink) 01/07: [FLINK-34549][API] Split partition-wise context from RuntimeContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 514edd4656a04ccc3184a136196e662f65e02b06 Author: Weijie Guo AuthorDate: Tue Apr 16 18:03:18 2024 +0800

(flink) 02/07: [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit 60488e69e7aa2f772d9090a92447a876b1bec474 Author: Weijie Guo AuthorDate: Mon Apr 8 17:25:39 2024 +0800

(flink) 05/07: [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit c5d543e40cdfbbd5caeb54bc7f237e67c3b2842e Author: Weijie Guo AuthorDate: Tue Apr 9 17:56:11 2024 +0800

(flink) branch FLIP-410-update3 created (now 90ebaa47f54)

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git at 90ebaa47f54 [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context This branch

(flink) 06/07: [FLINK-34549][API] Expose MetricGroup via RuntimeContext

2024-05-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLIP-410-update3 in repository https://gitbox.apache.org/repos/asf/flink.git commit ce1d11933f95b3e66d1316e75d6697aa19ac8776 Author: Weijie Guo AuthorDate: Tue Apr 9 18:09:03 2024 +0800

(flink) branch master updated: [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest

2024-04-26 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 4e6dbe2d1a2 [FLINK-35246][test] Fix incorrect

(flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 63f02a03d72abf13b39766e0edc890a6af303712 Author: Weijie Guo AuthorDate: Sun Feb 26 22:23:45 2023 +0800 [FLINK

(flink) 03/03: [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 259aef0b66b3e55013f02ac31d4cff61202b78c5 Author: Weijie Guo AuthorDate: Sun Feb 26 22:25:37 2023 +0800 [FLINK

(flink) 02/03: [FLINK-31223][test] Abstract SqlClientTestBase.

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6392f815e77bcd15a35abb7a3f8f60bc63180423 Author: Weijie Guo AuthorDate: Sun Feb 26 23:13:45 2023 +0800 [FLINK

(flink) branch master updated (797cb9cd843 -> 259aef0b66b)

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 797cb9cd843 [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (#24705) new 63f02a03d72

(flink-connector-elasticsearch) branch main updated: [FLINK-35134][Connectors/Elasticsearch] Drop support for Flink 1.17

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git The following commit(s) were added to refs/heads/main by this push: new 44a0a14 [FLINK-35134

(flink) branch master updated: [hotfix][docs] Fix the invalid link in 1.18 release note

2024-04-25 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new df4685af2d3 [hotfix][docs] Fix the invalid

(flink) branch FLINK-31223-rest-ssl-fix deleted (was 05cfbb8b308)

2024-04-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch FLINK-31223-rest-ssl-fix in repository https://gitbox.apache.org/repos/asf/flink.git was 05cfbb8b308 [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint

(flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

2024-04-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLINK-31223-rest-ssl-fix in repository https://gitbox.apache.org/repos/asf/flink.git commit d3123fd43c6c97d6061cb4f9fc38be452d5e7f8f Author: Weijie Guo AuthorDate: Sun Feb 26 22:23:45 2023

(flink) 03/03: [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.

2024-04-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLINK-31223-rest-ssl-fix in repository https://gitbox.apache.org/repos/asf/flink.git commit 05cfbb8b308ed0250077ed90bbd06a6661982f9a Author: Weijie Guo AuthorDate: Sun Feb 26 22:25:37 2023

(flink) 02/03: [FLINK-31223][test] Abstract SqlClientTestBase.

2024-04-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch FLINK-31223-rest-ssl-fix in repository https://gitbox.apache.org/repos/asf/flink.git commit 43e1ee5061a2fe8660220930f31b11055801c97f Author: Weijie Guo AuthorDate: Sun Feb 26 23:13:45 2023

(flink) branch FLINK-31223-rest-ssl-fix created (now 05cfbb8b308)

2024-04-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch FLINK-31223-rest-ssl-fix in repository https://gitbox.apache.org/repos/asf/flink.git at 05cfbb8b308 [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint

(flink) branch master updated: [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small

2024-04-23 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 712d9800e6c [FLINK-35166][runtime] Make

(flink) branch master updated: [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated

2024-04-23 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ea2eabe7da5 [FLINK-35214][runtime] Update

(flink) branch release-1.19 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator

2024-04-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 6045bd8bf93 [FLINK-35169][runtime

(flink) branch release-1.18 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator

2024-04-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 1b3849c196c [FLINK-35169][runtime

(flink) branch master updated (9336760ace7 -> 68a84fd02fb)

2024-04-21 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 9336760ace7 [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController add

(flink) branch master updated: [hotfix][runtime]Fix the missing methed parameter annotation problem

2024-04-15 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 9ae9c1463d8 [hotfix][runtime]Fix the missing

(flink) branch master updated (722fb9b4052 -> c0d889fbb9a)

2024-04-12 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 722fb9b4052 [FLINK-34250][docs] add new option for avro format docs add c0d889fbb9a [FLINK-35069][API

(flink) 02/02: [hotfix] Correct the option key for sortPartition

2024-04-07 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 32ab253a0442076659b0de67cecd525de47138c4 Author: Weijie Guo AuthorDate: Mon Apr 1 17:55:10 2024 +0800 [hotfix

(flink) 01/02: [hotfix] Document the field start from 1 for sortPartition

2024-04-07 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2bfb7c0a4413664f19203ee63fb2956d4847dd9c Author: Weijie Guo AuthorDate: Mon Apr 1 17:37:52 2024 +0800 [hotfix

(flink) branch master updated (5bbcf8de79c -> 32ab253a044)

2024-04-07 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 5bbcf8de79c [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0

(flink) branch master updated (080efb9c410 -> 54550e3b9b3)

2024-04-05 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 080efb9c410 [FLINK-34025] Add data skew metric endpoint and UI add 54550e3b9b3 [FLINK-34988][build] Fix

(flink) branch master updated (a4470966295 -> 8a18b119c95)

2024-04-02 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from a4470966295 [FLINK-33985][runtime] Support obtain all partitions existing in cluster through ShuffleMaster

(flink) branch master updated: [hotfix] Fix compile error in DataStreamV2SinkTransformation

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d271495c5be [hotfix] Fix compile error

(flink) 11/11: [FLINK-34548][API] Supports sink-v2 Sink

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 28762497bdf574855e4a9293f22ce80e6c7f9002 Author: Weijie Guo AuthorDate: Fri Mar 22 17:44:43 2024 +0800 [FLINK

(flink) 07/11: [FLINK-34548][API] Introduce ExecutionEnvironment

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e1147ca7e390c413c84d11a15b9f09834e930d06 Author: Weijie Guo AuthorDate: Fri Mar 22 16:41:11 2024 +0800 [FLINK

(flink) 08/11: [FLINK-34548][API] Implement process function's underlying operators

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4f71c5b4660be0da199123f085c8605f654803cf Author: Weijie Guo AuthorDate: Fri Mar 22 17:03:32 2024 +0800 [FLINK

(flink) 10/11: [FLINK-34548][API] Supports FLIP-27 Source

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 056660e0b694383c9c3a9cd054ebc0d0782f0411 Author: Weijie Guo AuthorDate: Fri Mar 22 17:27:27 2024 +0800 [FLINK

(flink) 01/11: [FLINK-34548][API] Initialize the datastream v2 related modules

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5b2e923be0a643aa4f5e761ecc499426596d66cf Author: Weijie Guo AuthorDate: Tue Feb 20 11:37:52 2024 +0800 [FLINK

(flink) 09/11: [FLINK-34548][API] Implement datastream

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ceafa5a5705b6547eb8b55449de2c912a9a494f6 Author: Weijie Guo AuthorDate: Fri Mar 22 17:13:22 2024 +0800 [FLINK

(flink) 04/11: [FLINK-34548][API] Introduce ProcessFunction and RuntimeContext related interfaces

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 13cfaa76b5eb90316ecb253d061f4b18b88fde27 Author: Weijie Guo AuthorDate: Thu Mar 21 18:29:01 2024 +0800 [FLINK

(flink) 05/11: [FLINK-34548][API] Introduce variants of ProcessFunction

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit cedbcce6eff6ae6201e192b9f5c593efff5fc977 Author: Weijie Guo AuthorDate: Tue Feb 20 15:18:18 2024 +0800 [FLINK

(flink) 02/11: [FLINK-34548][API] Create flink-core-api module and let flink-core depend on it

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 59525e460afe3665201771e371eab511231f70a6 Author: Weijie Guo AuthorDate: Tue Feb 20 11:50:08 2024 +0800 [FLINK

(flink) 03/11: [FLINK-34548][API] Move Function interface to flink-core-api

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 13790e032077e35bd7da5bc0fe8ad9fdd2572454 Author: Weijie Guo AuthorDate: Tue Feb 20 14:07:51 2024 +0800 [FLINK

(flink) 06/11: [FLINK-34548][API] Introduce stream interface and move KeySelector to flink-core-api

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9fa74a8a7061af3c518853fc10bfa7d7abf5ea6d Author: Weijie Guo AuthorDate: Thu Mar 21 18:39:50 2024 +0800 [FLINK

(flink) branch master updated (3841f062255 -> 28762497bdf)

2024-04-01 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3841f062255 [FLINK-34562][docs-zh] Port Debezium Avro Confluent changes (FLINK-34509) to Chinese new

(flink-connector-elasticsearch) branch main updated (4914929 -> 963c505)

2024-03-20 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git from 4914929 [hotfix] Add dependency convergence for org.yaml:snakeyaml add 963c505 [FLINK

(flink) branch master updated: [FLINK-34121][core] Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

2024-03-18 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new dd382894b4d [FLINK-34121][core] Introduce

(flink) branch release-1.19 updated: [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError

2024-03-17 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 4f7f6a97f79 [FLINK-34571][test

(flink-connector-opensearch) branch main updated: [FLINK-33925][connectors/opensearch] Allow customising bulk failure handling

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-opensearch.git The following commit(s) were added to refs/heads/main by this push: new 9e161cc [FLINK-33925

(flink) 04/05: [FLINK-34543][datastream] Introduce the Aggregate API on PartitionWindowedStream

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 46ec4b02ec2f514eb88e863b1d963e654dea1d32 Author: Wencong Liu AuthorDate: Tue Mar 12 13:49:56 2024 +0800 [FLINK

(flink) branch master updated (aa7158934bb -> a021db68a85)

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from aa7158934bb [FLINK-34660][checkpoint] Avoid randomizing changelog-related config when it's pre-defined (#24488

(flink) 03/05: [FLINK-34543][datastream] Introduce the Reduce API on PartitionWindowedStream

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit fe88e16faf588792cfc8c9f84f7992f5d88ace71 Author: Wencong Liu AuthorDate: Tue Mar 12 12:32:15 2024 +0800 [FLINK

(flink) 05/05: [FLINK-34543][datastream] Introduce the SortPartition API on PartitionWindowedStream

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit a021db68a8545b4183e935beccd9b0d62329ee67 Author: Wencong Liu AuthorDate: Tue Mar 12 14:46:04 2024 +0800 [FLINK

(flink) 01/05: [FLINK-34543][datastream] Introduce the PartitionWindowedStream

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4762311e284fadd0779c266f0f09c72585fe03ef Author: Wencong Liu AuthorDate: Wed Mar 6 20:34:45 2024 +0800 [FLINK

(flink) 02/05: [FLINK-34543][datastream] Introduce the MapPartition API on PartitionWindowedStream

2024-03-13 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit cfbd41ecaa16edad5e460572eea6b5cf660af99d Author: Wencong Liu AuthorDate: Tue Mar 12 12:17:00 2024 +0800 [FLINK

(flink) branch master updated: [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError

2024-03-11 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new fcf61b91089 [FLINK-34571][test] Fix flaky

(flink) branch master updated (1d8cbe9065e -> 4171b980717)

2024-03-08 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 1d8cbe9065e [FLINK-34483][docs] Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage

(flink) branch master updated (5fe6f2024f7 -> 60795b78dce)

2024-02-04 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 5fe6f2024f7 [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated. add 60795b78dce

(flink-connector-jdbc) branch main updated (5a90eb0a -> 611b45cf)

2024-01-31 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git from 5a90eb0a [FLINK-33365] include filters with Lookup joins add 611b45cf [FLINK-34259] Creating

(flink) 02/03: [FLINK-34225][runtime] Fix the race condition in UnionResultSubpartitionView

2024-01-29 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 71c9760322ea8002b7e1af8d93c604287bd098ca Author: yunfengzhou-hub AuthorDate: Wed Dec 13 11:00:45 2023 +0800

(flink) 01/03: [hotfix][runtime] Fix resource releasing and recovery logic in shuffle

2024-01-29 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4aa4507507b60ee4a2b7cc3624a9f36e4d3592ce Author: yunfengzhou-hub AuthorDate: Wed Jan 24 20:16:35 2024 +0800

(flink) 03/03: [FLINK-34233][runtime] Avoid enqueuing input channel before subpartitions initialized

2024-01-29 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 973190e8ca5b7225f18b5c176726ef8680faffca Author: yunfengzhou-hub AuthorDate: Thu Jan 25 09:39:26 2024 +0800

(flink) branch master updated (bb01c3070ea -> 973190e8ca5)

2024-01-29 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from bb01c3070ea [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test new 4aa4507507b [hotfix

(flink) branch master updated: [FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default

2024-01-29 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3b4fa6c424b [FLINK-34103][examples] Include

(flink) 01/02: [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo

2024-01-28 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 300381c2b4bb7e9c711459fb2ad55dbaf5add7ae Author: Zhanghao Chen AuthorDate: Sun Jan 28 00:08:07 2024 +0800 [FLINK

(flink) branch master updated (20450485b20 -> 324a5e45c80)

2024-01-28 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 20450485b20 [FLINK-34222][table-planner] Supports mini-batch for streaming regular join new 300381c2b4b

(flink) 02/02: [hotfix][examples] Doc on why MatrixVectorMul example is not bundled with Flink dist nor deployed in Maven repo

2024-01-28 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 324a5e45c80464335a95cad7fbccfd531d0b098b Author: Zhanghao Chen AuthorDate: Sun Jan 28 13:14:19 2024 +0800

(flink) branch master updated (11631cb5956 -> 2e56caf11c0)

2024-01-27 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 11631cb5956 [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs

(flink) branch master updated (4c1ae285fb6 -> 806970c4b47)

2024-01-24 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 4c1ae285fb6 [FLINK-24024][table-planner] Support session window TVF add 806970c4b47 [FLINK-34120][core

(flink) branch master updated: [FLINK-34090][core] Introduce SerializerConfig

2024-01-22 Thread guoweijie
This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 7336788a9c3 [FLINK-34090][core] Introduce

  1   2   3   4   5   6   7   >