You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2024/10/10 12:13:50 UTC
(flink) branch master updated: [hotfix][state/forst] Remove string.format() in critical path (#25473)
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 string.format() in critical path (#25473)
0e776fee86b is described below
commit 0e776fee86bd40ee7368986e06cbf81bf5f38ca6
Author: Yanfei Lei <fr...@gmail.com>
AuthorDate: Thu Oct 10 20:13:42 2024 +0800
[hotfix][state/forst] Remove string.format() in critical path (#25473)
---
.../src/main/java/org/apache/flink/state/forst/ForStMapState.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java
index 1dcc65e325f..05a25921c77 100644
--- a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java
+++ b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java
@@ -182,8 +182,7 @@ public class ForStMapState<K, N, UK, UV> extends AbstractMapState<K, N, UK, UV>
(RecordContext<K>) stateRequest.getRecordContext(),
(N) stateRequest.getNamespace(),
((Tuple2<UK, UV>) stateRequest.getPayload()).f0);
- Preconditions.checkNotNull(
- stateRequest.getPayload(), String.format("payload is null, %s", stateRequest));
+ Preconditions.checkNotNull(stateRequest.getPayload());
UV value = null;
if (stateRequest.getRequestType() == StateRequestType.MAP_PUT) {
value = ((Tuple2<UK, UV>) stateRequest.getPayload()).f1;