dianfu commented on code in PR #29599:
URL: https://github.com/apache/flink/pull/29599#discussion_r4421487555
##########
flink-python/pyflink/datastream/tests/test_data_stream.py:
##########
@@ -1053,6 +1053,53 @@ def filter(self, value):
expected = ['+I[c, 1]', '+I[e, 2]']
self.assert_equals_sorted(expected, results)
+ def test_map_state_contains_none_value(self):
Review Comment:
I'm thinking that we can introduce some unit tests for state_impl.py to
avoid it cases as much as possible. I will address this during merging this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
