OK got it


On Tue, May 20, 2014 at 2:11 PM, Jonathan Coveney
<notifications@github.com>wrote:

> In
> core/src/main/java/com/twitter/elephantbird/mapreduce/input/combined/CompositeInputSplit.java:
>
> > +   *                     for failing access checks.
> > +   */
> > +  @SuppressWarnings("unchecked")  // Generic array assignment
> > +  public void readFields(DataInput in) throws IOException {
> > +    if (conf == null) {
> > +      throw new IOException("Hadoop Configuration not set via setConf");
> > +    }
> > +    int card = WritableUtils.readVInt(in);
> > +    splits = new ArrayList<InputSplit>();
> > +    try {
> > +      for (int i = 0; i < card; ++i) {
> > +        Class<? extends InputSplit> clazz = (Class<? extends InputSplit>) conf.getClassByName(Text.readString(in));
> > +        InputSplit split = ReflectionUtils.newInstance(clazz, conf);
> > +        SerializationFactory factory = new SerializationFactory(conf);
> > +        Deserializer deserializer = factory.getDeserializer(clazz);
> > +        deserializer.open((DataInputStream) in);
>
> Same response as above. Doing it closes the stream for the later
> deserializers.
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/kevinweil/elephant-bird/pull/398/files#r12868400>
> .
>