I implements my DimTable by extends `LookupTableSource`[1], which stores data
like:
id=1 -> (SH, BJ, SD)
id=2 -> (...)
and then extends `TableFunction` to return the value corresponding to the
lookup keys，and maybe return multi rows, for example, when lookupkeys is id=1,
then in the `TableFunction.eval`
```
collect('SH')
collect('BJ')
collect('SD')
```
Now I want to get the region'count by id, which is from the tblEvent.id, sql is
:
SELECT tblEvent.id, COUNT(tblDim.region) FROM tblEvent JOIN tblDim FOR SYSTEM
AS OF tblEvent.proctime ON tblEvent.id = tblDim.id GROUP BY tblEvent.id
I expect the result of COUNT is always 3 for id = 1, no matter the id=1 appears
how many times.
but the actual result is : 3, 6, 9, ...
I think this is bcz the state mechanism behind COUNT, how to turn this off?
Or what's the correct use for this? StreamQueryConfig.maxIdleStateRetentionTime
or something?
The reason not using state in flink:
http://mail-archives.apache.org/mod_mbox/flink-dev/201901.mbox/%3cjira.13212450.1548753499000.193293.1548753540...@atlassian.jira%3E
[1]:https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sourceSinks.html#defining-a-tablesource-for-lookups
