Path Lines of Code amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java 796 amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/KinesisDeserializationSchema.java 12 amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/JobManagerWatermarkTracker.java 130