Hi,

> multipleOutputs.write(namedOutput, NullWritable.get(), value, path);
…
> As per my understanding  Multioutputs will create multiple writers from given 
>outputFormat but don't use OutputCommitter. 

Does your code end up looking like this? 

https://github.com/t3rmin4t0r/tpcds-partitioner/blob/master/src/main/java/org/notmysock/tpcds/ParTable.java#L267

That's worked just fine with task failures in 2014 with ORC writers, without an 
overwrite option.

Cheers,
Gopal



Reply via email to