[flink] branch master updated: [FLINK-25940][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

[hxb]

This is an automated email from the ASF dual-hosted git repository.

hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new c92cda9  [FLINK-25940][python] Fix the unstable test 
test_keyed_process_function_with_state in PyFlink
c92cda9 is described below

commit c92cda97108c6d6818e0fd6c22dba274884f3479
Author: huangxingbo <hxbks...@gmail.com>
AuthorDate: Mon Feb 14 11:07:02 2022 +0800

    [FLINK-25940][python] Fix the unstable test 
test_keyed_process_function_with_state in PyFlink
    
    This closes #18742.
---
 flink-python/pyflink/datastream/tests/test_data_stream.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/flink-python/pyflink/datastream/tests/test_data_stream.py 
b/flink-python/pyflink/datastream/tests/test_data_stream.py
index 1b6e0d5..e507468 100644
--- a/flink-python/pyflink/datastream/tests/test_data_stream.py
+++ b/flink-python/pyflink/datastream/tests/test_data_stream.py
@@ -632,8 +632,6 @@ class DataStreamTests(object):
                 self.map_state = 
runtime_context.get_map_state(map_state_descriptor)
 
             def process_element(self, value, ctx):
-                import time
-                time.sleep(1)
                 current_value = self.value_state.value()
                 self.value_state.update(value[0])
                 current_list = [_ for _ in self.list_state.get()]