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());