Hey there, We were using DataStreamUtils.collect in Scala for automated testing, which only works because of `DataStream.getJavaStream` accessor in the Scala version of `DataStream`. However, a recent commit ( https://github.com/apache/flink/commit/086acf681f01f2da530c04289e0682c56f98a378) removed `getJavaStream` and replaced the method with a private version that we can no longer access from our tests.
Do you have an alternative version of DataStreamUtils that does not require a Java DataStream? Cheers, Cory