Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5691#discussion_r174380744
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapMergingState.java
 ---
    @@ -28,18 +28,19 @@
     import java.util.Collection;
     
     /**
    - * Base class for {@link MergingState} ({@link 
org.apache.flink.runtime.state.internal.InternalMergingState})
    - * that is stored on the heap.
    + * Base class for {@link MergingState} ({@link InternalMergingState}) that 
is stored on the heap.
      *
    - * @param <K> The type of the key.
    - * @param <N> The type of the namespace.
    - * @param <SV> The type of the values in the state.
    - * @param <S> The type of State
    - * @param <SD> The type of StateDescriptor for the State S
    + * @param <K>      The type of the key.
    + * @param <N>      The type of the namespace.
    + * @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.
    --- End diff --
    
    indentation


---

Reply via email to