This is an automated email from the ASF dual-hosted git repository.

jkevan pushed a commit to branch reduceIndicesItems
in repository https://gitbox.apache.org/repos/asf/unomi.git


The following commit(s) were added to refs/heads/reduceIndicesItems by this 
push:
     new d9634fada fix bad merge
d9634fada is described below

commit d9634fada2916a8b81db07cb4e9a3d0f9218c3c8
Author: Kevan <[email protected]>
AuthorDate: Wed Feb 1 10:25:11 2023 +0100

    fix bad merge
---
 .../elasticsearch/ElasticSearchPersistenceServiceImpl.java       | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git 
a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
 
b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
index 61e852275..85e8aa18b 100644
--- 
a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
+++ 
b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java
@@ -890,7 +890,7 @@ public class ElasticSearchPersistenceServiceImpl implements 
PersistenceService,
                         GetResponse response = client.get(getRequest, 
RequestOptions.DEFAULT);
                         if (response.isExists()) {
                             String sourceAsString = 
response.getSourceAsString();
-                            -final T value = 
ESCustomObjectMapper.getObjectMapper().readValue(sourceAsString, clazz);
+                            final T value = 
ESCustomObjectMapper.getObjectMapper().readValue(sourceAsString, clazz);
                             setMetadata(value, response.getId(), 
response.getVersion(), response.getSeqNo(), response.getPrimaryTerm(), 
response.getIndex());
                             return value;
                         } else {
@@ -2651,14 +2651,9 @@ public class ElasticSearchPersistenceServiceImpl 
implements PersistenceService,
     private String getIndexNameForQuery(String itemType) {
         return rolloverIndices.contains(itemType) ? 
getRolloverIndexForQuery(itemType) : getIndex(itemType);
     }
-
-<<<<<<< Updated upstream
+    
     private String getRolloverIndexForQuery(String itemType) {
         return indexPrefix + "-" + itemType.toLowerCase() + "-*";
-=======
-    private String getMonthlyIndexForQuery(String itemType) {
-        return indexPrefix + "-" + getIndexNameForItemType(itemType) + "-*";
->>>>>>> Stashed changes
     }
 
     private String getIndex(String itemType) {

Reply via email to