[FLINK-27223][python] Fix the state access problem when python.state.…

…cache-size is set to 0 This closes apache#19457.
liuyongvs · Apr 14, 2022 · eee8804 · eee8804
1 parent 6155b3a
commit eee8804
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flink-python/pyflink/fn_execution/state_impl.py b/flink-python/pyflink/fn_execution/state_impl.py
@@ -149,7 +149,8 @@ def get_internal_state(self):
         return self._internal_state
 
     def _maybe_clear_write_cache(self):
-        if self._cache_type == SynchronousKvRuntimeState.CacheType.DISABLE_CACHE:
+        if self._cache_type == SynchronousKvRuntimeState.CacheType.DISABLE_CACHE or \
+                self._remote_state_backend._state_cache_size <= 0:
             self._internal_state.commit()
             self._internal_state._cleared = False
             self._internal_state._added_elements = []