未验证 提交 6942ec8f 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Language of instance could be NULL (#3485)

* Language of instance could be NULL

* Fix style check.

* Fix duplicated test cases.
上级 72f07b81
......@@ -18,8 +18,10 @@
package org.apache.skywalking.oap.server.core.query.entity;
import java.util.*;
import lombok.*;
import java.util.ArrayList;
import java.util.List;
import lombok.Getter;
import lombok.Setter;
/**
* @author peng-yongsheng
......@@ -29,7 +31,7 @@ public class ServiceInstance {
@Setter private String id;
@Setter private String name;
private final List<Attribute> attributes;
@Setter private Language language;
@Setter private Language language = Language.UNKNOWN;
public ServiceInstance() {
this.attributes = new ArrayList<>();
......
......@@ -29,7 +29,6 @@ import java.util.Map;
import org.apache.skywalking.oap.server.core.query.entity.Attribute;
import org.apache.skywalking.oap.server.core.query.entity.Database;
import org.apache.skywalking.oap.server.core.query.entity.Endpoint;
import org.apache.skywalking.oap.server.core.query.entity.Language;
import org.apache.skywalking.oap.server.core.query.entity.LanguageTrans;
import org.apache.skywalking.oap.server.core.query.entity.Service;
import org.apache.skywalking.oap.server.core.query.entity.ServiceInstance;
......@@ -255,28 +254,21 @@ public class MetadataQueryEsDAO extends EsDAO implements IMetadataQueryDAO {
String value = property.getValue().getAsString();
if (key.equals(LANGUAGE)) {
serviceInstance.setLanguage(LanguageTrans.INSTANCE.value(value));
}
if (key.equals(OS_NAME)) {
} else if (key.equals(OS_NAME)) {
serviceInstance.getAttributes().add(new Attribute(OS_NAME, value));
}
if (key.equals(HOST_NAME)) {
} else if (key.equals(HOST_NAME)) {
serviceInstance.getAttributes().add(new Attribute(HOST_NAME, value));
}
if (key.equals(PROCESS_NO)) {
} else if (key.equals(PROCESS_NO)) {
serviceInstance.getAttributes().add(new Attribute(PROCESS_NO, value));
}
if (key.equals(IPV4S)) {
} else if (key.equals(IPV4S)) {
List<String> ipv4s = ServiceInstanceInventory.PropertyUtil.ipv4sDeserialize(properties.get(IPV4S).getAsString());
for (String ipv4 : ipv4s) {
serviceInstance.getAttributes().add(new Attribute(ServiceInstanceInventory.PropertyUtil.IPV4S, ipv4));
}
} else {
serviceInstance.getAttributes().add(new Attribute(key, value));
}
serviceInstance.getAttributes().add(new Attribute(key, value));
}
} else {
serviceInstance.setLanguage(Language.UNKNOWN);
}
serviceInstances.add(serviceInstance);
......
......@@ -32,7 +32,6 @@ import java.util.Map;
import org.apache.skywalking.oap.server.core.query.entity.Attribute;
import org.apache.skywalking.oap.server.core.query.entity.Database;
import org.apache.skywalking.oap.server.core.query.entity.Endpoint;
import org.apache.skywalking.oap.server.core.query.entity.Language;
import org.apache.skywalking.oap.server.core.query.entity.LanguageTrans;
import org.apache.skywalking.oap.server.core.query.entity.Service;
import org.apache.skywalking.oap.server.core.query.entity.ServiceInstance;
......@@ -287,28 +286,21 @@ public class H2MetadataQueryDAO implements IMetadataQueryDAO {
String value = property.getValue().getAsString();
if (key.equals(LANGUAGE)) {
serviceInstance.setLanguage(LanguageTrans.INSTANCE.value(value));
}
if (key.equals(OS_NAME)) {
} else if (key.equals(OS_NAME)) {
serviceInstance.getAttributes().add(new Attribute(OS_NAME, value));
}
if (key.equals(HOST_NAME)) {
} else if (key.equals(HOST_NAME)) {
serviceInstance.getAttributes().add(new Attribute(HOST_NAME, value));
}
if (key.equals(PROCESS_NO)) {
} else if (key.equals(PROCESS_NO)) {
serviceInstance.getAttributes().add(new Attribute(PROCESS_NO, value));
}
if (key.equals(IPV4S)) {
} else if (key.equals(IPV4S)) {
List<String> ipv4s = ServiceInstanceInventory.PropertyUtil.ipv4sDeserialize(properties.get(IPV4S).getAsString());
for (String ipv4 : ipv4s) {
serviceInstance.getAttributes().add(new Attribute(ServiceInstanceInventory.PropertyUtil.IPV4S, ipv4));
}
} else {
serviceInstance.getAttributes().add(new Attribute(key, value));
}
serviceInstance.getAttributes().add(new Attribute(key, value));
}
} else {
serviceInstance.setLanguage(Language.UNKNOWN);
}
serviceInstances.add(serviceInstance);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册