v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java (8 lines):
	- line 40: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.
	- line 183: // TODO: implement logical type date and timestamp
	- line 265: // TODO: implement logical type date and timestamp
	- line 338: // TODO: implement logical date and datetime
	- line 370: // TODO: implement logical datetime
	- line 373: // TODO: implement logical date
	- line 414: // TODO: implement logical datetime
	- line 419: // TODO: implement logical date


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/PostgreSQLMappingProvider.java (7 lines):
	- line 41: // TODO: Refine mapping type according to
	- line 45: // TODO: Refine mapping type according to
	- line 49: // TODO: Refine mapping type according to
	- line 55: // TODO: Refine mapping type according to
	- line 70: // TODO: Refine mapping type according to
	- line 82: // TODO: Refine mapping type according to
	- line 92: // TODO: Refine mapping type according to


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java (6 lines):
	- line 471: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?
	- line 473: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?
	- line 528: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?
	- line 530: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?
	- line 581: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?
	- line 583: return StandardSQLTypeName.TIMESTAMP; // TODO: what type do we want here?


v1/src/main/java/com/google/cloud/teleport/templates/common/SubprocessTextTransformer.java (4 lines):
	- line 151: /** Factory method for making a new Invocable. TODO: REPLACE WITH PROCESSBUILDER */
	- line 168: // Sleep to create queues TODO use exponential backoff
	- line 258: // runtime.waitFor(2L, TimeUnit.SECONDS); // TODO need to discover if I need this, I think I
	- line 410: // TODO: Handle the lack of Python Mapper runtime


v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java (4 lines):
	- line 214: // Sleep to create queues TODO use exponential backoff
	- line 464: // TODO: createFile function
	- line 481: // TODO: add a counter of sum of total bytes
	- line 491: // TODO: create an execute batch fn


v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/InputRecordProcessor.java (3 lines):
	- line 109: // TODO we need to handle it as proper Interface Level as of now we have handle Prepared
	- line 110: // TODO Statement and Raw Statement Differently
	- line 112: * TODO:


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSpanner.java (3 lines):
	- line 599: // TODO: use getPostgresSourceConfig() instead of an else once SourceConfig.java is updated.
	- line 671: // TODO: spannerConfig = SpannerServiceFactoryImpl.createSpannerService(spannerConfig,
	- line 860: // TODO: Write errors from transformer and spanner writer into separate folders


it/splunk/src/main/java/org/apache/beam/it/splunk/CustomSplunkResourceManager.java (3 lines):
	- line 64: * <p>TODO - Remove when Beam 2.55 is released - https://github.com/apache/beam/pull/30200
	- line 118: // TODO - add support for https scheme
	- line 158: // TODO - add support for ssl


v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryDynamicConverters.java (3 lines):
	- line 111: // TODO: how should I know to remove these?  Maybe leave them?
	- line 146: // TODO String.format("%s:%s.%s", projectId.get(), datasetName.get(), key) if project id is
	- line 163: // Why do we use checkHeaderName here and not elsewhere, TODO if we add this back in


v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java (3 lines):
	- line 100: // TODO: convey all the information
	- line 101: "The manifest file, encoded in ASCII or UTF-8, must match the following format: ... TODO ..."
	- line 316: // TODO: remove NestedValueProvider when this is fixed in Beam.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/DeadLetterQueue.java (3 lines):
	- line 162: // TODO - add the exception message
	- line 211: // TODO - add the exception message
	- line 212: // TODO - Explore windowing with CoGroupByKey to extract source row based on mutation


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java (3 lines):
	- line 42: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.
	- line 151: // TODO: Implement logical date and datetime
	- line 229: // TODO: Implement logical date and datetime


v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java (3 lines):
	- line 1007: // TODO: Remove after models are supported in POSTGRESQL.
	- line 1453: // TODO: Remove after change streams are supported in POSTGRESQL.
	- line 1797: // TODO: Remove after placements are supported in POSTGRESQL.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFn.java (2 lines):
	- line 97: // TODO: update namespace in constructor when Spanner namespace support is added.
	- line 114: // TODO: Move the mutation generation to writer. Create generic record here instead


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/defaults/MySqlConfigDefaults.java (2 lines):
	- line 31: // TODO: Fine-tune the defaults based on benchmarking.
	- line 95: // TODO: Add innodb_parallel_read_threads for better performance tuning.


v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java (2 lines):
	- line 218: // TODO: verify if direct to object (Current) works the same as Object -> JsonNode-> Object
	- line 659: // TODO: For MySQL, we ignore the months field. This might require source-specific handling


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java (2 lines):
	- line 434: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.
	- line 944: // TODO: validate query?


v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java (2 lines):
	- line 357: // TODO: Add error.
	- line 623: // TODO: Logging every exception might overload Google Cloud Logging API. Find a better way to


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java (2 lines):
	- line 83: // TODO - Change Cloud Spanner nomenclature in code used to read DDL.
	- line 244: // TODO: pass shadow table ddl to shdaow tble mutaiton generator and sequence reader.


v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapper.java (2 lines):
	- line 98: /* TODO refactor this to avoid redundancy in Value.Foo and Value.FooArray */
	- line 206: /* TODO Support for AvroArrays to PG */


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java (2 lines):
	- line 49: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.
	- line 118: // TODO: https://github.com/apache/beam/issues/20415 Come up with something to determine


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SerializableGenericRecord.java (2 lines):
	- line 83: // TODO: Check if reuse can help with performance.
	- line 99: // TODO: Check if reuse can help with performance.


v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java (2 lines):
	- line 146: // TODO: Modularize long function implementation using helpers
	- line 647: // TODO: maybe encapsulate in the Ddl library.


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ShadowTableReadUtils.java (2 lines):
	- line 32: // TODO: After beam release, use the latest client lib version which supports setting lock
	- line 37: // TODO: Handle json type as PKs.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/CreateTransactionFn.java (1 line):
	- line 26: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/StringDeadLetterQueueSanitizer.java (1 line):
	- line 24: // TODO: Jackson2 is adding \n chars into the JSON which is not desired


plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpec.java (1 line):
	- line 76: // TODO: what else can be validated here?


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaRetrievalException.java (1 line):
	- line 22: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilder.java (1 line):
	- line 111: username) // TODO - support taking username and password from url as well


v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubAvroToBigQuery.java (1 line):
	- line 156: // TODO: Remove this workaround when a fix for BEAM-12256 is


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/package-info.java (1 line):
	- line 24: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java (1 line):
	- line 35: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/DeadLetterQueueSanitizer.java (1 line):
	- line 26: // TODO when this is a flex template it could incorporate outputs with configurable dest?


v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java (1 line):
	- line 278: sqlTemplateValues.put("primary_key_names_sql", String.join(",", primaryKeys)); // TODO: quoted?


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamJsonToJson.java (1 line):
	- line 137: // TODO: consider validating the value is mysql or oracle


v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/AvroWriteTransform.java (1 line):
	- line 192: // TODO: Build destination based on the schema ID or something compact than schema


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/BatchSpannerRead.java (1 line):
	- line 55: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/MySqlDao.java (1 line):
	- line 92: // TODO: retry handling is configurable with retry count


v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java (1 line):
	- line 43: // TODO: Fetch forward migration Dataflow job id and do full string match for the tag.


plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/PromoteHelper.java (1 line):
	- line 138: // TODO: remove this once copy tag is supported by promote API


v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertor.java (1 line):
	- line 46: // TODO: Use formatter from FormatDatastreamRecordToJson


v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java (1 line):
	- line 71: // TODO: merge with BigtableCommon options after CDC GA


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteSchemaTransformProvider.java (1 line):
	- line 70: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java (1 line):
	- line 184: // TODO - create a structure for the shard config and map directly to the object


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java (1 line):
	- line 32: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesRunMojo.java (1 line):
	- line 195: // TODO: is there a better way to get the plugin on the _same project_?


v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java (1 line):
	- line 315: // TODO: make the tests below match Spanner's SQL literal rules wherever possible,


v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java (1 line):
	- line 270: // TODO make SpannerAccessor serializable


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/ChangeEventTransformerDoFn.java (1 line):
	- line 183: // TODO: Transformation via session file should be marked deprecated and removed.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerConfig.java (1 line):
	- line 40: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java (1 line):
	- line 93: // TODO: After beam release, use the latest client lib version which supports setting lock


v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertor.java (1 line):
	- line 34: // TODO : check if we can use a common ChangeEventTypeConvertor for this.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SourceDbToSpanner.java (1 line):
	- line 95: // TODO - Validate if options are as expected


v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/JsonWriteTransform.java (1 line):
	- line 76: // TODO: Add DLQ support.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/OrderedCode.java (1 line):
	- line 44: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java (1 line):
	- line 157: // TODO: make the tests below match Spanner's SQL literal rules wherever possible,


it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java (1 line):
	- line 258: // TODO: determine elapsed time more accurately if Direct runner supports do so.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTableSourceDef.java (1 line):
	- line 28: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationGroup.java (1 line):
	- line 33: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java (1 line):
	- line 255: // TODO: remove NestedValueProvider when this is fixed in Beam.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java (1 line):
	- line 312: // TODO:


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJson.java (1 line):
	- line 206: // TODO: consider validating the value is mysql or oracle


v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapper.java (1 line):
	- line 54: // TODO: interpolate runtime tokens into new spec elements


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DmlInfo.java (1 line):
	- line 29: // TODO just failsafe value and all cleaning when creating the object?


v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumSourceRecordToDataflowCdcFormatTranslator.java (1 line):
	- line 62: // TODO: Consider including before value in the Row.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadOperation.java (1 line):
	- line 34: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/BigQueryDeadLetterQueueSanitizer.java (1 line):
	- line 26: // TODO: Jackson2 is adding \n chars into the JSON which is not desired


v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgres.java (1 line):
	- line 45: * <p>Example Usage: TODO: FIX EXAMPLE USAGE


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchema.java (1 line):
	- line 147: // TODO: Add pgsql support/ cross dialect support.


v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java (1 line):
	- line 121: // TODO:b/322630434 Consider updating the schema only for one table at a time.


v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQueryAuto.java (1 line):
	- line 38: // TODO: replace the original template when we are ready to do it, and remove `hidden`.


v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexCompression.java (1 line):
	- line 36: // TODO: Update Dataplex compression name once Snappy is supported.


v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToMongoDB.java (1 line):
	- line 49: * <p>Example Usage: TODO: FIX EXAMPLE USAGE


v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ForeignKey.java (1 line):
	- line 142: // TODO: Add Postgresql support for NOT ENFORCED foreign keys


plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java (1 line):
	- line 186: // TODO: is there a better way to get the plugin on the _same project_?


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/Transaction.java (1 line):
	- line 27: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/GuardedStringValueProvider.java (1 line):
	- line 71: // TODO: wok on an encrypted version of this.


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeConfiguration.java (1 line):
	- line 52: + " DELETE ", // TODO entire block should be configurably removed


v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/WriteTransform.java (1 line):
	- line 50: // TODO: Add support for adding DLQ for JSON deserializers.


v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java (1 line):
	- line 43: // TODO: Fetch forward migration Dataflow job id and do full string match for the tag.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java (1 line):
	- line 45: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


it/google-cloud-platform/src/main/java/org/apache/beam/it/jdbc/StaticJDBCResource.java (1 line):
	- line 67: // TODO: exclude the StaticJDBCResource files from the codecov checks


v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForLiveIT.java (1 line):
	- line 36: // TODO: Rename the class since its being used in both Live and Reverse replication tests and in


plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java (1 line):
	- line 509: // TODO: Check if the same should be applied to Python templates:


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java (1 line):
	- line 46: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadSpannerSchema.java (1 line):
	- line 33: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java (1 line):
	- line 431: // TODO: Cover tableRowRecords.get(TRANSFORM_DEADLETTER_OUT) error values


v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java (1 line):
	- line 222: // TODO: remove NestedValueProvider when this is fixed in Beam.


v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/JarFileReader.java (1 line):
	- line 35: /** TODO: rename this to FileReader. */


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequence.java (1 line):
	- line 116: // TODO: After beam release, use the latest client lib version which supports setting lock


v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java (1 line):
	- line 229: // TODO: uses row.getNumeric() once teleport uses new spanner library.


v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAuto.java (1 line):
	- line 37: // TODO: replace the original template when we are ready to do it, and remove `hidden`.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java (1 line):
	- line 58: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java (1 line):
	- line 863: // TODO: use AvroUtils.serializableSchemaSupplier once it is public


v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryTableToGcsTransform.java (1 line):
	- line 216: // TODO: Switch to DIRECT_READ when the BigQueryIO bug is fixed.


v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java (1 line):
	- line 135: // TODO: add a step to check that schema in the manifest match db schema.


v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/io/CdcJdbcIO.java (1 line):
	- line 541: // TODO: How should we handle failures?


v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JsonStringToMutationFn.java (1 line):
	- line 81: // TODO: make the tests below match Spanner's SQL literal rules wherever possible,


it/splunk/src/main/java/org/apache/beam/it/splunk/conditions/CustomSplunkEventsCheck.java (1 line):
	- line 28: * <p>TODO - Remove when Beam 2.55 is released - https://github.com/apache/beam/pull/30200


v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java (1 line):
	- line 437: // TODO: handle nested fields (types "RECORD" or "STRUCT")


v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicConverters.java (1 line):
	- line 149: // Why do we use checkHeaderName here and not elsewhere, TODO if we add this back in


v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequence.java (1 line):
	- line 93: // TODO: After beam release, use the latest client lib version which supports setting lock


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/package-info.java (1 line):
	- line 25: * corresponding changes are made in Apache Beam to prevent code divergence. TODO: (b/402322178)


v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryDynamicConverters.java (1 line):
	- line 150: // Why do we use checkHeaderName here and not elsewhere, TODO if we add this back in


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationCellCounter.java (1 line):
	- line 27: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtils.java (1 line):
	- line 275: changelogEntry.setLowWatermark(0); // TODO: Low watermark is not available yet


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/PubSubDeadLetterQueueSanitizer.java (1 line):
	- line 25: // TODO: Jackson2 is adding \n chars into the JSON which is not desired


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteResult.java (1 line):
	- line 41: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/FileBasedDeadLetterQueueReconsumer.java (1 line):
	- line 87: // TODO: Paths resolve converts "gs://bucket/.." to "gs:/bucket/.."


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java (1 line):
	- line 52: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerQuerySourceDef.java (1 line):
	- line 27: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicDestination.java (1 line):
	- line 76: // TODO: Test if sending null can work here, might be more efficient.


v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java (1 line):
	- line 50: // TODO: Remove KafkaRecord and support KV.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSourceDef.java (1 line):
	- line 26: * Beam to prevent code divergence. TODO: (b/402322178) Remove this local copy.


v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/QueryChangeStreamAction.java (1 line):
	- line 174: // TODO: Potentially we can avoid this fetch, by enriching the runningAt timestamp when the


v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToBigQueryOptions.java (1 line):
	- line 239: // TODO: remove the "Not used for partitioned reads" once


v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryMapper.java (1 line):
	- line 122: // TODO: A supplier that reloads the GCS file regularly would allow


v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java (1 line):
	- line 70: /** TODO - refactor to extend BigtableCommonOptions.WriteOptions. */