You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/02/20 03:14:59 UTC
[flink-statefun] 02/03: [FLINK-16176] Simplify
InvocationBatchRequest building
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 2825589d4827b2686872f6faeac78b5721c5b2b7
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Thu Feb 20 10:45:52 2020 +0800
[FLINK-16176] Simplify InvocationBatchRequest building
This closes #26.
---
.../org/apache/flink/statefun/flink/core/httpfn/HttpFunction.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunction.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunction.java
index 7c07a6f..77857b3 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunction.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunction.java
@@ -122,9 +122,7 @@ final class HttpFunction implements StatefulFunction {
return null;
}
InvocationBatchRequest.Builder builder = InvocationBatchRequest.newBuilder();
- for (Invocation invocation : next) {
- builder.addInvocations(invocation);
- }
+ builder.addAllInvocations(next);
return builder;
}