From 3dd47fc953721991e9ad3e28ebc013755f6fec9b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jo=CC=88rg=20Prante?= Date: Thu, 29 Apr 2021 11:33:43 +0200 Subject: [PATCH] make metric optional, but set bulk volume to max if bulk metric is disabled, default is bulk metric enabled --- .../xbib/elx/common/DefaultBulkProcessor.java | 17 +++++--- .../elx/common/DefaultIndexDefinition.java | 40 +++++++++---------- .../java/org/xbib/elx/common/Parameters.java | 6 +-- .../xbib/elx/http/test/BulkClientTest.java | 12 ++++-- .../xbib/elx/http/test/DuplicateIDTest.java | 4 +- .../org/xbib/elx/http/test/SearchTest.java | 16 +++++--- .../org/xbib/elx/http/test/SmokeTest.java | 6 ++- .../xbib/elx/node/test/BulkClientTest.java | 12 ++++-- .../xbib/elx/node/test/DuplicateIDTest.java | 4 +- .../org/xbib/elx/node/test/SearchTest.java | 32 +++++++++------ .../org/xbib/elx/node/test/SmokeTest.java | 6 ++- .../elx/transport/test/TestExtension.java | 4 +- 12 files changed, 98 insertions(+), 61 deletions(-) diff --git a/elx-common/src/main/java/org/xbib/elx/common/DefaultBulkProcessor.java b/elx-common/src/main/java/org/xbib/elx/common/DefaultBulkProcessor.java index e349779..8ef89f1 100644 --- a/elx-common/src/main/java/org/xbib/elx/common/DefaultBulkProcessor.java +++ b/elx-common/src/main/java/org/xbib/elx/common/DefaultBulkProcessor.java @@ -42,7 +42,7 @@ public class DefaultBulkProcessor implements BulkProcessor { private final DefaultBulkListener bulkListener; - private ScheduledFuture scheduledFuture; + private ScheduledFuture flushIntervalFuture; private BulkRequest bulkRequest; @@ -66,16 +66,21 @@ public class DefaultBulkProcessor implements BulkProcessor { Parameters.BULK_FLUSH_INTERVAL.getString()); TimeValue flushInterval = TimeValue.parseTimeValue(flushIntervalStr, TimeValue.timeValueSeconds(30), ""); - ByteSizeValue minVolumePerRequest = settings.getAsBytesSize(Parameters.BULK_MIN_VOLUME_PER_REQUEST.getName(), - ByteSizeValue.parseBytesSizeValue(Parameters.BULK_MIN_VOLUME_PER_REQUEST.getString(), "1k")); this.client = bulkClient.getClient(); if (flushInterval.millis() > 0L) { - this.scheduledFuture = bulkClient.getScheduler().scheduleWithFixedDelay(this::flush, flushInterval.millis(), + this.flushIntervalFuture = bulkClient.getScheduler().scheduleWithFixedDelay(this::flush, flushInterval.millis(), flushInterval.millis(), TimeUnit.MILLISECONDS); } this.bulkListener = new DefaultBulkListener(this, settings); this.bulkActions = maxActionsPerRequest; + ByteSizeValue minVolumePerRequest = settings.getAsBytesSize(Parameters.BULK_MIN_VOLUME_PER_REQUEST.getName(), + ByteSizeValue.parseBytesSizeValue(Parameters.BULK_MIN_VOLUME_PER_REQUEST.getString(), "1k")); this.bulkVolume = minVolumePerRequest.getBytes(); + if (!isBulkMetricEnabled()) { + ByteSizeValue maxVolumePerRequest = settings.getAsBytesSize(Parameters.BULK_MAX_VOLUME_PER_REQUEST.getName(), + ByteSizeValue.parseBytesSizeValue(Parameters.BULK_MAX_VOLUME_PER_REQUEST.getString(), "1m")); + this.bulkVolume = maxVolumePerRequest.getBytes(); + } this.bulkRequest = new BulkRequest(); this.closed = new AtomicBoolean(false); this.enabled = new AtomicBoolean(false); @@ -178,8 +183,8 @@ public class DefaultBulkProcessor implements BulkProcessor { public synchronized void close() throws IOException { if (closed.compareAndSet(false, true)) { try { - if (scheduledFuture != null) { - scheduledFuture.cancel(true); + if (flushIntervalFuture != null) { + flushIntervalFuture.cancel(true); } // like flush but without ensuring open if (bulkRequest.numberOfActions() > 0) { diff --git a/elx-common/src/main/java/org/xbib/elx/common/DefaultIndexDefinition.java b/elx-common/src/main/java/org/xbib/elx/common/DefaultIndexDefinition.java index 3b08b01..a9d2b12 100644 --- a/elx-common/src/main/java/org/xbib/elx/common/DefaultIndexDefinition.java +++ b/elx-common/src/main/java/org/xbib/elx/common/DefaultIndexDefinition.java @@ -94,26 +94,26 @@ public class DefaultIndexDefinition implements IndexDefinition { if (settings.get("settings") != null && settings.get("mapping") != null) { setSettings(findSettingsFrom(settings.get("settings"))); setMappings(findMappingsFrom(settings.get("mapping"))); - boolean shift = settings.getAsBoolean("shift", false); - setShift(shift); - if (shift) { - String dateTimeFormat = settings.get(Parameters.DATE_TIME_FORMAT.getName(), - Parameters.DATE_TIME_FORMAT.getString()); - DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(dateTimeFormat, Locale.getDefault()) - .withZone(ZoneId.systemDefault()); - setDateTimeFormatter(dateTimeFormatter); - String dateTimePatternStr = settings.get("dateTimePattern", "^(.*?)(\\d+)$"); - Pattern dateTimePattern = Pattern.compile(dateTimePatternStr); - setDateTimePattern(dateTimePattern); - String fullName = indexName + dateTimeFormatter.format(LocalDateTime.now()); - fullIndexName = adminClient.resolveAlias(fullName).stream().findFirst().orElse(fullName); - setFullIndexName(fullIndexName); - boolean prune = settings.getAsBoolean("prune", false); - setPrune(prune); - if (prune) { - setMinToKeep(settings.getAsInt("retention.mintokeep", 2)); - setDelta(settings.getAsInt("retention.delta", 2)); - } + } + boolean shift = settings.getAsBoolean("shift", false); + setShift(shift); + if (shift) { + String dateTimeFormat = settings.get(Parameters.DATE_TIME_FORMAT.getName(), + Parameters.DATE_TIME_FORMAT.getString()); + DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(dateTimeFormat, Locale.getDefault()) + .withZone(ZoneId.systemDefault()); + setDateTimeFormatter(dateTimeFormatter); + String dateTimePatternStr = settings.get("dateTimePattern", "^(.*?)(\\d+)$"); + Pattern dateTimePattern = Pattern.compile(dateTimePatternStr); + setDateTimePattern(dateTimePattern); + String fullName = indexName + dateTimeFormatter.format(LocalDateTime.now()); + fullIndexName = adminClient.resolveAlias(fullName).stream().findFirst().orElse(fullName); + setFullIndexName(fullIndexName); + boolean prune = settings.getAsBoolean("prune", false); + setPrune(prune); + if (prune) { + setMinToKeep(settings.getAsInt("retention.mintokeep", 2)); + setDelta(settings.getAsInt("retention.delta", 2)); } } } diff --git a/elx-common/src/main/java/org/xbib/elx/common/Parameters.java b/elx-common/src/main/java/org/xbib/elx/common/Parameters.java index 623c566..445a726 100644 --- a/elx-common/src/main/java/org/xbib/elx/common/Parameters.java +++ b/elx-common/src/main/java/org/xbib/elx/common/Parameters.java @@ -26,12 +26,12 @@ public enum Parameters { BULK_FLUSH_INTERVAL("bulk.flush_interval", String.class, "30s"), - BULK_MEASURE_INTERVAL("bulk.measure_interval", String.class, "1s"), - - BULK_METRIC_ENABLED("bulk.metric.enabled", Boolean.class, Boolean.FALSE), + BULK_METRIC_ENABLED("bulk.metric.enabled", Boolean.class, Boolean.TRUE), BULK_METRIC_LOG_INTERVAL("bulk.metric.log_interval", String.class, "10s"), + BULK_MEASURE_INTERVAL("bulk.measure_interval", String.class, "1s"), + BULK_RING_BUFFER_SIZE("bulk.ring_buffer_size", Integer.class, Runtime.getRuntime().availableProcessors()), BULK_PERMITS("bulk.permits", Integer.class, Runtime.getRuntime().availableProcessors() - 1), diff --git a/elx-http/src/test/java/org/xbib/elx/http/test/BulkClientTest.java b/elx-http/src/test/java/org/xbib/elx/http/test/BulkClientTest.java index a24ac29..f7948ae 100644 --- a/elx-http/src/test/java/org/xbib/elx/http/test/BulkClientTest.java +++ b/elx-http/src/test/java/org/xbib/elx/http/test/BulkClientTest.java @@ -53,7 +53,9 @@ class BulkClientTest { bulkClient.index(indexDefinition, "1", true, "{ \"name\" : \"Hello World\"}"); // single doc ingest bulkClient.flush(); bulkClient.waitForResponses(30L, TimeUnit.SECONDS); - assertEquals(1, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(1, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -75,7 +77,9 @@ class BulkClientTest { bulkClient.index(indexDefinition, null, false, "{ \"name\" : \"" + helper.randomString(32) + "\"}"); } bulkClient.waitForResponses(30L, TimeUnit.SECONDS); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -118,7 +122,9 @@ class BulkClientTest { bulkClient.stopBulk(indexDefinition); bulkClient.refreshIndex(indexDefinition); assertEquals(maxthreads * actions, bulkClient.getSearchableDocs(indexDefinition)); - assertEquals(maxthreads * actions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(maxthreads * actions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-http/src/test/java/org/xbib/elx/http/test/DuplicateIDTest.java b/elx-http/src/test/java/org/xbib/elx/http/test/DuplicateIDTest.java index acbbdbb..9471ed9 100644 --- a/elx-http/src/test/java/org/xbib/elx/http/test/DuplicateIDTest.java +++ b/elx-http/src/test/java/org/xbib/elx/http/test/DuplicateIDTest.java @@ -46,7 +46,9 @@ class DuplicateIDTest { bulkClient.refreshIndex(indexDefinition); long hits = bulkClient.getSearchableDocs(indexDefinition); assertTrue(hits < ACTIONS); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-http/src/test/java/org/xbib/elx/http/test/SearchTest.java b/elx-http/src/test/java/org/xbib/elx/http/test/SearchTest.java index 6f9f0b9..4a205b1 100644 --- a/elx-http/src/test/java/org/xbib/elx/http/test/SearchTest.java +++ b/elx-http/src/test/java/org/xbib/elx/http/test/SearchTest.java @@ -49,7 +49,9 @@ class SearchTest { bulkClient.waitForResponses(30L, TimeUnit.SECONDS); bulkClient.refreshIndex(indexDefinition); assertEquals(numactions, bulkClient.getSearchableDocs(indexDefinition)); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -73,11 +75,13 @@ class SearchTest { idcount.incrementAndGet(); }); assertEquals(numactions, idcount.get()); - assertEquals(275, searchClient.getSearchMetric().getQueries().getCount()); - assertEquals(273, searchClient.getSearchMetric().getSucceededQueries().getCount()); - assertEquals(2, searchClient.getSearchMetric().getEmptyQueries().getCount()); - assertEquals(0, searchClient.getSearchMetric().getFailedQueries().getCount()); - assertEquals(0, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + if (searchClient.isSearchMetricEnabled()) { + assertEquals(275, searchClient.getSearchMetric().getQueries().getCount()); + assertEquals(273, searchClient.getSearchMetric().getSucceededQueries().getCount()); + assertEquals(2, searchClient.getSearchMetric().getEmptyQueries().getCount()); + assertEquals(0, searchClient.getSearchMetric().getFailedQueries().getCount()); + assertEquals(0, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + } } } } diff --git a/elx-http/src/test/java/org/xbib/elx/http/test/SmokeTest.java b/elx-http/src/test/java/org/xbib/elx/http/test/SmokeTest.java index 6250280..9fd2043 100644 --- a/elx-http/src/test/java/org/xbib/elx/http/test/SmokeTest.java +++ b/elx-http/src/test/java/org/xbib/elx/http/test/SmokeTest.java @@ -63,8 +63,10 @@ class SmokeTest { assertTrue(bulkClient.waitForResponses(30, TimeUnit.SECONDS)); adminClient.updateReplicaLevel(indexDefinition); assertEquals(1, adminClient.getReplicaLevel(indexDefinition)); - assertEquals(0, bulkClient.getBulkProcessor().getBulkMetric().getFailed().getCount()); - assertEquals(6, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(0, bulkClient.getBulkProcessor().getBulkMetric().getFailed().getCount()); + assertEquals(6, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-node/src/test/java/org/xbib/elx/node/test/BulkClientTest.java b/elx-node/src/test/java/org/xbib/elx/node/test/BulkClientTest.java index 00fe607..ef05476 100644 --- a/elx-node/src/test/java/org/xbib/elx/node/test/BulkClientTest.java +++ b/elx-node/src/test/java/org/xbib/elx/node/test/BulkClientTest.java @@ -52,7 +52,9 @@ class BulkClientTest { bulkClient.newIndex(indexDefinition); bulkClient.index(indexDefinition, "1", true, "{ \"name\" : \"Hello World\"}"); // single doc ingest bulkClient.waitForResponses(30L, TimeUnit.SECONDS); - assertEquals(1, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(1, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -76,7 +78,9 @@ class BulkClientTest { } bulkClient.stopBulk(indexDefinition); bulkClient.waitForResponses(30L, TimeUnit.SECONDS); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -120,7 +124,9 @@ class BulkClientTest { bulkClient.stopBulk(indexDefinition); bulkClient.refreshIndex(indexDefinition); assertEquals(maxthreads * actions, bulkClient.getSearchableDocs(indexDefinition)); - assertEquals(maxthreads * actions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(maxthreads * actions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-node/src/test/java/org/xbib/elx/node/test/DuplicateIDTest.java b/elx-node/src/test/java/org/xbib/elx/node/test/DuplicateIDTest.java index c9c84d5..b2c61f2 100644 --- a/elx-node/src/test/java/org/xbib/elx/node/test/DuplicateIDTest.java +++ b/elx-node/src/test/java/org/xbib/elx/node/test/DuplicateIDTest.java @@ -45,7 +45,9 @@ class DuplicateIDTest { bulkClient.waitForResponses(30L, TimeUnit.SECONDS); bulkClient.refreshIndex(indexDefinition); assertTrue(bulkClient.getSearchableDocs(indexDefinition) < ACTIONS); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-node/src/test/java/org/xbib/elx/node/test/SearchTest.java b/elx-node/src/test/java/org/xbib/elx/node/test/SearchTest.java index db0570a..0de8a28 100644 --- a/elx-node/src/test/java/org/xbib/elx/node/test/SearchTest.java +++ b/elx-node/src/test/java/org/xbib/elx/node/test/SearchTest.java @@ -52,7 +52,9 @@ class SearchTest { bulkClient.waitForResponses(30L, TimeUnit.SECONDS); bulkClient.refreshIndex(indexDefinition); assertEquals(numactions, bulkClient.getSearchableDocs(indexDefinition)); - assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(numactions, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } @@ -69,9 +71,11 @@ class SearchTest { TimeValue.timeValueMillis(100), 579); long count = stream.count(); assertEquals(numactions, count); - assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); - assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); - assertEquals(1L, searchClient.getSearchMetric().getEmptyQueries().getCount()); + if (searchClient.isSearchMetricEnabled()) { + assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); + assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + assertEquals(1L, searchClient.getSearchMetric().getEmptyQueries().getCount()); + } // test stream docs stream = searchClient.search(qb -> qb .setIndices(indexDefinition.getFullIndexName()) @@ -80,9 +84,11 @@ class SearchTest { final AtomicInteger hitcount = new AtomicInteger(); stream.forEach(hit -> hitcount.incrementAndGet()); assertEquals(numactions, hitcount.get()); - assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); - assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); - assertEquals(2L, searchClient.getSearchMetric().getEmptyQueries().getCount()); + if (searchClient.isSearchMetricEnabled()) { + assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); + assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + assertEquals(2L, searchClient.getSearchMetric().getEmptyQueries().getCount()); + } // test stream doc ids Stream ids = searchClient.getIds(qb -> qb .setIndices(indexDefinition.getFullIndexName()) @@ -90,11 +96,13 @@ class SearchTest { final AtomicInteger idcount = new AtomicInteger(); ids.forEach(id -> idcount.incrementAndGet()); assertEquals(numactions, idcount.get()); - assertEquals(1542L, searchClient.getSearchMetric().getQueries().getCount()); - assertEquals(1539L, searchClient.getSearchMetric().getSucceededQueries().getCount()); - assertEquals(3L, searchClient.getSearchMetric().getEmptyQueries().getCount()); - assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); - assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + if (searchClient.isSearchMetricEnabled()) { + assertEquals(1542L, searchClient.getSearchMetric().getQueries().getCount()); + assertEquals(1539L, searchClient.getSearchMetric().getSucceededQueries().getCount()); + assertEquals(3L, searchClient.getSearchMetric().getEmptyQueries().getCount()); + assertEquals(0L, searchClient.getSearchMetric().getFailedQueries().getCount()); + assertEquals(0L, searchClient.getSearchMetric().getTimeoutQueries().getCount()); + } } } } diff --git a/elx-node/src/test/java/org/xbib/elx/node/test/SmokeTest.java b/elx-node/src/test/java/org/xbib/elx/node/test/SmokeTest.java index 5011907..80971ca 100644 --- a/elx-node/src/test/java/org/xbib/elx/node/test/SmokeTest.java +++ b/elx-node/src/test/java/org/xbib/elx/node/test/SmokeTest.java @@ -66,8 +66,10 @@ class SmokeTest { assertTrue(bulkClient.waitForResponses(30, TimeUnit.SECONDS)); adminClient.updateReplicaLevel(indexDefinition); assertEquals(1, adminClient.getReplicaLevel(indexDefinition)); - assertEquals(0, bulkClient.getBulkProcessor().getBulkMetric().getFailed().getCount()); - assertEquals(6, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + if (bulkClient.getBulkProcessor().isBulkMetricEnabled()) { + assertEquals(0, bulkClient.getBulkProcessor().getBulkMetric().getFailed().getCount()); + assertEquals(6, bulkClient.getBulkProcessor().getBulkMetric().getSucceeded().getCount()); + } if (bulkClient.getBulkProcessor().getLastBulkError() != null) { logger.error("error", bulkClient.getBulkProcessor().getLastBulkError()); } diff --git a/elx-transport/src/test/java/org/xbib/elx/transport/test/TestExtension.java b/elx-transport/src/test/java/org/xbib/elx/transport/test/TestExtension.java index b9472be..8617479 100644 --- a/elx-transport/src/test/java/org/xbib/elx/transport/test/TestExtension.java +++ b/elx-transport/src/test/java/org/xbib/elx/transport/test/TestExtension.java @@ -163,8 +163,8 @@ public class TestExtension implements ParameterResolver, BeforeEachCallback, Aft .put(Parameters.PORT.getName(), port) .put(Parameters.CLUSTER_TARGET_HEALTH.getName(), "YELLOW") .put(Parameters.CLUSTER_TARGET_HEALTH_TIMEOUT.getName(), "1m") - //.put(Parameters.BULK_METRIC_ENABLED.getName(), Boolean.TRUE) - //.put(Parameters.SEARCH_METRIC_ENABLED.getName(), Boolean.TRUE) + .put(Parameters.BULK_METRIC_ENABLED.getName(), Boolean.FALSE) + .put(Parameters.SEARCH_METRIC_ENABLED.getName(), Boolean.FALSE) .build(); }