setCacheProviderOrIgnore in transaction

embulk · Feb 24, 2022 · 1cc0613 · 1cc0613
1 parent b4d8dee
commit 1cc0613
Showing 1 changed file with 1 addition and 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
@@ -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());