Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia merged PR #24748: URL: https://github.com/apache/flink/pull/24748 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on PR #24748: URL: https://github.com/apache/flink/pull/24748#issuecomment-2115075350 Thanks all for the detailed review!  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1602677598 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,207 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

Zakelly commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1601239723 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,207 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1601082456 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperatorV2.java: ## @@ -188,6 +190,35 @@

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1600886728 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperatorV2.java: ## @@ -188,6

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1597838569 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java: ## @@ -102,6 +104,12 @@ public class

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1597912452 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596619045 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596255057 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596251789 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596247061 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596244806 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

Zakelly commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596216484 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java: ## @@ -259,6 +262,44 @@

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1596135042 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595237975 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595180329 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595174398 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java: ## @@ -130,11 +152,17 @@ public AsyncExecutionController(

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595172001 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java: ## @@ -220,6 +222,40 @@ public

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595167569 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595166564 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/SerialEpochManager.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595073378 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/SerialEpochManager.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595062558 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AbstractEpochManager.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595053517 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AbstractEpochManager.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1595026752 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AbstractEpochManager.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1593512764 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java: ## @@ -130,11 +152,17 @@ public

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

yunfengzhou-hub commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1593486058 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AbstractEpochManager.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35030][runtime] Introduce Epoch Manager under async execution [flink]

Zakelly commented on code in PR #24748: URL: https://github.com/apache/flink/pull/24748#discussion_r1593310127 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software