data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineParser.java (4 lines): - line 47: private final Map sourceConnectorMap = new HashMap<>(); //TODO Remove this and rely only on pipelineMap - line 156: //creation. except for running the creation again, it will not harm anything - TODO Fix this - line 177: sourceConnectorMap.put(pipelineName, pipelineConnector); //TODO retrieve from parent Pipeline using name - line 195: * TODO Update this to be more elegant and trigger destroy of plugins data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/HTTPSource.java (3 lines): - line 82: // TODO: enable encrypted key with password - line 107: // TODO: allow customization on URI path for log ingestion - line 111: // TODO: attach HealthCheckService data-prepper-plugins/service-map-stateful/src/main/java/com/amazon/dataprepper/plugins/prepper/ServiceMapStatefulPrepper.java (3 lines): - line 48: // TODO: This should not be tracked in this class, move it up to the creator - line 58: //TODO: Consider keeping this state in a db - line 285: // TODO: Temp code, complex instance creation logic should be moved to a separate class data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexConstants.java (3 lines): - line 16: // TODO: extract out version number into version enum - line 24: // TODO: extract out version number into version enum - line 28: // TODO: extract out version number into version enum data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerClientPool.java (3 lines): - line 36: // TODO: remove singleton now that port is configurable - line 57: // TODO: Resolve to IP first, or is hostname good enough? - line 62: // TODO: replace hardcoded port with customization data-prepper-api/src/main/java/com/amazon/dataprepper/model/record/Record.java (2 lines): - line 12: * TODO: The current implementation focuses on proving the bare bones for which this class only need to - line 13: * TODO: support sample test cases. data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/ProcessWorker.java (2 lines): - line 51: //TODO Hacky way to avoid logging continuously - Will be removed as part of metrics implementation - line 91: * TODO Add isolator pattern - Fail if one of the Sink fails [isolator Pattern] data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineConfigurationValidator.java (2 lines): - line 48: //validateForOrphans(orderedPipelineNames, pipelineConfigurationMap); //TODO: Should we disable orphan pipelines ? - line 131: * TODO: Should this be removed? (unused code) research/zipkin-opensearch-to-otel/src/main/java/com/amazon/dataprepper/research/zipkin/ZipkinOpenSearchToOtelPrepper.java (2 lines): - line 59: // TODO: read span status from tags - line 141: // TODO: add library name and version data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/certificate/model/Certificate.java (1 line): - line 10: // TODO: accommodate encrypted private key with password data-prepper-plugins/mapdb-prepper-state/src/main/java/com/amazon/dataprepper/plugins/prepper/state/MapDbPrepperState.java (1 line): - line 40: // TODO: Cleanup references to file-based map data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/LogThrottlingStrategy.java (1 line): - line 30: * TODO: data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/Pipeline.java (1 line): - line 87: // TODO: allow this to be configurable as well? data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IsmPolicyManagement.java (1 line): - line 38: // TODO: replace with new _opensearch API data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/LogHTTPService.java (1 line): - line 42: // TODO: support other data-types as request body, e.g. json_lines, msgpack data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/index/IndexManager.java (1 line): - line 194: // TODO: replace IOException with custom data-prepper exception e2e-test/trace/src/integrationTest/resources/raw-span-e2e-pipeline-latest-release.yml (1 line): - line 19: root_span_flush_delay: 3 # TODO: remove after 1.1 release data-prepper-plugins/otel-trace-group-prepper/src/main/java/com/amazon/dataprepper/plugins/prepper/oteltracegroup/OTelTraceGroupPrepper.java (1 line): - line 136: // TODO: retry for status code 429 of OpenSearchException? data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/codec/JsonCodec.java (1 line): - line 19: * TODO: replace output List<String> with List<InternalModel> type data-prepper-api/src/main/java/com/amazon/dataprepper/prepper/state/PrepperState.java (1 line): - line 67: // TODO: Potentially remove, this is file-specific data-prepper-core/src/main/java/com/amazon/dataprepper/plugin/DefaultPluginFactory.java (1 line): - line 50: // TODO: Remove this along with the removal of com.amazon.dataprepper.plugins.PluginFactory data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/sink/FileSink.java (1 line): - line 69: // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/OpenSearchSink.java (1 line): - line 147: // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 data-prepper-plugins/peer-forwarder/src/main/java/com/amazon/dataprepper/plugins/prepper/peerforwarder/PeerForwarder.java (1 line): - line 224: //TODO: cleanup resources data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/PluginRepository.java (1 line): - line 25: * TODO Add capability to discover custom new plugins data-prepper-core/src/main/java/com/amazon/dataprepper/DataPrepper.java (1 line): - line 36: // TODO: Remove DataPrepperServer dependency on DataPrepper e2e-test/trace/src/integrationTest/java/com/amazon/dataprepper/integration/trace/EndToEndRawSpanTest.java (1 line): - line 132: * TODO: Can we do better? data-prepper-core/src/main/java/com/amazon/dataprepper/pipeline/PipelineConnector.java (1 line): - line 78: //TODO: Cleanup resources data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java (1 line): - line 64: // TODO: replace with custom backoff policy setting including maximum interval between retries data-prepper-plugins/opensearch/src/main/java/com/amazon/dataprepper/plugins/sink/opensearch/OpenSearchSinkConfiguration.java (1 line): - line 15: * TODO: add retryConfiguration data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/sink/StdOutSink.java (1 line): - line 42: // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 data-prepper-plugins/common/src/main/java/com/amazon/dataprepper/plugins/source/file/FileSource.java (1 line): - line 107: // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 data-prepper-plugins/http-source/src/main/java/com/amazon/dataprepper/plugins/source/loghttp/certificate/CertificateProviderFactory.java (1 line): - line 23: // TODO: support more certificate providers e2e-test/trace/src/integrationTest/resources/raw-span-e2e-pipeline.yml (1 line): - line 14: root_span_flush_delay: 1 # TODO: remove after 1.1 release