src/main/java/org/embulk/executor/mapreduce/EmbulkPartitioningMapReduce.java in embulk-executor-mapreduce-0.1.3 vs src/main/java/org/embulk/executor/mapreduce/EmbulkPartitioningMapReduce.java in embulk-executor-mapreduce-0.1.4

- old
+ new

@@ -43,14 +43,21 @@ { private Context context; private SessionRunner runner; @Override - public void setup(Context context) throws IOException + public void setup(Context context) throws IOException, InterruptedException { this.context = context; this.runner = new SessionRunner(context); - runner.readPluginArchive().restoreLoadPathsTo(runner.getScriptingContainer()); + + runner.execSession(new ExecAction<Void>() { // for Exec.getLogger + public Void run() throws IOException + { + runner.readPluginArchive().restoreLoadPathsTo(runner.getScriptingContainer()); + return null; + } + }); } @Override public void map(IntWritable key, NullWritable value, final Context context) throws IOException, InterruptedException {