Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6156#discussion_r195116411
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapMergingState.java
---
@@ -34,12 +33,10 @@
* @param <IN> The type of the input elements.
* @param <SV> The type of the values in the state.
* @param <OUT> The type of the output elements.
- * @param <S> The type of State
*/
-public abstract class AbstractHeapMergingState<K, N, IN, SV, OUT, S
extends State>
- extends AbstractHeapState<K, N, SV, S>
- implements InternalMergingState<K, N, IN, SV, OUT> {
-
+public abstract class AbstractHeapMergingState<K, N, IN, SV, OUT>
+ extends AbstractHeapState<K, N, SV>
+ implements InternalMergingState<K, N, IN, SV, OUT>,
org.apache.flink.runtime.state.internal.InternalAppendingState<K, N, IN, SV,
OUT> {
--- End diff --
I would make this a regular import.
---
