@Override
public void setConf(Configuration conf) {
try {
KryoInstantiator kryoInst = new ConfiguredInstantiator(new HadoopConfig(conf));
testKryo = kryoInst.newKryo();
kryoPool = KryoPool.withByteArrayOutputStream(MAX_CACHED_KRYO, kryoInst);
}
catch(ConfigurationException cx) {
// This interface can't throw
throw new RuntimeException(cx);