通过sql_query执行返回table对象,执行table.to_pandas()报错:
Traceback (most recent call last):
File
"C:/projects/dataService-pyflink_explore/dataService-calculate-code-python/src/test/test_mysql_connector.py",
line 161, in <module>
print(table.to_pandas().head(6))
File
"C:\Users\18242\AppData\Local\Programs\Python\Python37\lib\site-packages\pyflink\table\table.py",
line 723, in to_pandas
.collectAsPandasDataFrame(self._j_table, max_arrow_batch_size)
File
"C:\Users\18242\AppData\Local\Programs\Python\Python37\lib\site-packages\py4j\java_gateway.py",
line 1286, in __call__
answer, self.gateway_client, self.target_id, self.name)
File
"C:\Users\18242\AppData\Local\Programs\Python\Python37\lib\site-packages\pyflink\util\exceptions.py",
line 154, in deco
raise exception_mapping[exception](s.split(': ', 1)[1], stack_trace)
pyflink.util.exceptions.TableException: 'Sort on a non-time-attribute field is
not supported.'
请教各位大佬,为什么会转换失败?但表格本身print_schema是没问题的。