waittting created FLINK-25303:
---------------------------------
Summary: LookupTableSource/TableFunction
Key: FLINK-25303
URL: https://issues.apache.org/jira/browse/FLINK-25303
Project: Flink
Issue Type: Bug
Reporter: waittting
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)
