Repository: crunch Updated Branches: refs/heads/master ba7a3477c -> a3761da72
CRUNCH-514: Initialize delegate MapFns inside of AvroDerivedValueDeepCopier Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/a3761da7 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/a3761da7 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/a3761da7 Branch: refs/heads/master Commit: a3761da72503ee209b487d831178d234281ac332 Parents: ba7a347 Author: Josh Wills <[email protected]> Authored: Sat Apr 25 10:11:04 2015 -0700 Committer: Josh Wills <[email protected]> Committed: Sat Apr 25 10:11:04 2015 -0700 ---------------------------------------------------------------------- .../org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/a3761da7/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java index e872dd2..f1bd8e2 100644 --- a/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java +++ b/crunch-core/src/main/java/org/apache/crunch/types/avro/AvroDerivedValueDeepCopier.java @@ -39,6 +39,10 @@ public class AvroDerivedValueDeepCopier<T, S> implements DeepCopier { @Override public void initialize(Configuration conf) { + derivedToAvroFn.setConfiguration(conf); + derivedToAvroFn.initialize(); + avroToDerivedFn.setConfiguration(conf); + avroToDerivedFn.initialize(); avroBaseType.initialize(conf); }
