You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/21 05:47:00 UTC
[jira] [Created] (FLINK-31877) StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable
Sergey Nuyanzin created FLINK-31877:
---------------------------------------
Summary: StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable
Key: FLINK-31877
URL: https://issues.apache.org/jira/browse/FLINK-31877
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.16.1
Reporter: Sergey Nuyanzin
{noformat}
Apr 21 05:11:45 =================================== FAILURES ===================================
Apr 21 05:11:45 _____ StreamExecutionEnvironmentTests.test_from_collection_with_data_types _____
Apr 21 05:11:45
Apr 21 05:11:45 self = <pyflink.datastream.tests.test_stream_execution_environment.StreamExecutionEnvironmentTests testMethod=test_from_collection_with_data_types>
Apr 21 05:11:45
Apr 21 05:11:45 def test_from_collection_with_data_types(self):
Apr 21 05:11:45 # verify from_collection for the collection with single object.
Apr 21 05:11:45 ds = self.env.from_collection(['Hi', 'Hello'], type_info=Types.STRING())
Apr 21 05:11:45 ds.add_sink(self.test_sink)
Apr 21 05:11:45 > self.env.execute("test from collection with single object")
Apr 21 05:11:45
Apr 21 05:11:45 pyflink/datastream/tests/test_stream_execution_environment.py:257:
Apr 21 05:11:45 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
Apr 21 05:11:45 pyflink/datastream/stream_execution_environment.py:764: in execute
Apr 21 05:11:45 return JobExecutionResult(self._j_stream_execution_environment.execute(j_stream_graph))
Apr 21 05:11:45 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1321: in __call__
Apr 21 05:11:45 return_value = get_return_value(
Apr 21 05:11:45 pyflink/util/exceptions.py:146: in deco
Apr 21 05:11:45 return f(*a, **kw)
Apr 21 05:11:45 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
{noformat}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=48320&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295&l=31864
--
This message was sent by Atlassian Jira
(v8.20.10#820010)