Skip to content
Merged
Show file tree
Hide file tree
Changes from 11 commits
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
import datadog.trace.api.CorrelationIdentifier;
import datadog.trace.api.DDSpanId;
import datadog.trace.api.DDTraceId;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.bootstrap.InstrumentationContext;
import datadog.trace.bootstrap.instrumentation.api.AgentSpanContext;
import datadog.trace.bootstrap.instrumentation.api.AgentTracer;
Expand Down Expand Up @@ -113,8 +112,7 @@ public static void getMdcValue(
case "dd.trace_id":
if (context != null) {
DDTraceId traceId = context.getTraceId();
if (traceId.toHighOrderLong() != 0
&& InstrumenterConfig.get().isLogs128bTraceIdEnabled()) {
if (traceId.toHighOrderLong() != 0 && Config.get().isLogs128bTraceIdEnabled()) {
value = traceId.toHexString();
} else {
value = traceId.toString();
Expand Down Expand Up @@ -155,7 +153,7 @@ public static void onExit(
if (context != null) {
DDTraceId traceId = context.getTraceId();
String traceIdValue =
InstrumenterConfig.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
Config.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
? traceId.toHexString()
: traceId.toString();
correlationValues.put(CorrelationIdentifier.getTraceIdKey(), traceIdValue);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
import datadog.trace.api.CorrelationIdentifier;
import datadog.trace.api.DDSpanId;
import datadog.trace.api.DDTraceId;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.bootstrap.instrumentation.api.AgentSpan;
import datadog.trace.bootstrap.instrumentation.api.Tags;
import java.util.List;
Expand Down Expand Up @@ -57,7 +56,7 @@ public StringMap injectContextData(List<Property> list, StringMap reusable) {
if (span != null) {
DDTraceId traceId = span.context().getTraceId();
String traceIdValue =
InstrumenterConfig.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
Config.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
? traceId.toHexString()
: traceId.toString();
newContextData.putValue(CorrelationIdentifier.getTraceIdKey(), traceIdValue);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
import datadog.trace.api.CorrelationIdentifier;
import datadog.trace.api.DDSpanId;
import datadog.trace.api.DDTraceId;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.bootstrap.InstrumentationContext;
import datadog.trace.bootstrap.instrumentation.api.AgentSpanContext;
import datadog.trace.bootstrap.instrumentation.api.AgentTracer;
Expand Down Expand Up @@ -95,8 +94,7 @@ public static void getMdcValue(
case "dd.trace_id":
if (context != null) {
DDTraceId traceId = context.getTraceId();
if (traceId.toHighOrderLong() != 0
&& InstrumenterConfig.get().isLogs128bTraceIdEnabled()) {
if (traceId.toHighOrderLong() != 0 && Config.get().isLogs128bTraceIdEnabled()) {
value = traceId.toHexString();
} else {
value = traceId.toString();
Expand Down Expand Up @@ -157,7 +155,7 @@ public static void onExit(
if (context != null) {
DDTraceId traceId = context.getTraceId();
String traceIdValue =
InstrumenterConfig.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
Config.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
? traceId.toHexString()
: traceId.toString();
mdc.put(CorrelationIdentifier.getTraceIdKey(), traceIdValue);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
import datadog.trace.api.CorrelationIdentifier;
import datadog.trace.api.DDSpanId;
import datadog.trace.api.DDTraceId;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.bootstrap.InstrumentationContext;
import datadog.trace.bootstrap.instrumentation.api.AgentSpanContext;
import datadog.trace.bootstrap.instrumentation.api.AgentTracer;
Expand Down Expand Up @@ -90,7 +89,7 @@ public static void onExit(
if (context != null) {
DDTraceId traceId = context.getTraceId();
String traceIdValue =
InstrumenterConfig.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
Config.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
? traceId.toHexString()
: traceId.toString();
correlationValues.put(CorrelationIdentifier.getTraceIdKey(), traceIdValue);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
import datadog.trace.api.CorrelationIdentifier;
import datadog.trace.api.DDSpanId;
import datadog.trace.api.DDTraceId;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.bootstrap.InstrumentationContext;
import datadog.trace.bootstrap.instrumentation.api.AgentSpanContext;
import datadog.trace.bootstrap.instrumentation.api.AgentTracer;
Expand Down Expand Up @@ -83,7 +82,7 @@ public static void onExit(
if (context != null) {
DDTraceId traceId = context.getTraceId();
String traceIdValue =
InstrumenterConfig.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
Config.get().isLogs128bTraceIdEnabled() && traceId.toHighOrderLong() != 0
? traceId.toHexString()
: traceId.toString();
correlationValues.put(CorrelationIdentifier.getTraceIdKey(), traceIdValue);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,10 @@ abstract class LogContextInjectionTestBase extends AgentTestRunner {

abstract Map<String, Object> getMap()

def setup() {
injectSysConfig("logs.injection.enabled", "true")
Copy link
Contributor

@mcculls mcculls Mar 11, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this should already be the default? https://github.com/DataDog/dd-trace-java/blob/master/dd-trace-api/src/main/java/datadog/trace/api/ConfigDefaults.java#L105

never mind - I see the default is being changed below

this will be a breaking change for a lot of customers, is there a plan to mitigate this?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, I can add it under the DD_TRACE_EXPERIMENTAL_FEATURES_ENABLED flag.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This change could be dropped, now we're only changing the default when enabling breaking changes

}

def "Log context shows trace and span ids for active scope"() {
when:
put("foo", "bar")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ abstract class LogInjectionSmokeTest extends AbstractSmokeTest {
boolean noTags = false

@Shared
boolean trace128bits = false
boolean trace128bits = true

@Shared
@AutoCleanup
Expand Down Expand Up @@ -86,9 +86,9 @@ abstract class LogInjectionSmokeTest extends AbstractSmokeTest {
command.add("-Ddd.version=" as String)
command.add("-Ddd.service.name=" as String)
}
if (trace128bits) {
command.add("-Ddd.$TRACE_128_BIT_TRACEID_GENERATION_ENABLED=true" as String)
command.add("-Ddd.$TRACE_128_BIT_TRACEID_LOGGING_ENABLED=true" as String)
if (!trace128bits) {
command.add("-Ddd.$TRACE_128_BIT_TRACEID_GENERATION_ENABLED=false" as String)
command.add("-Ddd.$TRACE_128_BIT_TRACEID_LOGGING_ENABLED=false" as String)
}
if (supportsDirectLogSubmission()) {
command.add("-Ddd.$GeneralConfig.AGENTLESS_LOG_SUBMISSION_ENABLED=true" as String)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -179,6 +179,7 @@ abstract class AbstractSmokeTest extends ProcessManager {
"-Ddd.trace.agent.port=${server.address.port}",
"-Ddd.env=${ENV}",
"-Ddd.version=${VERSION}",
"-Ddd.logs.injection=true",
"-Ddd.profiling.enabled=true",
"-Ddd.profiling.start-delay=${PROFILING_START_DELAY_SECONDS}",
"-Ddd.profiling.upload.period=${PROFILING_RECORDING_UPLOAD_PERIOD_SECONDS}",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ public final class ConfigDefaults {
static final boolean DEFAULT_PERF_METRICS_ENABLED = false;
// No default constants for metrics statsd support -- falls back to jmxfetch values

static final boolean DEFAULT_LOGS_INJECTION_ENABLED = true;
static final boolean DEFAULT_LOGS_INJECTION_ENABLED = false;

static final String DEFAULT_APPSEC_ENABLED = "inactive";
static final boolean DEFAULT_APPSEC_REPORTING_INBAND = false;
Expand Down Expand Up @@ -233,7 +233,7 @@ public final class ConfigDefaults {
static final int DEFAULT_TELEMETRY_DEPENDENCY_RESOLUTION_QUEUE_SIZE = 100000;

static final boolean DEFAULT_TRACE_128_BIT_TRACEID_GENERATION_ENABLED = true;
static final boolean DEFAULT_TRACE_128_BIT_TRACEID_LOGGING_ENABLED = false;
static final boolean DEFAULT_TRACE_128_BIT_TRACEID_LOGGING_ENABLED = true;
static final boolean DEFAULT_SECURE_RANDOM = false;

public static final int DEFAULT_TRACE_X_DATADOG_TAGS_MAX_LENGTH = 512;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,9 @@ public final class TracerConfig {
@Deprecated public static final String TRACE_RESOLVER_ENABLED = "trace.resolver.enabled";
public static final String SERVICE_MAPPING = "service.mapping";

public static final String TRACE_EXPERIMENTAL_FEATURES_ENABLED =
"trace.experimental.features.enabled";

public static final String SPAN_TAGS = "trace.span.tags";
public static final String TRACE_ANALYTICS_ENABLED = "trace.analytics.enabled";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import datadog.trace.api.DynamicConfig;
import datadog.trace.api.EndpointTracker;
import datadog.trace.api.IdGenerationStrategy;
import datadog.trace.api.InstrumenterConfig;
import datadog.trace.api.StatsDClient;
import datadog.trace.api.TraceConfig;
import datadog.trace.api.config.GeneralConfig;
Expand Down Expand Up @@ -607,7 +606,7 @@ private CoreTracer(
.setTracingTags(config.getMergedSpanTags())
.apply();

this.logs128bTraceIdEnabled = InstrumenterConfig.get().isLogs128bTraceIdEnabled();
this.logs128bTraceIdEnabled = Config.get().isLogs128bTraceIdEnabled();
this.partialFlushMinSpans = partialFlushMinSpans;
this.idGenerationStrategy =
null == idGenerationStrategy
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ abstract class CorrelationIdInjectorTest extends DDSpecification {

def "test correlation id injection"() {
setup:
injectSysConfig("logs.injection.enabled", "true")
def tracer = buildTracer()
def journal = buildJournal()
def logger = buildLogger()
Expand Down
22 changes: 22 additions & 0 deletions internal-api/src/main/java/datadog/trace/api/Config.java
Original file line number Diff line number Diff line change
Expand Up @@ -483,6 +483,7 @@ public static String getHostName() {
private final boolean secureRandom;

private final boolean trace128bitTraceIdGenerationEnabled;
private final boolean logs128bTraceIdEnabled;

private final Set<String> grpcIgnoredInboundMethods;
private final Set<String> grpcIgnoredOutboundMethods;
Expand Down Expand Up @@ -559,6 +560,7 @@ public static String getHostName() {
private final long dependecyResolutionPeriodMillis;

private final boolean apmTracingEnabled;
private final Set<String> experimentalFeaturesEnabled;

// Read order: System Properties -> Env Variables, [-> properties file], [-> default value]
private Config() {
Expand Down Expand Up @@ -624,6 +626,9 @@ private Config(final ConfigProvider configProvider, final InstrumenterConfig ins
configProvider.getString(
SERVLET_ROOT_CONTEXT_SERVICE_NAME, DEFAULT_SERVLET_ROOT_CONTEXT_SERVICE_NAME);

experimentalFeaturesEnabled =
configProvider.getSet(TRACE_EXPERIMENTAL_FEATURES_ENABLED, new HashSet<>());

integrationSynapseLegacyOperationName =
configProvider.getBoolean(INTEGRATION_SYNAPSE_LEGACY_OPERATION_NAME, false);
writerType = configProvider.getString(WRITER_TYPE, DEFAULT_AGENT_WRITER_TYPE);
Expand Down Expand Up @@ -655,6 +660,11 @@ private Config(final ConfigProvider configProvider, final InstrumenterConfig ins
configProvider.getBoolean(
TRACE_128_BIT_TRACEID_GENERATION_ENABLED,
DEFAULT_TRACE_128_BIT_TRACEID_GENERATION_ENABLED);

logs128bTraceIdEnabled =
configProvider.getBoolean(
TRACE_128_BIT_TRACEID_LOGGING_ENABLED, DEFAULT_TRACE_128_BIT_TRACEID_LOGGING_ENABLED);

if (secureRandom) {
strategyName = "SECURE_RANDOM";
}
Expand Down Expand Up @@ -2002,6 +2012,10 @@ public String getRootContextServiceName() {
return rootContextServiceName;
}

public Set<String> getExperimentalFeaturesEnabled() {
return experimentalFeaturesEnabled;
}

public boolean isTraceEnabled() {
return instrumenterConfig.isTraceEnabled();
}
Expand Down Expand Up @@ -3430,6 +3444,10 @@ public boolean isTrace128bitTraceIdGenerationEnabled() {
return trace128bitTraceIdGenerationEnabled;
}

public boolean isLogs128bTraceIdEnabled() {
return logs128bTraceIdEnabled;
}

public Set<String> getGrpcIgnoredInboundMethods() {
return grpcIgnoredInboundMethods;
}
Expand Down Expand Up @@ -4344,6 +4362,8 @@ public String toString() {
+ serviceNameSetByUser
+ ", rootContextServiceName="
+ rootContextServiceName
+ ", experimentalFeaturesEnabled="
+ experimentalFeaturesEnabled
+ ", integrationSynapseLegacyOperationName="
+ integrationSynapseLegacyOperationName
+ ", writerType='"
Expand Down Expand Up @@ -4662,6 +4682,8 @@ public String toString() {
+ idGenerationStrategy
+ ", trace128bitTraceIdGenerationEnabled="
+ trace128bitTraceIdGenerationEnabled
+ ", logs128bTraceIdEnabled="
+ logs128bTraceIdEnabled
+ ", grpcIgnoredInboundMethods="
+ grpcIgnoredInboundMethods
+ ", grpcIgnoredOutboundMethods="
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
import static datadog.trace.api.ConfigDefaults.DEFAULT_RUNTIME_CONTEXT_FIELD_INJECTION;
import static datadog.trace.api.ConfigDefaults.DEFAULT_SERIALVERSIONUID_FIELD_INJECTION;
import static datadog.trace.api.ConfigDefaults.DEFAULT_TELEMETRY_ENABLED;
import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_128_BIT_TRACEID_LOGGING_ENABLED;
import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_ANNOTATIONS;
import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_ANNOTATION_ASYNC;
import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_ENABLED;
Expand Down Expand Up @@ -51,7 +50,6 @@
import static datadog.trace.api.config.TraceInstrumentationConfig.RESOLVER_USE_URL_CACHES;
import static datadog.trace.api.config.TraceInstrumentationConfig.RUNTIME_CONTEXT_FIELD_INJECTION;
import static datadog.trace.api.config.TraceInstrumentationConfig.SERIALVERSIONUID_FIELD_INJECTION;
import static datadog.trace.api.config.TraceInstrumentationConfig.TRACE_128_BIT_TRACEID_LOGGING_ENABLED;
import static datadog.trace.api.config.TraceInstrumentationConfig.TRACE_ANNOTATIONS;
import static datadog.trace.api.config.TraceInstrumentationConfig.TRACE_ANNOTATION_ASYNC;
import static datadog.trace.api.config.TraceInstrumentationConfig.TRACE_CLASSES_EXCLUDE;
Expand Down Expand Up @@ -105,7 +103,6 @@ public class InstrumenterConfig {
private final boolean codeOriginEnabled;
private final boolean traceEnabled;
private final boolean traceOtelEnabled;
private final boolean logs128bTraceIdEnabled;
private final ProfilingEnablement profilingEnabled;
private final boolean ciVisibilityEnabled;
private final ProductActivation appSecActivation;
Expand Down Expand Up @@ -182,9 +179,7 @@ private InstrumenterConfig() {
CODE_ORIGIN_FOR_SPANS_ENABLED, DEFAULT_CODE_ORIGIN_FOR_SPANS_ENABLED);
traceEnabled = configProvider.getBoolean(TRACE_ENABLED, DEFAULT_TRACE_ENABLED);
traceOtelEnabled = configProvider.getBoolean(TRACE_OTEL_ENABLED, DEFAULT_TRACE_OTEL_ENABLED);
logs128bTraceIdEnabled =
configProvider.getBoolean(
TRACE_128_BIT_TRACEID_LOGGING_ENABLED, DEFAULT_TRACE_128_BIT_TRACEID_LOGGING_ENABLED);

profilingEnabled =
ProfilingEnablement.of(
configProvider.getString(PROFILING_ENABLED, String.valueOf(PROFILING_ENABLED_DEFAULT)));
Expand Down Expand Up @@ -336,10 +331,6 @@ public boolean isTraceOtelEnabled() {
return traceOtelEnabled;
}

public boolean isLogs128bTraceIdEnabled() {
return logs128bTraceIdEnabled;
}

public boolean isProfilingEnabled() {
return profilingEnabled.isActive();
}
Expand Down Expand Up @@ -557,8 +548,6 @@ public String toString() {
+ traceEnabled
+ ", traceOtelEnabled="
+ traceOtelEnabled
+ ", logs128bTraceIdEnabled="
+ logs128bTraceIdEnabled
+ ", profilingEnabled="
+ profilingEnabled
+ ", ciVisibilityEnabled="
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,7 @@ class ConfigCollectorTest extends DDSpecification {
"data.streams.enabled" | "false"
"trace.tags" | ""
"trace.header.tags" | ""
"logs.injection.enabled" | "true"
"logs.injection.enabled" | "false"
// defaults to null meaning sample everything but not exactly the same as when explicitly set to 1.0
"trace.sample.rate" | null
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -107,6 +107,7 @@ import static datadog.trace.api.config.TracerConfig.HTTP_CLIENT_ERROR_STATUSES
import static datadog.trace.api.config.TracerConfig.HTTP_SERVER_ERROR_STATUSES
import static datadog.trace.api.config.TracerConfig.ID_GENERATION_STRATEGY
import static datadog.trace.api.config.TracerConfig.PARTIAL_FLUSH_ENABLED
import static datadog.trace.api.config.TracerConfig.TRACE_EXPERIMENTAL_FEATURES_ENABLED
import static datadog.trace.api.config.TracerConfig.TRACE_LONG_RUNNING_ENABLED
import static datadog.trace.api.config.TracerConfig.TRACE_LONG_RUNNING_FLUSH_INTERVAL
import static datadog.trace.api.config.TracerConfig.TRACE_LONG_RUNNING_INITIAL_FLUSH_INTERVAL
Expand Down Expand Up @@ -221,6 +222,8 @@ class ConfigTest extends DDSpecification {
prop.setProperty(TRACE_LONG_RUNNING_ENABLED, "true")
prop.setProperty(TRACE_LONG_RUNNING_FLUSH_INTERVAL, "250")

prop.setProperty(TRACE_EXPERIMENTAL_FEATURES_ENABLED, "DD_TAGS, DD_TRACE_HTTP_CLIENT_TAG_QUERY_STRING")

prop.setProperty(PROFILING_ENABLED, "true")
prop.setProperty(PROFILING_URL, "new url")
prop.setProperty(PROFILING_TAGS, "f:6,host:test-host")
Expand Down Expand Up @@ -312,6 +315,8 @@ class ConfigTest extends DDSpecification {
config.isLongRunningTraceEnabled()
config.getLongRunningTraceFlushInterval() == 250

config.experimentalFeaturesEnabled == ["DD_TAGS", "DD_TRACE_HTTP_CLIENT_TAG_QUERY_STRING"].toSet()

config.profilingEnabled == true
config.profilingUrl == "new url"
config.mergedProfilingTags == [b: "2", f: "6", (HOST_TAG): "test-host", (RUNTIME_ID_TAG): config.getRuntimeId(), (RUNTIME_VERSION_TAG): config.getRuntimeVersion(), (SERVICE_TAG): config.serviceName, (LANGUAGE_TAG_KEY): LANGUAGE_TAG_VALUE]
Expand Down Expand Up @@ -402,6 +407,8 @@ class ConfigTest extends DDSpecification {
System.setProperty(PREFIX + TRACE_LONG_RUNNING_ENABLED, "true")
System.setProperty(PREFIX + TRACE_LONG_RUNNING_FLUSH_INTERVAL, "333")

System.setProperty(PREFIX + TRACE_EXPERIMENTAL_FEATURES_ENABLED, "DD_TAGS, DD_TRACE_HTTP_CLIENT_TAG_QUERY_STRING")

System.setProperty(PREFIX + PROFILING_ENABLED, "true")
System.setProperty(PREFIX + PROFILING_URL, "new url")
System.setProperty(PREFIX + PROFILING_TAGS, "f:6,host:test-host")
Expand Down Expand Up @@ -493,6 +500,8 @@ class ConfigTest extends DDSpecification {
config.getLongRunningTraceFlushInterval() == 333
config.traceRateLimit == 200

config.experimentalFeaturesEnabled == ["DD_TAGS", "DD_TRACE_HTTP_CLIENT_TAG_QUERY_STRING"].toSet()

config.profilingEnabled == true
config.profilingUrl == "new url"
config.mergedProfilingTags == [b: "2", f: "6", (HOST_TAG): "test-host", (RUNTIME_ID_TAG): config.getRuntimeId(), (RUNTIME_VERSION_TAG): config.getRuntimeVersion(), (SERVICE_TAG): config.serviceName, (LANGUAGE_TAG_KEY): LANGUAGE_TAG_VALUE]
Expand Down