[
https://issues.apache.org/jira/browse/FLINK-31877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718510#comment-17718510
]
Sergey Nuyanzin commented on FLINK-31877:
-----------------------------------------
// cc [~xtsong], [~jark]
> 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
> Priority: Critical
> Labels: test-stability
>
> {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)
