You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Till Rohrmann (Jira)" <ji...@apache.org> on 2022/02/03 09:42:00 UTC
[jira] [Created] (FLINK-25940) pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP
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)