Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

Zakelly closed pull request #24739: [FLINK-35161][state] Implement StateExecutor for ForStStateBackend URL: https://github.com/apache/flink/pull/24739 -- 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

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

masteryhx commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1592121657 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -31,75 +30,50 @@ /** * The

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

Zakelly commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1591893262 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590951299 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -31,75 +30,50 @@ /** * The

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590937187 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java: ## @@ -0,0 +1,129 @@ +/* + * Licensed to the

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590936786 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590917605 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

masteryhx commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590633134 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java: ## @@ -31,75 +30,50 @@ /** * The

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

Zakelly commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1590582493 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

fredia commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1584477969 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r158208 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java: ## @@ -95,4 +100,32 @@ public V

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1584431128 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1584427802 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java: ## @@ -0,0 +1,123 @@ +/* + * Licensed to the

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

fredia commented on code in PR #24739: URL: https://github.com/apache/flink/pull/24739#discussion_r1584188915 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java: ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

flinkbot commented on PR #24739: URL: https://github.com/apache/flink/pull/24739#issuecomment-2082072721 ## CI report: * 751bee80d40a2f1e4a8669f514371f68730a4a0a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35161][state] Implement StateExecutor for ForStStateBackend [flink]

ljz2051 opened a new pull request, #24739: URL: https://github.com/apache/flink/pull/24739 ## What is the purpose of the change This pull request implements the StateExecutor for ForStStatebackend, which groups the remote state access to optimize performance. Please refer to