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)
