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

Reply via email to