Merge pull request #58 from vietnguyen-td/set-cache-or-ignore-in-tran…

…saction setCacheProviderOrIgnore in transaction
embulk · Mar 1, 2022 · 5769d1f · 5769d1f
2 parents b4d8dee + 1cc0613
commit 5769d1f
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());