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

    https://github.com/apache/flink/pull/5138#discussion_r156231965
  
    --- Diff: 
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper.java
 ---
    @@ -27,6 +28,7 @@
      *
      * @param <T> The type created by the deserialization schema.
      */
    +@PublicEvolving
     public class KinesisDeserializationSchemaWrapper<T> implements 
KinesisDeserializationSchema<T> {
    --- End diff --
    
    I think this is also only meant for `@Internal` use.


---

Reply via email to