[flink-statefun] 06/07: [hotfix] [core] Remove redundant conditioning in HttpRequestReplyClient.parseResponse

[tzulitai]

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 d0d999a35b6b559d8ee4595aaed3de57e5849b51
Author: Tzu-Li (Gordon) Tai <tzuli...@apache.org>
AuthorDate: Mon Nov 23 11:34:52 2020 +0800

    [hotfix] [core] Remove redundant conditioning in 
HttpRequestReplyClient.parseResponse
---
 .../flink/statefun/flink/core/httpfn/HttpRequestReplyClient.java    | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpRequestReplyClient.java
 
b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpRequestReplyClient.java
index efff157..f27528d 100644
--- 
a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpRequestReplyClient.java
+++ 
b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpRequestReplyClient.java
@@ -73,11 +73,7 @@ final class HttpRequestReplyClient implements 
RequestReplyClient {
   private static FromFunction parseResponse(Response response) {
     final InputStream httpResponseBody = responseBody(response);
     try {
-      FromFunction fromFunction = parseProtobufOrThrow(FromFunction.parser(), 
httpResponseBody);
-      if (fromFunction.hasInvocationResult()) {
-        return fromFunction;
-      }
-      return FromFunction.getDefaultInstance();
+      return parseProtobufOrThrow(FromFunction.parser(), httpResponseBody);
     } finally {
       IOUtils.closeQuietly(httpResponseBody);
     }