It should be set in the DataSourceTask, I would assume. Can you try to trace your way from "registerInputOutput()" and "invoke()" to where the input format is called?
On Wed, Jun 18, 2014 at 2:39 PM, Timo Walther <[email protected]> wrote: > I already tried that but it resulted in the same exception. Where should > the ContextClassLoader be set when I deserialize an InputFormat on an other > node in the cluster? > > > > > > On 18.06.2014 14:24, Stephan Ewen wrote: > >> You can always do "Thread.currentThread().getContextClassLoader()" >> >> >
