(flink) branch master updated (4594f5e081d -> 707bae0fb11)

2025-05-11 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 4594f5e081d [FLINK-36876] Support external eventLoopGroup for RestClient add 707bae0fb11 [FLINK-37552][state

(flink) branch master updated: [FLINK-37554][state/forst] Add UT for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend (#26440)

2025-04-15 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 795fcbe79a7 [FLINK-37554][state/forst] Add UT

(flink) branch release-2.0 updated: [FLINK-37623][datastream] Async state support for process() in Datastream API (#26439)

2025-04-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 8c8667e0166 [FLINK-37623

(flink) branch master updated: [FLINK-37623][datastream] Async state support for process() in Datastream API (#26419)

2025-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 98000fbe598 [FLINK-37623][datastream] Async

(flink) branch release-2.0 updated: [FLINK-37620][state/forst] ForSt Sync mode support remote storage (#26422)

2025-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 8605484ca6a [FLINK-37620][state

(flink) branch master updated (b37c98599b3 -> f7b5d00c453)

2025-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from b37c98599b3 [FLINK-37610] Check if `ORDER BY` keys exists before accessing add f7b5d00c453 [FLINK-37642

(flink) branch master updated: [FLINK-37620][state/forst] ForSt Sync mode support remote storage (#26412)

2025-04-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 3bc96001656 [FLINK-37620][state/forst] ForSt

(flink) branch release-2.0 updated: [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators (#26395)

2025-04-08 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 14e85eced10 [FLINK-37458

(flink) branch master updated: [FLINK-37524][state/forst] Make ForStState Restore from previous StateMetaInfo (#26391)

2025-04-06 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 b0ad87a76f5 [FLINK-37524][state/forst] Make

(flink) branch release-2.0 updated: [FLINK-37597][state/forst] Use ResourceGuard to make sure snapshot quit before ForSt disposal

2025-04-06 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 4f71f44145b [FLINK-37597][state

(flink) 01/02: [FLINK-37597][state/forst] Use ResourceGuard to make sure snapshot quit before ForSt disposal

2025-04-04 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 36eb336e4a623400a6bfdf1aab29723038e472a1 Author: fredia AuthorDate: Tue Apr 1 14:42:23 2025 +0800 [FLINK-37597

(flink) 02/02: [FLINK-37158][tests] Introduce ForSt to existing ITCases

2025-04-04 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 076fa80e3147d2d19f2f54af6b85fd63038fb6a0 Author: fredia AuthorDate: Thu Apr 3 12:32:20 2025 +0800 [FLINK-37158

(flink) branch master updated (4a0c2e40506 -> 076fa80e314)

2025-04-03 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 4a0c2e40506 [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator (#26328) new

(flink) branch master updated: [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator (#26328)

2025-04-02 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 4a0c2e40506 [FLINK-37521][runtime] Implement

(flink) branch master updated: [FLINK-37463][state/forst] make serialzer in ForStMapState Threadlocal (#26286)

2025-03-18 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 1c5a295ec5f [FLINK-37463][state/forst] make

(flink) branch master updated: Revert "[FLINK-37158][tests] Introduce ForSt to existing ITCases (#26000)" (#26291)

2025-03-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 0d0c185c7c2 Revert "[FLINK-37158][

(flink) branch master updated: [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators (#26283)

2025-03-12 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 932f17da6cb [FLINK-37458][datastream] Forbid

(flink) branch master updated: [FLINK-37158][tests] Introduce ForSt to existing ITCases (#26000)

2025-03-11 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 6099697b501 [FLINK-37158][tests] Introduce

(flink) branch release-2.0 updated: [BP-2.0][FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend (#26269)

2025-03-06 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 2865c9d6573 [BP-2.0][FLINK-37434

(flink) branch master updated: [FLINK-37434][state/forst] Make incremental checkpoint configurable in ForStSyncKeyedStateBackend (#26267)

2025-03-06 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 c3190b7bce5 [FLINK-37434][state/forst] Make

(flink) branch release-2.0 updated: [FLINK-37268][example] Use async state in flink-examples-streaming (#26136)

2025-02-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 866e1a948ef [FLINK-37268][example

(flink) branch master updated: [FLINK-37268][example] Use async state in flink-examples-streaming (#26117)

2025-02-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 759635db069 [FLINK-37268][example] Use async

(flink) branch release-2.0 updated: [FLINK-35578][state/rocksdb] Bump frocksdbjni to 8.10.0-ververica-1.0 (#26067)

2025-01-23 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-2.0 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-2.0 by this push: new 9c4c3fad4b9 [FLINK-35578][state

(flink) branch master updated (ea2251e843b -> b615a7e9b6a)

2025-01-23 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from ea2251e843b [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4

(flink) branch master updated: [FLINK-37021][state/forst] Forst remote dir share checkpoint dir (#26006)

2025-01-19 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 64f686c705d [FLINK-37021][state/forst] Forst

(flink) branch master updated: [FLINK-35405][runtime] Add metrics for AsyncExecutionController (#25998)

2025-01-19 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 704b5c4b200 [FLINK-35405][runtime] Add

(flink) branch master updated: [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007)

2025-01-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 9b411b3f1f7 [hotfix] Fix compile error in

(flink) branch master updated: [FLINK-37140][runtime] Create async timer service when restore async operator (#25993)

2025-01-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 33de4ea7739 [FLINK-37140][runtime] Create

(flink) branch master updated (4ae4b871c08 -> c9311756582)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 4ae4b871c08 [FLINK-36957][Datastream] Implement asyc state version of stream flatmap (#25848) add c9311756582

(flink) branch master updated: [FLINK-36957][Datastream] Implement asyc state version of stream flatmap (#25848)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 4ae4b871c08 [FLINK-36957][Datastream

(flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions created (now 097d4982959)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions in repository https://gitbox.apache.org/repos/asf/flink.git at 097d4982959 Address reviewer feedback No new revisions were added

(flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs created (now cb22534b7d4)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs in repository https://gitbox.apache.org/repos/asf/flink.git at cb22534b7d4 [hotfix] [docs] Add lead()/lag() Table API agg

(flink) branch fhueske-FLINK-36642-backport created (now 1c51e884ff5)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-FLINK-36642-backport in repository https://gitbox.apache.org/repos/asf/flink.git at 1c51e884ff5 [FLINK-36642][table] Fix SQL names of built-in functions (#25601) No new

(flink) branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs deleted (was cb22534b7d4)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-hotfix-add-lead_lag-table-api-agg-functions-to-docs in repository https://gitbox.apache.org/repos/asf/flink.git was cb22534b7d4 [hotfix] [docs] Add lead()/lag() Table API agg

(flink) branch fhueske-FLINK-36642-backport deleted (was 1c51e884ff5)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-FLINK-36642-backport in repository https://gitbox.apache.org/repos/asf/flink.git was 1c51e884ff5 [FLINK-36642][table] Fix SQL names of built-in functions (#25601) The revisions

(flink) branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions deleted (was 097d4982959)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch fhueske-FLINK-36642-Fix_SqlNames_of_builtin_functions in repository https://gitbox.apache.org/repos/asf/flink.git was 097d4982959 Address reviewer feedback The revisions that were on

(flink) branch ngn346 deleted (was 81ea19f5b19)

2025-01-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch ngn346 in repository https://gitbox.apache.org/repos/asf/flink.git was 81ea19f5b19 fixup! [FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom

(flink) branch master updated: [FLINK-37031][state/forst] Bump forstjni to 0.1.5 && make ForStFlinkFileSystem thread safe" (#25927)

2025-01-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 a79f2e2f1b4 [FLINK-37031][state/forst] Bump

(flink) branch master updated: [FLINK-36935][state/forst] Implement fast link for ForStFileSystem (#25818)

2025-01-06 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 9878e561af3 [FLINK-36935][state/forst

(flink) branch master updated: [FLINK-36961][state/forst] Wait ForSt state excutor shutdown when disposing (#25854)

2024-12-31 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 1fc886b5103 [FLINK-36961][state/forst] Wait

(flink) branch master updated: [FLINK-35904][test] Make async test harness extend exsit test harness (#25856)

2024-12-25 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 0a55677dff7 [FLINK-35904][test] Make async

(flink) branch master updated (6248fd4fd61 -> 12ee2993707)

2024-12-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 6248fd4fd61 [FLINK-33921][table] Cleanup deprecated IdleStateRetentionTime related method in

(flink) branch master updated (d541997954e -> 96773507be2)

2024-12-16 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d541997954e [FLINK-36904] Fix document error on how to programmatically configure serialization add

(flink) branch master updated: [FLINK-36875][runtime] Complete timer before emiting watermark (#25773)

2024-12-11 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 43c50b91418 [FLINK-36875][runtime] Complete

(flink) branch master updated: [FLINK-34974][state] Support getOrCreateKeyedState for AsyncKeyedStateBackend (#25745)

2024-12-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 6a85f8047b2 [FLINK-34974][state] Support

(flink) branch master updated: [FLINK-36693][state/forst] Implement checkpoint/restore for ForStSyncKeyedStateBackend (#25643)

2024-11-19 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 7341b6ef050 [FLINK-36693][state/forst

(flink) branch master updated: [FLINK-36592][state/forst] Support file cache for ForStStateBackend (#25561)

2024-11-07 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 2ceb62da555 [FLINK-36592][state/forst

(flink) branch master updated: [FLINK-35268][state] Add ttl interface for Async State API && implement TtlListStateV2/TtlValueStateV2 (#25515)

2024-10-29 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 dbfc83d1cfd [FLINK-35268][state] Add ttl

(flink) branch master updated: [FLINK-35029][state/forst] Store timer in JVM heap when use async state backend (#25501)

2024-10-22 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 039a07d09cf [FLINK-35029][state/forst] Store

(flink) branch master updated: [FLINK-35031][runtime] LatencyMarker/RecordAttribute emitting under async execution model (#25503)

2024-10-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 ecb41150dab [FLINK-35031][runtime

(flink) branch master updated: [hotfix][state/forst] Remove string.format() in critical path (#25473)

2024-10-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 0e776fee86b [hotfix][state/forst] Remove

(flink) 01/02: [FLINK-35928][state/forst] Bump forstjni version to 0.1.2-beta

2024-10-01 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6f132a8de491f6a93015bdd8432603a368330baf Author: fredia AuthorDate: Mon Sep 30 12:43:15 2024 +0800 [FLINK-35928

(flink) 02/02: [FLINK-36374][state/forst] Bundle forst statebackend in flink-dist and provide shortcut to enable

2024-10-01 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit dc2bf35bd7b589e2072a06581bc535284ec4d070 Author: Zakelly AuthorDate: Thu Sep 26 12:49:06 2024 +0800 [FLINK-36374

(flink) branch master updated (3b2a96854c4 -> dc2bf35bd7b)

2024-10-01 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3b2a96854c4 [FLINK-36355][runtime] Remove deprecated SetupableStreamOperator new 6f132a8de49 [FLINK-35928

(flink) branch master updated (6444f18ed36 -> 73a02855caf)

2024-09-30 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 6444f18ed36 [FLINK-36378][table] Fix type extraction bug between java BigDecimal and sql decimal. add

(flink) branch master updated: [FLINK-34975][state/forst] Support multiget for forstdb (#25363)

2024-09-25 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 f33abffe1da [FLINK-34975][state/forst

(flink) branch master updated: [FLINK-34975][state/forst] Execute read/write state request in different executor (#25360)

2024-09-22 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 1d1bf5c8f69 [FLINK-34975][state/forst

(flink) branch master updated: [FLINK-35667][state/forst] Implement Reducing Async State API for ForStStateBackend (#25308)

2024-09-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 d8b3243eaa5 [FLINK-35667][state/forst

(flink) branch master updated: [FLINK-35927][state/forst] Make ForStFlinkFileSystem write misc file in local filesystem (#25310)

2024-09-13 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 f520674f52e [FLINK-35927][state/forst] Make

(flink) branch master updated: [FLINK-36243][state/forst] Store namespace in state request and contextKey (#25300)

2024-09-11 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 25969c9de1e [FLINK-36243][state/forst] Store

(flink) branch master updated: [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode (#25192)

2024-09-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 7adeecd3445 [FLINK-34510][Runtime/State

(flink) branch master updated: [hotfix][checkpoint] Rename file-merging options in documents (#25048)

2024-07-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 c15145b4a8c [hotfix][checkpoint] Rename file

(flink) branch release-1.20 updated: [hotfix][checkpoint] Rename file-merging options in documents (#25049)

2024-07-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch release-1.20 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.20 by this push: new 0bdbfeb41be [hotfix][checkpoint

(flink) branch release-1.18 updated: [BP-1.18] [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#25032)

2024-07-07 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 87b36233512 [BP-1.18] [FLINK

(flink) branch master updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#24917)

2024-07-05 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 e78524a8780 [FLINK-33192][runtime] Fix Memory

(flink) branch master updated: [FLINK-32091][checkpoint] Add file size metrics for file-merging (#24922)

2024-06-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 54978689f68 [FLINK-32091][checkpoint] Add

(flink) branch master updated (9fbe9f30480 -> 1e996b8731b)

2024-05-27 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 9fbe9f30480 [FLINK-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt (#24847

(flink) branch master updated: [FLINK-35382][test] Disable snapshot-file-merging in ChangelogCompatibilityITCase (#24813)

2024-05-20 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 26b149a1664 [FLINK-35382][test] Disable

(flink) branch master updated: [FLINK-35030][runtime] Introduce Epoch Manager for under async execution (#24748)

2024-05-16 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 f1ecb9e4701 [FLINK-35030][runtime] Introduce

(flink) branch master updated: [FLINK-32082][docs] Documentation of checkpoint file-merging (#24766)

2024-05-16 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 a8cf2ba1224 [FLINK-32082][docs] Documentation

(flink) branch master updated: [FLINK-32092][tests] Integrate snapshot file-merging with existing IT cases (#24789)

2024-05-15 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 b87ead743dc [FLINK-32092][tests] Integrate

(flink) branch master updated: [FLINK-32087][checkpoint] Introduce space amplification statistics of file merging (#24762)

2024-05-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 9a5a99b1a30 [FLINK-32087][checkpoint

(flink) branch master updated (547e4b53ebe -> 4fe66e06974)

2024-05-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 547e4b53ebe [FLINK-35270]Enrich information in logs, making it easier for debugging add 4fe66e06974 [FLINK

(flink) branch master updated: [FLINK-35158][runtime] Error handling in StateFuture's callback

2024-05-08 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 bb0f4429598 [FLINK-35158][runtime] Error

(flink) branch master updated (714d1cb2e0b -> 3ff2ba43720)

2024-04-26 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 714d1cb2e0b [FLINK-35189][test-utils] Introduce test-filesystem connector and catalog based on filesystem to

(flink) branch master updated: [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (#24705)

2024-04-25 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 797cb9cd843 [hotfix][runtime] Make sure run

(flink) branch master updated: [FLINK-35156][Runtime] Make operators of DataStream V2 integrate with async state processing

2024-04-24 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 a87db9333d8 [FLINK-35156][Runtime] Make

(flink) branch master updated (ea2eabe7da5 -> 8475d284f2a)

2024-04-23 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from ea2eabe7da5 [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel

(flink) branch master updated (51d015b5704 -> 0b2e9880354)

2024-04-22 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 51d015b5704 [FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest add 0b2e9880354 [FLINK-35028

(flink) branch master updated: [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController

2024-04-21 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 9336760ace7 [FLINK-35027][runtime/checkpoint

(flink) 02/03: [FLINK-35025][Runtime/State] Abstract stream operators for async state processing

2024-04-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e1edb24ecc2e28987803ded3b460323c0179a052 Author: Zakelly AuthorDate: Fri Apr 12 21:52:29 2024 +0800 [FLINK-35025

(flink) branch master updated: [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager

2024-04-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 31ea1a9358f [FLINK-34936][Checkpointing

(flink) 03/03: [FLINK-35025][Runtime/State] Introduce element order for async state processing

2024-04-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit fe8dde4ea489f466982ba896c1e2b22a7466e719 Author: Zakelly AuthorDate: Mon Apr 15 20:53:47 2024 +0800 [FLINK-35025

(flink) branch master updated (31ea1a9358f -> fe8dde4ea48)

2024-04-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 31ea1a9358f [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager

(flink) 01/03: [FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components.

2024-04-17 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c7be45d0ba9c4ab6c2ce7757b6c8cd8e1f0fe539 Author: Zakelly AuthorDate: Fri Apr 12 18:34:07 2024 +0800 [FLINK-35025

(flink) branch master updated: [FLINK-32440][checkpoint] Introduce file merging configuration (#22973)

2024-04-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 c601c70e5c4 [FLINK-32440][checkpoint

(flink) branch master updated: [FLINK-35024][Runtime/State] Implement the record buffer of AsyncExecutionController (#24633)

2024-04-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 6d139a19c80 [FLINK-35024][Runtime/State

(flink) 02/03: [FLINK-34986][Runtime/State] Basic implementation of AEC, RecordContext and reference counting

2024-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 294084872604d599c1e2c52302ce0f08bb0e6492 Author: Zakelly AuthorDate: Wed Apr 3 18:39:17 2024 +0800 [FLINK-34986

(flink) 01/03: [FLINK-34986][Runtime/State] Introduce element-control component

2024-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 60c771b987af73382f8a41ccf7fecfdbe6dc8b1c Author: fredia AuthorDate: Thu Mar 21 17:51:23 2024 +0800 [FLINK-34986

(flink) 03/03: [FLINK-34986][Runtime/State] More tests for reference counting of ContextStateFutureImpl

2024-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ec2a140daed15ef596a70f9fb645c55a23c84a2c Author: Zakelly AuthorDate: Sun Apr 7 11:47:14 2024 +0800 [FLINK-34986

(flink) branch master updated (54f789d21ef -> ec2a140daed)

2024-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 54f789d21ef [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629) new 60c771b987a

(flink) branch master updated: [hotfix][doc] Generate and use docs of RpcOptions instead of AkkaOptions (#24629)

2024-04-10 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 54f789d21ef [hotfix][doc] Generate and use

(flink) branch master updated: [FLINK-28440][State/changelog] Increase the materialization Interval of ChangelogRecoveryITCase#testMaterialization

2024-04-09 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 10522ff67ec [FLINK-28440][State/changelog

(flink) branch master updated: [FLINK-34668][checkpoint] Report operator state handle of file merging directory to JM

2024-03-26 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 05b27be4112 [FLINK-34668][checkpoint] Report

(flink) branch master updated (f7593524579 -> 501de487de9)

2024-03-19 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from f7593524579 [FLINK-34228] Add long UTF serializer/deserializer add 501de487de9 [FLINK-34667][state/changelog

(flink) 01/03: [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 1d1dca6d6b1a80c4fcd3337489a99c0d834692ea Author: Jinzhong Li AuthorDate: Tue Feb 27 18:08:03 2024 +0800 [FLINK

(flink) 02/03: [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ed75795e97800177cb67141ab838632d5ec55bb5 Author: Jinzhong Li AuthorDate: Wed Feb 28 12:19:36 2024 +0800 [FLINK

(flink) 03/03: [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 649e2b412e10c7f698721cbbd8697f9b02248977 Author: Jinzhong Li AuthorDate: Wed Feb 28 18:44:30 2024 +0800 [FLINK

(flink) branch master updated (3b9623e5d2e -> 649e2b412e1)

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3b9623e5d2e [FLINK-32076][checkpoint] Introduce blocking file pool to reuse files (#24418) new 1d1dca6d6b1

(flink) branch master updated: [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase (#24470)

2024-03-11 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei 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 94b55d1ae61 [FLINK-34624][state/changelog

  1   2   >