Additional code needed for using Nussknacker with different Flink versions - View it on GitHub