From 088bbbf7006e159b33754c2dc9fc45b35f73bba3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Fri, 13 Oct 2023 11:40:41 +0200 Subject: [PATCH] feat: multi-tenant --- src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java | 2 +- src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java b/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java index 2719d9f..8adc39f 100644 --- a/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java +++ b/src/test/java/io/kestra/plugin/elasticsearch/BulkTest.java @@ -50,7 +50,7 @@ void run() throws Exception { output.write(("{ \"field1\" : \"value4\" }\n").getBytes(StandardCharsets.UTF_8)); } - URI uri = storageInterface.put(URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile)); + URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile)); Bulk put = Bulk.builder() .connection(ElasticsearchConnection.builder().hosts(hosts).build()) diff --git a/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java b/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java index 79aa6f4..eb8c839 100644 --- a/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java +++ b/src/test/java/io/kestra/plugin/elasticsearch/LoadTest.java @@ -47,7 +47,7 @@ void run() throws Exception { "name", "john" )); } - URI uri = storageInterface.put(URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile)); + URI uri = storageInterface.put(null, URI.create("/" + IdUtils.create() + ".ion"), new FileInputStream(tempFile)); Load put = Load.builder() .connection(ElasticsearchConnection.builder().hosts(hosts).build())