[
https://issues.apache.org/jira/browse/FLINK-13393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-13393:
---------------------------------
Description:
Now there is a exception when user use table source like:
{code:java}
class MyTableSource[T] extend StreamTableSource[T]
{code}
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.
was:
Now there is a exception when use:
class MyTableSource[T] extend StreamTableSource[T].
> Blink-planner not support generic TableSource
> ---------------------------------------------
>
> Key: FLINK-13393
> URL: https://issues.apache.org/jira/browse/FLINK-13393
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Jingsong Lee
> Assignee: Jingsong Lee
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.9.0, 1.10.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Now there is a exception when user use table source like:
> {code:java}
> class MyTableSource[T] extend StreamTableSource[T]
> {code}
> 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.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
