inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/ZooKeeperWatcher.java (3 lines):
	- line 352: // TODO: One thought is to add call to ZooKeeperListener so say,
	- line 382: * TODO: Currently this method rethrows the exception to let the caller handle
	- line 395: * TODO: Currently, this method does nothing. Is this ever expected to happen? Do we abort or


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java (3 lines):
	- line 994: // TODO consider the data proxy load and re-balance
	- line 1045: // TODO consider the data proxy load and re-balance
	- line 1106: // TODO if more than one data proxy cluster, currently takes first


inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java (3 lines):
	- line 119: * Get field info list. TODO 1. Support partition field(not need to add index at 0), 2. Add is_metadata field in
	- line 149: // TODO The meta field needs to be selectable and cannot be filled in by the user
	- line 163: * mappingUnitList.add(new FieldMappingUnit(dataField, dataField)); // TODO discarded later for (MetaField metaField


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/trick/BaseTaskWriter.java (2 lines):
	- line 155: // TODO attach the previous row if has a positional-delete row schema in appender factory.
	- line 171: // TODO attach the previous row if has a positional-delete row schema in appender factory.


inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/relational/JdbcSourceEventDispatcher.java (2 lines):
	- line 145: // TODO `HistorizedSchema.storeOnlyCapturedTables` first appeared in io.debezium.core: 1.6.4-final,
	- line 174: // TODO `HistorizedSchema.storeOnlyCapturedTables` first appeared in io.debezium.core: 1.6.4-final,


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/dirtyData/impl/DirtyQueryLogServiceImpl.java (2 lines):
	- line 108: // TODO dirtyQueryLog.setTaskId();
	- line 140: // TODO dirtyQueryLog.setTaskId();


inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgUtils.java (2 lines):
	- line 226: // TODO : avoid name conflict?
	- line 333: // TODO : avoid name conflict?


inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/regex/DateUtils.java (2 lines):
	- line 218: // TODO : more than one part match the time regex in file name ("/data/joox_logs/2000701106/201602170040.log"
	- line 246: // TODO : time regex error


inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/local/FileTask.java (2 lines):
	- line 323: * TODO: should we do a full scan to avoid lost events?
	- line 366: * TODO: what if this file doesn't have any date pattern regex.


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/PostgresDialect.java (1 line):
	- line 141: // TODO: We can't convert BINARY data type to


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/consume/ConsumePulsarOperator.java (1 line):
	- line 145: // TODO when saving, save the enabled DLQ / RLQ into inlong_stream, then create Pulsar topic for them


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSource.java (1 line):
	- line 173: // TODO: remove this when MessageId is serializable itself.


inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/LogCommand.java (1 line):
	- line 61: // for now only filter by one condition. TODO:support OR and AND, make a condition filter.


inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorFactory.java (1 line):
	- line 141: // TODO we can possibly optimize it to use the nullability of the field


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/DynamicPulsarSerializationSchema.java (1 line):
	- line 183: // TODO need get topic from row.


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkCatalog.java (1 line):
	- line 149: // TODO modify this after Flink support partition transform.


inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSourceBuilder.java (1 line):
	- line 90: // TODO: Add a variable metricSchema to report audit information


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopRenameFileCommitter.java (1 line):
	- line 130: // TODO: in the future we may also need to check if the target file exists.


inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/pulsar/InlongPulsarRequest.java (1 line):
	- line 41: * TODO Add default value InlongConstants.DEFAULT_PULSAR_TENANT when you remove the 'tenant'


inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java (1 line):
	- line 50: // TODO: Add some method to make report audit information exactly once


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/debezium/reader/BinlogSplitReader.java (1 line):
	- line 242: // TODO: there is still very little chance that we can't capture new added table.


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveWriterFactory.java (1 line):
	- line 199: // TODO: support partition properties, for now assume they're same as table properties


inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java (1 line):
	- line 194: // TODO: add ddl to queue


inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java (1 line):
	- line 86: // TODO: Add a variable metricSchema to report audit information


inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/AgentConfiguration.java (1 line):
	- line 90: // TODO: flush to local file as properties file.


inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkCatalog.java (1 line):
	- line 554: // TODO modify this after Flink support partition transform.


inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/DataProxyController.java (1 line):
	- line 54: // TODO protocol type must be provided by the DataProxy


inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorFactory.java (1 line):
	- line 143: // TODO we can possibly optimize it to use the nullability of the field


inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java (1 line):
	- line 41: // TODO: support SourceExactlyMetric and add metric collection points


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java (1 line):
	- line 224: rollback(snapshotId); // TODO: what if rollback throw Exception


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorFactory.java (1 line):
	- line 112: // TODO we can possibly optimize it to use the nullability of the field


inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/Manager.java (1 line):
	- line 92: // TODO: change job state which is in running state.


inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/filter/DateFormatRegex.java (1 line):
	- line 74: // TODO: check with more regex


inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/DeleteCommand.java (1 line):
	- line 64: // TODO: handle and/or classify the exceptions


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/TDSQLPostgresDialect.java (1 line):
	- line 134: // TODO: We can't convert BINARY data type to


inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/ZKUtil.java (1 line):
	- line 450: // TODO: Double check the replacement


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java (1 line):
	- line 1516: // TODO: somehow merge metrics from all active producers?


inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/SchemaChangeUtils.java (1 line):
	- line 239: * TODO: currently only support add column,delete column and column type change, rename column and column position change are not supported


inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/AgentUtils.java (1 line):
	- line 211: // TODO: locale seems not working


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java (1 line):
	- line 172: // TODO: remove this when MessageId is serializable itself.


inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/MySQLBinlogProvider.java (1 line):
	- line 79: // TODO Needs to be configurable for those parameters


inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/local/FileScanner.java (1 line):
	- line 67: // TODO the time is not YYYYMMDDHH


inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/IcebergTableSource.java (1 line):
	- line 207: // TODO: support nested projection


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarQueueResourceOperator.java (1 line):
	- line 289: * TODO delete Subscription and InlongConsume info


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupOperator4Pulsar.java (1 line):
	- line 80: // TODO get the cluster from inlong_cluster by entity.getInlongClusterTag()


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/PulsarMetadataReader.java (1 line):
	- line 213: // TODO:here topic not found must not be wait forever, otherwise is a bug!


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupOperator4TubeMQ.java (1 line):
	- line 71: // TODO get the cluster


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/MySQLDialect.java (1 line):
	- line 137: // TODO: We can't convert BINARY data type to


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java (1 line):
	- line 758: // TODO author=Horia Chiorean date=14/11/2016 description=workaround for


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/debezium/internal/DebeziumChangeFetcher.java (1 line):
	- line 334: // TODO query charset from table information_schema


inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/AgentDbUtils.java (1 line):
	- line 64: /* TODO: try to decrypt password, if failed then use raw password */


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/table/HudiTableInlongFactory.java (1 line):
	- line 55: // TODO query hive path from hive metastore


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/trick/SortedPosDeleteWriter.java (1 line):
	- line 115: // TODO Flush buffer based on the policy that checking whether whole heap memory size exceed the


inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SubscribeFetchResult.java (1 line):
	- line 60: // TODO to fix here


inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/MasterConfig.java (1 line):
	- line 164: * @param webResourcePath TODO: Have no usage, could be removed?


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java (1 line):
	- line 498: // TODO: may append something more meaningful than a timestamp, like query ID


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hudi/HudiCatalogClient.java (1 line):
	- line 223: // FIXME: splitSchemas need config by frontend


inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/DeleteSortListener.java (1 line):
	- line 122: // TODO if the job is OFFLINE, should delete the scheduler information


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/AbstractJdbcDialect.java (1 line):
	- line 56: // TODO: We can't convert VARBINARY(n) data type to


inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/TMaster.java (1 line):
	- line 2051: * Print the TODO subscribe info


inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java (1 line):
	- line 395: // TODO Load balancing needs to be considered.


inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentManager.java (1 line):
	- line 157: // TODO: change job state which is in running state.


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/source/fetch/PostgresScanFetchTask.java (1 line):
	- line 134: // lk_test TODO maybe has bug


inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/CsvDeserializationInfo.java (1 line):
	- line 55: // TODO: support mapping index to field


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/StarRocksDynamicSinkFunction.java (1 line):
	- line 228: // TODO: add ddl to queue


inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/source/utils/PgSchema.java (1 line):
	- line 88: // TODO: check whether we always set isFromSnapshot = true


inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkOperation.java (1 line):
	- line 231: // TODO Temporarily remove this method. The method of checking node needs to be modified.