[ https://issues.apache.org/jira/browse/FLINK-31877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-31877: ----------------------------------- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Critical but is unassigned and neither itself nor its Sub-Tasks have been updated for 14 days. I have gone ahead and marked it "stale-critical". If this ticket is critical, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > 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: stale-critical, 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)