GIScience / GIScience/osmalert
Compute distinct users using Flink aggregation
Open
- Dominant language
- Java
- Stars
- 3
- Forks
- 0
- PR merge metrics
- No merged PRs in 30d
Description
Currently the distinct user count is achieved via a singleton.
This is potentially unsafe for both concurrent and remote Flink job execution.
TODO:
Use `org.apache.flink.api.common.functions.AggregateFunction` to store the intermediate state safely.
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.