[jira] [Created] (FLINK-21216) StreamPandasConversionTests Fails

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-21216) StreamPandasConversionTests Fails

Shang Yuanchun (Jira)
Guowei Ma created FLINK-21216:
---------------------------------

             Summary: 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.13.0
            Reporter: Guowei Ma


[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)