flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java (1 line):
	- line 110: // TODO: wrap accumulator


flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchema.java (1 line):
	- line 80: // TODO FLINK-4194 ADD SUPPORT FOR boolean isEndOfStream(T nextElement);


flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java (1 line):
	- line 672: // TODO: have this thread emit the records for tracking backpressure