iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkExceptionHandler.java (2 lines):
	- line 34: // TODO: heartbeat
	- line 35: // TODO: retry strategy


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorExceptionHandler.java (1 line):
	- line 34: // TODO: retry strategy


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorTask.java (1 line):
	- line 76: new LinkedBlockingQueue<>(parallelism))); // TODO: thread name


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkConsumer.java (1 line):
	- line 49: // TODO: retry strategy


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceTask.java (1 line):
	- line 73: new LinkedBlockingQueue<>(parallelism))); // TODO: thread name


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/sink/SinkTask.java (1 line):
	- line 66: new LinkedBlockingQueue<>(parallelism))); // TODO: thread name


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/common/PipeRowCollector.java (1 line):
	- line 92: // TODO: non-PipeInsertionEvent sourceEvent is not supported?


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/processor/ProcessorConsumer.java (1 line):
	- line 52: // TODO: retry strategy


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/DemoSink.java (1 line):
	- line 43: // TODO: SHIT..


iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/source/pull/PullSourceConsumer.java (1 line):
	- line 40: // TODO: scheduler strategy