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
{