Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Won't Fix
-
None
-
None
Description
Thanks to FLINK-11074, we can create harness tester from a DataStream which makes easier to write harness test.
However, it would be better if we change the parameter type fromĀ api.scala.DataStream to api.datastream.DataStream for the createHarnessTester() method, so that both java.DataStream and scala.DataStream can use this method.