Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4183
@fhueske That's correct. we generate watermark by timestamp subtracting the
offset. (that's SLA mechanism). we are on the same boat.
I think the value of firstResultTimeOffset is represent the maximum delay
of the data source. e.g., the TT source guarantee that the maximum delay of
data is no more than 5 seconds. Then we can set firstResultTimeOffset=5 seconds.
So, the name of firstResultTimeOffset not pretty suitable. and i think this
config item can not be used in early feature. for example the maximum data
delay of TT source is 5seconds, so we should set firstResultTimeOffset=5, but
we also want get early result for a window (of course we must deal with
retract/updated result).
At current time I also suggest separate the deferred and early
configuration items. deferred is a configuration item of data source data delay
SLA. and early is a configuration item of emit window result. How about
slaOfdataDelay? I am not good at naming the config item. But want try to
clearly express the meaning of this configuration item.
To be honest I'm not sure about early result feature whether we are on the
same boat or not. If not, I think we need detail communication. :-)
Thanks,
SunJincheng
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
