Zhenhao Li created FLINK-22615:
----------------------------------

             Summary: can't use test harness to test Scala UDF because of two 
versions of ProcessWindowFunction
                 Key: FLINK-22615
                 URL: https://issues.apache.org/jira/browse/FLINK-22615
             Project: Flink
          Issue Type: Improvement
            Reporter: Zhenhao Li


I'm trying to use `InternalSingleValueProcessWindowFunction` to test a UDF of 
class
```
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction
```

But the constructor of `InternalSingleValueProcessWindowFunction` expect 
```
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction and
```

I'm wondering if it is possible to use a common abstraction for Java and Scala 
in those test utilities. 




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to