yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-10-29 09:52:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(): use static yaml mapper es search service (#13016)

Browse Source
This commit is contained in:
david-leifker 2025-03-28 17:47:28 -05:00 committed by GitHub
parent a846f9d92d
commit fa80c8dbfe
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
metadata-service/factories/src/main/java/com/linkedin/gms/factory/search/ElasticSearchServiceFactory.java
View File

@ -2,9 +2,6 @@ package com.linkedin.gms.factory.search;
import static com.linkedin.metadata.Constants.*; import static com.linkedin.metadata.Constants.*;
import com.fasterxml.jackson.core.StreamReadConstraints;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.dataformat.yaml.YAMLMapper;
import com.linkedin.gms.factory.config.ConfigurationProvider; import com.linkedin.gms.factory.config.ConfigurationProvider;
import com.linkedin.gms.factory.entityregistry.EntityRegistryFactory; import com.linkedin.gms.factory.entityregistry.EntityRegistryFactory;
import com.linkedin.metadata.config.search.ElasticSearchConfiguration; import com.linkedin.metadata.config.search.ElasticSearchConfiguration;
@ -17,6 +14,7 @@ import com.linkedin.metadata.search.elasticsearch.query.ESBrowseDAO;
import com.linkedin.metadata.search.elasticsearch.query.ESSearchDAO; import com.linkedin.metadata.search.elasticsearch.query.ESSearchDAO;
import com.linkedin.metadata.search.elasticsearch.query.filter.QueryFilterRewriteChain; import com.linkedin.metadata.search.elasticsearch.query.filter.QueryFilterRewriteChain;
import com.linkedin.metadata.search.elasticsearch.update.ESWriteDAO; import com.linkedin.metadata.search.elasticsearch.update.ESWriteDAO;
import io.datahubproject.metadata.context.ObjectMapperContext;
import java.io.IOException; import java.io.IOException;
import javax.annotation.Nonnull; import javax.annotation.Nonnull;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -30,17 +28,6 @@ import org.springframework.context.annotation.Import;
@Configuration @Configuration
@Import({EntityRegistryFactory.class, SettingsBuilderFactory.class}) @Import({EntityRegistryFactory.class, SettingsBuilderFactory.class})
public class ElasticSearchServiceFactory { public class ElasticSearchServiceFactory {
private static final ObjectMapper YAML_MAPPER = new YAMLMapper();
static {
int maxSize =
Integer.parseInt(
System.getenv()
.getOrDefault(INGESTION_MAX_SERIALIZED_STRING_LENGTH, MAX_JACKSON_STRING_SIZE));
YAML_MAPPER
.getFactory()
.setStreamReadConstraints(StreamReadConstraints.builder().maxStringLength(maxSize).build());
}
@Autowired @Autowired
@Qualifier("baseElasticSearchComponents") @Qualifier("baseElasticSearchComponents")
@ -68,7 +55,7 @@ public class ElasticSearchServiceFactory {
CustomSearchConfiguration customSearchConfiguration = CustomSearchConfiguration customSearchConfiguration =
searchConfiguration.getCustom() == null searchConfiguration.getCustom() == null
? null ? null
: searchConfiguration.getCustom().resolve(YAML_MAPPER); : searchConfiguration.getCustom().resolve(ObjectMapperContext.DEFAULT.getYamlMapper());
ESSearchDAO esSearchDAO = ESSearchDAO esSearchDAO =
new ESSearchDAO( new ESSearchDAO(