提交 5dc4dd2c 编写于 作者: R rmetzger

Merge pull request #97 from fhueske/master

Fixed bug. stub.open() was not called for COMBININGSORT local strategy.
...@@ -724,6 +724,7 @@ public class RegularPactTask<S extends Stub, OT> extends AbstractTask implements ...@@ -724,6 +724,7 @@ public class RegularPactTask<S extends Stub, OT> extends AbstractTask implements
// if the class is null, the driver has no user code // if the class is null, the driver has no user code
if (userCodeFunctionType != null && GenericReducer.class.isAssignableFrom(userCodeFunctionType)) { if (userCodeFunctionType != null && GenericReducer.class.isAssignableFrom(userCodeFunctionType)) {
localStub = initStub(userCodeFunctionType); localStub = initStub(userCodeFunctionType);
localStub.open(this.config.getStubParameters());
} else { } else {
throw new IllegalStateException("Performing combining sort outside a reduce task!"); throw new IllegalStateException("Performing combining sort outside a reduce task!");
} }
...@@ -1207,7 +1208,7 @@ public class RegularPactTask<S extends Stub, OT> extends AbstractTask implements ...@@ -1207,7 +1208,7 @@ public class RegularPactTask<S extends Stub, OT> extends AbstractTask implements
try { try {
stub.open(parameters); stub.open(parameters);
} catch (Throwable t) { } catch (Throwable t) {
throw new Exception("The user defined 'open(Configuration)' method caused an exception: " + t.getMessage(), t); throw new Exception("The user defined 'open(Configuration)' method in " + stub.getClass().toString() + " caused an exception: " + t.getMessage(), t);
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册