amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java (2 lines):
	- line 633: // TODO: have this thread emit the records for tracking backpressure
	- line 1172: // TODO: refresh watermark while idle


amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util/JobManagerWatermarkTracker.java (1 line):
	- line 112: // TODO: wrap accumulator


amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization/KinesisDeserializationSchema.java (1 line):
	- line 75: // TODO FLINK-4194 ADD SUPPORT FOR boolean isEndOfStream(T nextElement);