[flink-statefun] branch master updated: [FLINK-20336] [core] Do not silently pass UNRECOGNIZED state mutations

[tz...@apache.org]

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


The following commit(s) were added to refs/heads/master by this push:
     new e52f1c1  [FLINK-20336] [core] Do not silently pass UNRECOGNIZED state mutations
e52f1c1 is described below

commit e52f1c1f6cec09cec7650057e66c976462ce364c
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Tue May 25 15:41:57 2021 +0800

    [FLINK-20336] [core] Do not silently pass UNRECOGNIZED state mutations
    
    This closes #235.
---
 .../statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java
index 150949a..e5c4b76 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java
@@ -83,9 +83,8 @@ public final class PersistedRemoteFunctionValues {
             break;
           }
         case UNRECOGNIZED:
-          {
-            break;
-          }
+          throw new IllegalStateException(
+              "Received an UNRECOGNIZED PersistedValueMutation type. This may be caused by a mismatch or incompatibility with the remote function SDK version and the Stateful Functions version.");
         default:
           throw new IllegalStateException("Unexpected value: " + mutate.getMutationType());
       }