Till Rohrmann created FLINK-25940: ------------------------------------- Summary: pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP Key: FLINK-25940 URL: https://issues.apache.org/jira/browse/FLINK-25940 Project: Flink Issue Type: Bug Components: API / Python Affects Versions: 1.15.0 Reporter: Till Rohrmann
The test {{pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state}} fails on AZP: {code} 2022-02-02T17:44:12.1898582Z Feb 02 17:44:12 =================================== FAILURES =================================== 2022-02-02T17:44:12.1899860Z Feb 02 17:44:12 _____ StreamingModeDataStreamTests.test_keyed_process_function_with_state ______ 2022-02-02T17:44:12.1900493Z Feb 02 17:44:12 2022-02-02T17:44:12.1901218Z Feb 02 17:44:12 self = <pyflink.datastream.tests.test_data_stream.StreamingModeDataStreamTests testMethod=test_keyed_process_function_with_state> 2022-02-02T17:44:12.1901948Z Feb 02 17:44:12 2022-02-02T17:44:12.1902745Z Feb 02 17:44:12 def test_keyed_process_function_with_state(self): 2022-02-02T17:44:12.1903722Z Feb 02 17:44:12 self.env.get_config().set_auto_watermark_interval(2000) 2022-02-02T17:44:12.1904473Z Feb 02 17:44:12 self.env.set_stream_time_characteristic(TimeCharacteristic.EventTime) 2022-02-02T17:44:12.1906780Z Feb 02 17:44:12 data_stream = self.env.from_collection([(1, 'hi', '1603708211000'), 2022-02-02T17:44:12.1908034Z Feb 02 17:44:12 (2, 'hello', '1603708224000'), 2022-02-02T17:44:12.1909166Z Feb 02 17:44:12 (3, 'hi', '1603708226000'), 2022-02-02T17:44:12.1910122Z Feb 02 17:44:12 (4, 'hello', '1603708289000'), 2022-02-02T17:44:12.1911099Z Feb 02 17:44:12 (5, 'hi', '1603708291000'), 2022-02-02T17:44:12.1912451Z Feb 02 17:44:12 (6, 'hello', '1603708293000')], 2022-02-02T17:44:12.1913456Z Feb 02 17:44:12 type_info=Types.ROW([Types.INT(), Types.STRING(), 2022-02-02T17:44:12.1914338Z Feb 02 17:44:12 Types.STRING()])) 2022-02-02T17:44:12.1914811Z Feb 02 17:44:12 2022-02-02T17:44:12.1915317Z Feb 02 17:44:12 class MyTimestampAssigner(TimestampAssigner): 2022-02-02T17:44:12.1915724Z Feb 02 17:44:12 2022-02-02T17:44:12.1916782Z Feb 02 17:44:12 def extract_timestamp(self, value, record_timestamp) -> int: 2022-02-02T17:44:12.1917621Z Feb 02 17:44:12 return int(value[2]) 2022-02-02T17:44:12.1918262Z Feb 02 17:44:12 2022-02-02T17:44:12.1918855Z Feb 02 17:44:12 class MyProcessFunction(KeyedProcessFunction): 2022-02-02T17:44:12.1919363Z Feb 02 17:44:12 2022-02-02T17:44:12.1919744Z Feb 02 17:44:12 def __init__(self): 2022-02-02T17:44:12.1920143Z Feb 02 17:44:12 self.value_state = None 2022-02-02T17:44:12.1920648Z Feb 02 17:44:12 self.list_state = None 2022-02-02T17:44:12.1921298Z Feb 02 17:44:12 self.map_state = None 2022-02-02T17:44:12.1921864Z Feb 02 17:44:12 2022-02-02T17:44:12.1922479Z Feb 02 17:44:12 def open(self, runtime_context: RuntimeContext): 2022-02-02T17:44:12.1923907Z Feb 02 17:44:12 value_state_descriptor = ValueStateDescriptor('value_state', Types.INT()) 2022-02-02T17:44:12.1924922Z Feb 02 17:44:12 self.value_state = runtime_context.get_state(value_state_descriptor) 2022-02-02T17:44:12.1925741Z Feb 02 17:44:12 list_state_descriptor = ListStateDescriptor('list_state', Types.INT()) 2022-02-02T17:44:12.1926482Z Feb 02 17:44:12 self.list_state = runtime_context.get_list_state(list_state_descriptor) 2022-02-02T17:44:12.1927465Z Feb 02 17:44:12 map_state_descriptor = MapStateDescriptor('map_state', Types.INT(), Types.STRING()) 2022-02-02T17:44:12.1927998Z Feb 02 17:44:12 state_ttl_config = StateTtlConfig \ 2022-02-02T17:44:12.1928444Z Feb 02 17:44:12 .new_builder(Time.seconds(1)) \ 2022-02-02T17:44:12.1928943Z Feb 02 17:44:12 .set_update_type(StateTtlConfig.UpdateType.OnReadAndWrite) \ 2022-02-02T17:44:12.1929462Z Feb 02 17:44:12 .set_state_visibility( 2022-02-02T17:44:12.1929939Z Feb 02 17:44:12 StateTtlConfig.StateVisibility.ReturnExpiredIfNotCleanedUp) \ 2022-02-02T17:44:12.1930601Z Feb 02 17:44:12 .disable_cleanup_in_background() \ 2022-02-02T17:44:12.1931032Z Feb 02 17:44:12 .build() 2022-02-02T17:44:12.1931480Z Feb 02 17:44:12 map_state_descriptor.enable_time_to_live(state_ttl_config) 2022-02-02T17:44:12.1932018Z Feb 02 17:44:12 self.map_state = runtime_context.get_map_state(map_state_descriptor) 2022-02-02T17:44:12.1932610Z Feb 02 17:44:12 2022-02-02T17:44:12.1933172Z Feb 02 17:44:12 def process_element(self, value, ctx): 2022-02-02T17:44:12.1933623Z Feb 02 17:44:12 import time 2022-02-02T17:44:12.1934007Z Feb 02 17:44:12 time.sleep(1) 2022-02-02T17:44:12.1934419Z Feb 02 17:44:12 current_value = self.value_state.value() 2022-02-02T17:44:12.1934977Z Feb 02 17:44:12 self.value_state.update(value[0]) 2022-02-02T17:44:12.1935451Z Feb 02 17:44:12 current_list = [_ for _ in self.list_state.get()] 2022-02-02T17:44:12.1935921Z Feb 02 17:44:12 self.list_state.add(value[0]) 2022-02-02T17:44:12.1936401Z Feb 02 17:44:12 map_entries = {k: v for k, v in self.map_state.items()} 2022-02-02T17:44:12.1936862Z Feb 02 17:44:12 keys = sorted(map_entries.keys()) 2022-02-02T17:44:12.1937649Z Feb 02 17:44:12 map_entries_string = [str(k) + ': ' + str(map_entries[k]) for k in keys] 2022-02-02T17:44:12.1938404Z Feb 02 17:44:12 map_entries_string = '{' + ', '.join(map_entries_string) + '}' 2022-02-02T17:44:12.1938906Z Feb 02 17:44:12 self.map_state.put(value[0], value[1]) 2022-02-02T17:44:12.1939350Z Feb 02 17:44:12 current_key = ctx.get_current_key() 2022-02-02T17:44:12.1939889Z Feb 02 17:44:12 yield "current key: {}, current value state: {}, current list state: {}, " \ 2022-02-02T17:44:12.1940521Z Feb 02 17:44:12 "current map state: {}, current value: {}".format(str(current_key), 2022-02-02T17:44:12.1941111Z Feb 02 17:44:12 str(current_value), 2022-02-02T17:44:12.1941645Z Feb 02 17:44:12 str(current_list), 2022-02-02T17:44:12.1942254Z Feb 02 17:44:12 map_entries_string, 2022-02-02T17:44:12.1942796Z Feb 02 17:44:12 str(value)) 2022-02-02T17:44:12.1943369Z Feb 02 17:44:12 2022-02-02T17:44:12.1943761Z Feb 02 17:44:12 def on_timer(self, timestamp, ctx): 2022-02-02T17:44:12.1944178Z Feb 02 17:44:12 pass 2022-02-02T17:44:12.1944503Z Feb 02 17:44:12 2022-02-02T17:44:12.1944898Z Feb 02 17:44:12 watermark_strategy = WatermarkStrategy.for_monotonous_timestamps() \ 2022-02-02T17:44:12.1945537Z Feb 02 17:44:12 .with_timestamp_assigner(MyTimestampAssigner()) 2022-02-02T17:44:12.1946018Z Feb 02 17:44:12 data_stream.assign_timestamps_and_watermarks(watermark_strategy) \ 2022-02-02T17:44:12.1946525Z Feb 02 17:44:12 .key_by(lambda x: x[1], key_type=Types.STRING()) \ 2022-02-02T17:44:12.1947019Z Feb 02 17:44:12 .process(MyProcessFunction(), output_type=Types.STRING()) \ 2022-02-02T17:44:12.1947465Z Feb 02 17:44:12 .add_sink(self.test_sink) 2022-02-02T17:44:12.1948146Z Feb 02 17:44:12 self.env.execute('test time stamp assigner with keyed process function') 2022-02-02T17:44:12.1948637Z Feb 02 17:44:12 results = self.test_sink.get_results() 2022-02-02T17:44:12.1949166Z Feb 02 17:44:12 expected = ["current key: hi, current value state: None, current list state: [], " 2022-02-02T17:44:12.1949957Z Feb 02 17:44:12 "current map state: {}, current value: Row(f0=1, f1='hi', " 2022-02-02T17:44:12.1950624Z Feb 02 17:44:12 "f2='1603708211000')", 2022-02-02T17:44:12.1951234Z Feb 02 17:44:12 "current key: hello, current value state: None, " 2022-02-02T17:44:12.1951822Z Feb 02 17:44:12 "current list state: [], current map state: {}, current value: Row(f0=2," 2022-02-02T17:44:12.1952596Z Feb 02 17:44:12 " f1='hello', f2='1603708224000')", 2022-02-02T17:44:12.1953292Z Feb 02 17:44:12 "current key: hi, current value state: 1, current list state: [1], " 2022-02-02T17:44:12.1954134Z Feb 02 17:44:12 "current map state: {1: hi}, current value: Row(f0=3, f1='hi', " 2022-02-02T17:44:12.1954799Z Feb 02 17:44:12 "f2='1603708226000')", 2022-02-02T17:44:12.1955331Z Feb 02 17:44:12 "current key: hello, current value state: 2, current list state: [2], " 2022-02-02T17:44:12.1956145Z Feb 02 17:44:12 "current map state: {2: hello}, current value: Row(f0=4, f1='hello', " 2022-02-02T17:44:12.1956826Z Feb 02 17:44:12 "f2='1603708289000')", 2022-02-02T17:44:12.1957362Z Feb 02 17:44:12 "current key: hi, current value state: 3, current list state: [1, 3], " 2022-02-02T17:44:12.1958156Z Feb 02 17:44:12 "current map state: {1: hi, 3: hi}, current value: Row(f0=5, f1='hi', " 2022-02-02T17:44:12.1958845Z Feb 02 17:44:12 "f2='1603708291000')", 2022-02-02T17:44:12.1959382Z Feb 02 17:44:12 "current key: hello, current value state: 4, current list state: [2, 4]," 2022-02-02T17:44:12.1960011Z Feb 02 17:44:12 " current map state: {2: hello, 4: hello}, current value: Row(f0=6, " 2022-02-02T17:44:12.1960715Z Feb 02 17:44:12 "f1='hello', f2='1603708293000')"] 2022-02-02T17:44:12.1961159Z Feb 02 17:44:12 > self.assert_equals_sorted(expected, results) 2022-02-02T17:44:12.1961533Z Feb 02 17:44:12 2022-02-02T17:44:12.1961906Z Feb 02 17:44:12 pyflink/datastream/tests/test_data_stream.py:683: 2022-02-02T17:44:12.1962464Z Feb 02 17:44:12 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 2022-02-02T17:44:12.1963186Z Feb 02 17:44:12 pyflink/datastream/tests/test_data_stream.py:62: in assert_equals_sorted 2022-02-02T17:44:12.1963670Z Feb 02 17:44:12 self.assertEqual(expected, actual) 2022-02-02T17:44:12.1964685Z Feb 02 17:44:12 E AssertionError: Lists differ: ["cur[719 chars]te: {1: hi, 3: hi}, current value: Row(f0=5, f[172 chars]0')"] != ["cur[719 chars]te: {3: hi}, current value: Row(f0=5, f1='hi',[165 chars]0')"] 2022-02-02T17:44:12.1965369Z Feb 02 17:44:12 E 2022-02-02T17:44:12.1965731Z Feb 02 17:44:12 E First differing element 4: 2022-02-02T17:44:12.1966428Z Feb 02 17:44:12 E "curr[80 chars]te: {1: hi, 3: hi}, current value: Row(f0=5, f[23 chars]00')" 2022-02-02T17:44:12.1967192Z Feb 02 17:44:12 E "curr[80 chars]te: {3: hi}, current value: Row(f0=5, f1='hi',[16 chars]00')" 2022-02-02T17:44:12.1967860Z Feb 02 17:44:12 E 2022-02-02T17:44:12.1968268Z Feb 02 17:44:12 E Diff is 1211 characters long. Set self.maxDiff to None to see it. 2022-02-02T17:44:12.1968783Z Feb 02 17:44:12 =============================== warnings summary =============================== 2022-02-02T17:44:12.1969374Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_classpaths 2022-02-02T17:44:12.1970541Z Feb 02 17:44:12 /__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/future/standard_library/__init__.py:65: DeprecationWarning: the imp module is deprecated in favour of importlib; see the module's documentation for alternative uses 2022-02-02T17:44:12.1971219Z Feb 02 17:44:12 import imp 2022-02-02T17:44:12.1971530Z Feb 02 17:44:12 2022-02-02T17:44:12.1972027Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_classpaths 2022-02-02T17:44:12.1973535Z Feb 02 17:44:12 /__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/typehints/typehints.py:693: DeprecationWarning: Using or importing the ABCs from 'collections' instead of from 'collections.abc' is deprecated since Python 3.3, and in 3.10 it will stop working 2022-02-02T17:44:12.1974526Z Feb 02 17:44:12 if not isinstance(type_params, collections.Iterable): 2022-02-02T17:44:12.1974930Z Feb 02 17:44:12 2022-02-02T17:44:12.1975407Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_classpaths 2022-02-02T17:44:12.1976680Z Feb 02 17:44:12 /__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/typehints/typehints.py:532: DeprecationWarning: Using or importing the ABCs from 'collections' instead of from 'collections.abc' is deprecated since Python 3.3, and in 3.10 it will stop working 2022-02-02T17:44:12.1977509Z Feb 02 17:44:12 if not isinstance(type_params, (collections.Sequence, set)): 2022-02-02T17:44:12.1977939Z Feb 02 17:44:12 2022-02-02T17:44:12.1978432Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_python_archive 2022-02-02T17:44:12.1979475Z Feb 02 17:44:12 /__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/_pytest/threadexception.py:75: PytestUnhandledThreadExceptionWarning: Exception in thread read_grpc_client_inputs 2022-02-02T17:44:12.1980064Z Feb 02 17:44:12 2022-02-02T17:44:12.1980434Z Feb 02 17:44:12 Traceback (most recent call last): 2022-02-02T17:44:12.1981152Z Feb 02 17:44:12 File "/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/threading.py", line 932, in _bootstrap_inner 2022-02-02T17:44:12.1981642Z Feb 02 17:44:12 self.run() 2022-02-02T17:44:12.1982368Z Feb 02 17:44:12 File "/__w/1/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/threading.py", line 870, in run 2022-02-02T17:44:12.1982884Z Feb 02 17:44:12 self._target(*self._args, **self._kwargs) 2022-02-02T17:44:12.1983865Z Feb 02 17:44:12 File "/__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/data_plane.py", line 598, in <lambda> 2022-02-02T17:44:12.1984471Z Feb 02 17:44:12 target=lambda: self._read_inputs(elements_iterator), 2022-02-02T17:44:12.1985299Z Feb 02 17:44:12 File "/__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/data_plane.py", line 581, in _read_inputs 2022-02-02T17:44:12.1985881Z Feb 02 17:44:12 for elements in elements_iterator: 2022-02-02T17:44:12.1986760Z Feb 02 17:44:12 File "/__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/grpc/_channel.py", line 426, in __next__ 2022-02-02T17:44:12.1987262Z Feb 02 17:44:12 return self._next() 2022-02-02T17:44:12.1987946Z Feb 02 17:44:12 File "/__w/1/s/flink-python/.tox/py38/lib/python3.8/site-packages/grpc/_channel.py", line 826, in _next 2022-02-02T17:44:12.1988425Z Feb 02 17:44:12 raise self 2022-02-02T17:44:12.1989023Z Feb 02 17:44:12 grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: 2022-02-02T17:44:12.1990067Z Feb 02 17:44:12 status = StatusCode.CANCELLED 2022-02-02T17:44:12.1990653Z Feb 02 17:44:12 details = "Multiplexer hanging up" 2022-02-02T17:44:12.1991849Z Feb 02 17:44:12 debug_error_string = "{"created":"@1643823819.576493566","description":"Error received from peer ipv4:127.0.0.1:33091","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Multiplexer hanging up","grpc_status":1}" 2022-02-02T17:44:12.1993432Z Feb 02 17:44:12 > 2022-02-02T17:44:12.1993889Z Feb 02 17:44:12 2022-02-02T17:44:12.1994521Z Feb 02 17:44:12 warnings.warn(pytest.PytestUnhandledThreadExceptionWarning(msg)) 2022-02-02T17:44:12.1995279Z Feb 02 17:44:12 2022-02-02T17:44:12.1996037Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_python_file 2022-02-02T17:44:12.1997435Z Feb 02 17:44:12 /__w/1/s/flink-python/pyflink/table/table_environment.py:1997: DeprecationWarning: Deprecated in 1.12. Use from_data_stream(DataStream, *Expression) instead. 2022-02-02T17:44:12.1998269Z Feb 02 17:44:12 warnings.warn( 2022-02-02T17:44:12.1998594Z Feb 02 17:44:12 2022-02-02T17:44:12.1999075Z Feb 02 17:44:12 pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_execute 2022-02-02T17:44:12.2000008Z Feb 02 17:44:12 /__w/1/s/flink-python/pyflink/table/table_environment.py:538: DeprecationWarning: Deprecated in 1.10. Use create_table instead. 2022-02-02T17:44:12.2000823Z Feb 02 17:44:12 warnings.warn("Deprecated in 1.10. Use create_table instead.", DeprecationWarning) 2022-02-02T17:44:12.2001522Z Feb 02 17:44:12 2022-02-02T17:44:12.2002614Z Feb 02 17:44:12 -- Docs: https://docs.pytest.org/en/stable/warnings.html 2022-02-02T17:44:12.2003603Z Feb 02 17:44:12 ============================= slowest 20 durations ============================= 2022-02-02T17:44:12.2004618Z Feb 02 17:44:12 10.16s call pyflink/datastream/tests/test_connectors.py::ConnectorTests::test_stream_file_sink 2022-02-02T17:44:12.2005726Z Feb 02 17:44:12 9.83s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_process_function_with_state 2022-02-02T17:44:12.2006511Z Feb 02 17:44:12 8.79s call pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state 2022-02-02T17:44:12.2007232Z Feb 02 17:44:12 6.78s call pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_add_python_file 2022-02-02T17:44:12.2007961Z Feb 02 17:44:12 5.52s call pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_execute_and_collect 2022-02-02T17:44:12.2009001Z Feb 02 17:44:12 5.44s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_execute_and_collect 2022-02-02T17:44:12.2010033Z Feb 02 17:44:12 5.26s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_basic_co_operations_with_output_type 2022-02-02T17:44:12.2011152Z Feb 02 17:44:12 5.25s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_basic_co_operations 2022-02-02T17:44:12.2012377Z Feb 02 17:44:12 4.53s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_co_process 2022-02-02T17:44:12.2013701Z Feb 02 17:44:12 4.35s call pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_set_requirements_with_cached_directory 2022-02-02T17:44:12.2014884Z Feb 02 17:44:12 4.32s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_reduce_with_state 2022-02-02T17:44:12.2015900Z Feb 02 17:44:12 4.26s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_flat_map 2022-02-02T17:44:12.2016970Z Feb 02 17:44:12 4.21s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_co_map 2022-02-02T17:44:12.2018270Z Feb 02 17:44:12 4.06s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_filter 2022-02-02T17:44:12.2019463Z Feb 02 17:44:12 3.90s call pyflink/datastream/tests/test_stream_execution_environment.py::StreamExecutionEnvironmentTests::test_set_requirements_without_cached_directory 2022-02-02T17:44:12.2020715Z Feb 02 17:44:12 3.90s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_aggregating_state 2022-02-02T17:44:12.2021749Z Feb 02 17:44:12 3.87s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_keyed_co_flat_map 2022-02-02T17:44:12.2022862Z Feb 02 17:44:12 3.84s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_multi_key_by 2022-02-02T17:44:12.2024078Z Feb 02 17:44:12 3.83s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_time_window 2022-02-02T17:44:12.2024912Z Feb 02 17:44:12 3.83s call pyflink/datastream/tests/test_data_stream.py::BatchModeDataStreamTests::test_count_window 2022-02-02T17:44:12.2025750Z Feb 02 17:44:12 =========================== short test summary info ============================ 2022-02-02T17:44:12.2026370Z Feb 02 17:44:12 FAILED pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state 2022-02-02T17:44:12.2027008Z Feb 02 17:44:12 ======= 1 failed, 154 passed, 1 skipped, 6 warnings in 235.76s (0:03:55) ======= 2022-02-02T17:44:12.5428501Z Feb 02 17:44:12 test module /__w/1/s/flink-python/pyflink/datastream failed 2022-02-02T17:44:12.5431151Z Feb 02 17:44:12 ERROR: InvocationError for command /bin/bash ./dev/integration_test.sh (exited with code 1) 2022-02-02T17:44:12.5432097Z Feb 02 17:44:12 py38 finish: run-test after 999.77 seconds 2022-02-02T17:44:12.5436171Z Feb 02 17:44:12 py38 start: run-test-post 2022-02-02T17:44:12.5437071Z Feb 02 17:44:12 py38 finish: run-test-post after 0.00 seconds 2022-02-02T17:44:12.5438162Z Feb 02 17:44:12 ___________________________________ summary ____________________________________ 2022-02-02T17:44:12.5453873Z Feb 02 17:44:12 ERROR: py38: commands failed 2022-02-02T17:44:12.5455066Z Feb 02 17:44:12 cleanup /__w/1/s/flink-python/.tox/.tmp/package/1/apache-flink-1.15.dev0.zip 2022-02-02T17:44:12.6013749Z Feb 02 17:44:12 ============tox checks... [FAILED]============ {code} https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30642&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901&l=24759 -- This message was sent by Atlassian Jira (v8.20.1#820001)