[FLINK-22615] can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Zhenhao Li
• Created: 10/May/21 07:22
• Updated: 24/Dec/21 10:39

Description

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.