flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Cory Monty <cory.mo...@getbraintree.com>
Subject DataStreamUtils and Scala
Date Mon, 01 Feb 2016 17:40:59 GMT
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

Mime
View raw message