Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Now there is a exception when user use table source like:
class MyTableSource[T] extend StreamTableSource[T]
The reason is that blink-planner use TypeExtractor to extract class from TableSource, and use this class to DataFormatConverter.
Now, table source has DataType return type, so we don't need extract class from TableSource, we can just use conversionClass of DataType.
Attachments
Issue Links
- links to
