Re: WorkerHook deserialization problem

2016-11-01 Thread Kevin Peek
thank you for the detailed response. On Fri, Oct 28, 2016 at 4:15 PM, P. Taylor Goetz wrote: > I was able to verify this to be a bug in how worker hooks work in local > mode. > > In trying to see if this affects distributed mode as well, a found a more > serious issue that prevents workers from

Re: WorkerHook deserialization problem

2016-10-28 Thread P. Taylor Goetz
I was able to verify this to be a bug in how worker hooks work in local mode. In trying to see if this affects distributed mode as well, a found a more serious issue that prevents workers from shutting down gracefully (an thus preventing shutdown hooks from running): https://issues.apache.org/j

WorkerHook deserialization problem

2016-10-21 Thread Kevin Peek
I am running into problems with WorkerHooks on a local cluster. Even using only a BaseWorkerHook, I get an Exception. When I run the following code, an EOFException is thrown - it seems the Worker is trying to deserialize an empty byte[] for one of the WorkerHooks. Comment out the line adding the h