Spark streaming supports direct join from stream DataFrame and batch DataFrame , and it's easy to implement an enrich pipeline that joins a stream and a dimension table.
I checked the doc of flink, seems that this feature is a jira ticket which haven't been resolved yet. So how can I implement such a pipeline easily in Flink?