flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java (3 lines):
	- line 121: // TODO: replace this with a complete solution of reading first model data from unbounded
	- line 134: // TODO: replace this simple implementation of model data version with the formal API to
	- line 215: // TODO: Add INFO level logging.


flink-ml-core/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java (1 line):
	- line 95: // TODO: add version in the metadata.


flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/VariableLengthByteKeyComparator.java (1 line):
	- line 39: * <p>TODO: remove this class after making the corresponding class in Flink public.


flink-ml-servable-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/SparseVectorSerializer.java (1 line):
	- line 85: // TODO: optimize the serialization/deserialization process of SparseVectorSerializer.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/TailOperator.java (1 line):
	- line 105: // TODO: Unfortunately, we have to rely on the tail operator to help


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/Iterations.java (1 line):
	- line 485: // TODO: Support epoch watermark alignment for TailOperator.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/HeadOperatorFactory.java (1 line):
	- line 82: // TODO: We would have to create a new mailboxExecutor since the given one


flink-ml-python/pyflink/ml/__init__.py (1 line):
	- line 24: # TODO: Remove custom jar loader after FLINK-15635 and FLINK-28002 are fixed and released.


flink-ml-python/pyflink/ml/util/read_write_utils.py (1 line):
	- line 85: # TODO: add version in the metadata.


flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/FixedLengthByteKeyComparator.java (1 line):
	- line 39: * <p>TODO: remove this class after making the corresponding class in Flink public.


flink-ml-lib/src/main/java/org/apache/flink/ml/common/optimizer/SGD.java (1 line):
	- line 261: // TODO: supports efficient shuffle of training set on each partition.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/checkpoint/Checkpoints.java (1 line):
	- line 166: // TODO: support of the remote fs.


flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java (1 line):
	- line 162: // TODO: Add INFO level logging.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/InputOperator.java (1 line):
	- line 53: // TODO: FLINK-31373 Support processing watermarks in iterations.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java (1 line):
	- line 73: // TODO: Note that here we relies on the assumption that the


flink-ml-python/src/main/java/org/apache/flink/ml/python/PythonBridgeUtils.java (1 line):
	- line 56: // TODO: Remove this class after Flink ML depends on a Flink version with FLINK-30168 and


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/ReplayOperator.java (1 line):
	- line 264: // TODO: free cached records when they will no longer be replayed, and enable caching


flink-ml-python/pyflink/ml/wrapper.py (1 line):
	- line 63: # TODO: Remove this class after Flink ML depends on a Flink version


flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/KeyAndValueSerializer.java (1 line):
	- line 45: * <p>TODO: remove this class after making the corresponding class in Flink public.


flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperator.java (1 line):
	- line 132: // TODO: there may be a memory leak if the BroadcastWrapper finishes fast before this


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/utils/ReflectionUtils.java (1 line):
	- line 107: * <p>TODO: Remove this method after the Py4j bug is fixed.


flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperator.java (1 line):
	- line 107: // TODO: Note that here we relies on the assumption that the


flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/Iterations.java (1 line):
	- line 485: // TODO: Support epoch watermark alignment for TailOperator.


flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/sort/BytesKeyNormalizationUtil.java (1 line):
	- line 29: * <p>TODO: remove this class after making the corresponding class in Flink public.