Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5695
IMO it is not a problem to have duplicate code for legacy/new code.
Creating a base class is more effort that it is worth, as the legacy version
will be removed again in 1.6 we would then have to merge the new version with
the base class again.---
