[
https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276030#comment-17276030
]
Huang Xingbo commented on FLINK-21216:
--------------------------------------
I will take a look asap.
> StreamPandasConversionTests Fails
> ---------------------------------
>
> Key: FLINK-21216
> URL: https://issues.apache.org/jira/browse/FLINK-21216
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.12.0, 1.13.0
> Reporter: Guowei Ma
> Priority: Major
> Labels: test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12699&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=8d78fe4f-d658-5c70-12f8-4921589024c3]
>
> =================================== FAILURES
> ===================================
> _______________ StreamPandasConversionTests.test_empty_to_pandas
> _______________
>
> self =
> <pyflink.table.tests.test_pandas_conversion.StreamPandasConversionTests
> testMethod=test_empty_to_pandas>
>
> def test_empty_to_pandas(self):
> > table = self.t_env.from_pandas(self.pdf, self.data_type)
>
> pyflink/table/tests/test_pandas_conversion.py:144:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> pyflink/table/table_environment.py:1462: in from_pandas
> arrow_schema = pa.Schema.from_pandas(pdf, preserve_index=False)
> pyarrow/types.pxi:1315: in pyarrow.lib.Schema.from_pandas
> ???
> .tox/py37-cython/lib/python3.7/site-packages/pyarrow/pandas_compat.py:519: in
> dataframe_to_types
> type_ = pa.lib._ndarray_to_arrow_type(values, type_)
> pyarrow/array.pxi:53: in pyarrow.lib._ndarray_to_arrow_type
> ???
> pyarrow/array.pxi:64: in pyarrow.lib._ndarray_to_type
> ???
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
>
> > ???
> E pyarrow.lib.ArrowTypeError: Did not pass numpy.dtype object
>
> pyarrow/error.pxi:108: ArrowTypeError
> _________________ StreamPandasConversionTests.test_from_pandas
> _________________
>
> self =
> <pyflink.table.tests.test_pandas_conversion.StreamPandasConversionTests
> testMethod=test_from_pandas>
>
> def test_from_pandas(self):
> > table = self.t_env.from_pandas(self.pdf, self.data_type, 5)
>
> pyflink/table/tests/test_pandas_conversion.py:120:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
