Skip to content

Commit d0c0ca1

Browse files
authored
Tweak the ECS fields in DeprecatedMessage (#62855)
Follow-up to #61484.
1 parent 4c23fad commit d0c0ca1

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

qa/logging-config/src/test/java/org/elasticsearch/common/logging/JsonLoggerTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -107,8 +107,8 @@ public void testDeprecatedMessageWithoutXOpaqueId() throws IOException {
107107
hasEntry("node.name", "sample-name"),
108108
hasEntry("message", "deprecated message1"),
109109
hasEntry("data_stream.type", "logs"),
110-
hasEntry("data_stream.datatype", "deprecation"),
111-
hasEntry("data_stream.namespace", "elasticsearch"),
110+
hasEntry("data_stream.dataset", "deprecation.elasticsearch"),
111+
hasEntry("data_stream.namespace", "default"),
112112
hasEntry("ecs.version", DeprecatedMessage.ECS_VERSION),
113113
hasEntry("key", "a key"),
114114
not(hasKey("x-opaque-id"))
@@ -145,8 +145,8 @@ public void testDeprecatedMessage() throws Exception {
145145
hasEntry("node.name", "sample-name"),
146146
hasEntry("message", "deprecated message1"),
147147
hasEntry("data_stream.type", "logs"),
148-
hasEntry("data_stream.datatype", "deprecation"),
149-
hasEntry("data_stream.namespace", "elasticsearch"),
148+
hasEntry("data_stream.dataset", "deprecation.elasticsearch"),
149+
hasEntry("data_stream.namespace", "default"),
150150
hasEntry("ecs.version", DeprecatedMessage.ECS_VERSION),
151151
hasEntry("key", "someKey"),
152152
hasEntry("x-opaque-id", "someId")

server/src/main/java/org/elasticsearch/common/logging/DeprecatedMessage.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@ public class DeprecatedMessage {
3434
public static ESLogMessage of(String key, String xOpaqueId, String messagePattern, Object... args) {
3535
ESLogMessage esLogMessage = new ESLogMessage(messagePattern, args)
3636
.field("data_stream.type", "logs")
37-
.field("data_stream.datatype", "deprecation")
38-
.field("data_stream.namespace", "elasticsearch")
37+
.field("data_stream.dataset", "deprecation.elasticsearch")
38+
.field("data_stream.namespace", "default")
3939
.field("ecs.version", ECS_VERSION)
4040
.field("key", key);
4141

x-pack/plugin/deprecation/qa/rest/src/javaRestTest/java/org/elasticsearch/xpack/deprecation/DeprecationHttpIT.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -275,8 +275,8 @@ public void testDeprecationMessagesCanBeIndexed() throws Exception {
275275
hasKey("cluster.name"),
276276
hasKey("cluster.uuid"),
277277
hasKey("log.logger"),
278-
hasEntry("data_stream.datatype", "deprecation"),
279-
hasEntry("data_stream.namespace", "elasticsearch"),
278+
hasEntry("data_stream.dataset", "deprecation.elasticsearch"),
279+
hasEntry("data_stream.namespace", "default"),
280280
hasEntry("data_stream.type", "logs"),
281281
hasEntry("ecs.version", "1.6"),
282282
hasEntry("key", "deprecated_settings"),
@@ -291,8 +291,8 @@ public void testDeprecationMessagesCanBeIndexed() throws Exception {
291291
hasKey("cluster.name"),
292292
hasKey("cluster.uuid"),
293293
hasKey("log.logger"),
294-
hasEntry("data_stream.datatype", "deprecation"),
295-
hasEntry("data_stream.namespace", "elasticsearch"),
294+
hasEntry("data_stream.dataset", "deprecation.elasticsearch"),
295+
hasEntry("data_stream.namespace", "default"),
296296
hasEntry("data_stream.type", "logs"),
297297
hasEntry("ecs.version", "1.6"),
298298
hasEntry("key", "deprecated_route"),

0 commit comments

Comments
 (0)