Commit 3a9e247e authored by Igor Filippov (EPAM)'s avatar Igor Filippov (EPAM)
Browse files

minor fixes

parent 1ba8558e
Pipeline #12602 passed with stages
in 37 minutes
......@@ -14,6 +14,7 @@
package org.opengroup.osdu.indexer.service;
import java.io.IOException;
import java.util.List;
import org.opengroup.osdu.core.common.model.indexer.JobStatus;
......@@ -24,6 +25,6 @@ public interface IndexerService {
JobStatus processRecordChangedMessages(RecordChangedMessages recordChangedMessages, List<RecordInfo> recordInfos) throws Exception;
void processSchemaMessages(List<RecordInfo> recordInfos) throws Exception;
void processSchemaMessages(List<RecordInfo> recordInfos) throws IOException;
}
\ No newline at end of file
......@@ -175,10 +175,8 @@ public class IndexerServiceImpl implements IndexerService {
String index = elasticIndexNameResolver.getIndexNameFromKind(kind);
boolean indexExist = indicesService.isIndexExist(restClient, index);
if (msg.getValue() == OperationType.purge_schema) {
if (indexExist) {
indicesService.deleteIndex(restClient, index);
}
if (indexExist && msg.getValue() == OperationType.purge_schema) {
indicesService.deleteIndex(restClient, index);
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment