[
https://issues.apache.org/jira/browse/FLINK-25303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waittting updated FLINK-25303:
------------------------------
Attachment: screenshot-20211214-193243.png
> LookupTableSource/TableFunction
> -------------------------------
>
> Key: FLINK-25303
> URL: https://issues.apache.org/jira/browse/FLINK-25303
> Project: Flink
> Issue Type: Bug
> Reporter: waittting
> Priority: Major
> Attachments: screenshot-20211214-193243.png
>
>
> Hello, I need to implement LookupTableSource in my code, so I created a class
> {code:java}
> public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext context) {
> CCDynamicLookUpFunction = new CCDynamicLookUpFunction();
> returnTableFunctionProvider.of(tableFunction);
> } {code}
> {code:java}
> public class CCDynamicLookUpFunction extends TableFunction<RowData> {} {code}
> In the class CCDynamicLookUpFunction, I have fetched my data and executed the
> collect func
> {code:java}
> public void eval(Object... keys) {
> RowData row = dataReader.getNext();
> System.out.println(row.toString());
> collect(row);
> }{code}
> I'm sure the row is not null.
> But I find that the data I've collected doesn't seem to have any effect
> {code:java}
> +I(17978,2020-03-23T00:00:00.189760,F,A,true,0,-32768,-2147483648,-9223372036854775808,-18446744073709551616,-3.1,-3.14,-3.141291000)
> +I(17978,2020-03-23T00:00:00.189760,F,A,true,0,-32768,-2147483648,-9223372036854775808,-18446744073709551616,-3.1,-3.14,-3.141291000)
> | +I | -2147483648 | e0f22c444f807abbd6a38ac0fc2... | 2021-12-14T11:09:46.772
> | (NULL) | (NULL) | (NULL) |
> (NULL) | (NULL) | (NULL) | (NULL) |
> (NULL) | (NULL) | (NULL) |
> (NULL) | (NULL) |
> (NULL) |
> {code}
> Can you tell me why?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
