From 1cc0613691e028ce69495d1b6b0339d325ad36cf Mon Sep 17 00:00:00 2001
From: vietnguyen <viet.nguyen@treasure-data.com>
Date: Thu, 24 Feb 2022 15:14:42 +0700
Subject: [PATCH] setCacheProviderOrIgnore in transaction

---
 .../org/embulk/filter/expand_json/ExpandJsonFilterPlugin.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/embulk/filter/expand_json/ExpandJsonFilterPlugin.java b/src/main/java/org/embulk/filter/expand_json/ExpandJsonFilterPlugin.java
index 1f22e0b..613b695 100644
--- a/src/main/java/org/embulk/filter/expand_json/ExpandJsonFilterPlugin.java
+++ b/src/main/java/org/embulk/filter/expand_json/ExpandJsonFilterPlugin.java
@@ -92,7 +92,7 @@ public void transaction(ConfigSource config, Schema inputSchema,
         PluginTask task = configMapper.map(config, PluginTask.class);
 
         // set cache provider
-        task.getCacheProviderName().ifPresent(this::setCacheProvider);
+        task.getCacheProviderName().ifPresent(this::setCacheProviderOrIgnore);
 
         // check if a column specified as json_column_name option exists or not
         Column jsonColumn = inputSchema.lookupColumn(task.getJsonColumnName());