Create Embedded Flink Infrastructure for tests, see: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/testing/#testing-flink-jobs