Hequn Cheng created FLINK-11222: ----------------------------------- Summary: Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase Key: FLINK-11222 URL: https://issues.apache.org/jira/browse/FLINK-11222 Project: Flink Issue Type: Improvement Components: Table API & SQL Reporter: Hequn Cheng
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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)