Permalink
Browse files

bump cascading to 2.0.3

  • Loading branch information...
1 parent 9f9f5d5 commit 4b9080e36c4f92b60db44b176f52563d5b7496e7 bpastel committed Aug 14, 2012
Showing with 5 additions and 3 deletions.
  1. +1 −1 project.clj
  2. +4 −2 src/clj/cascalog/testing.clj
View
@@ -1,6 +1,6 @@
(def shared
'[[org.clojure/tools.macro "0.1.1"]
- [cascading/cascading-hadoop "2.0.0"
+ [cascading/cascading-hadoop "2.0.3"
:exclusions [org.codehaus.janino/janino
org.apache.hadoop/hadoop-core]]
[org.clojure/tools.macro "0.1.1"]
@@ -23,8 +23,10 @@
[java.io File]))
(defn roundtrip [obj]
- (HadoopUtil/deserializeBase64
- (HadoopUtil/serializeBase64 obj)))
+ (let [conf (hadoop/job-conf (conf/project-conf))]
+ (HadoopUtil/deserializeBase64
+ (HadoopUtil/serializeBase64 obj conf true)
+ conf (class obj) true)))
(defn invoke-filter [fil coll]
(let [fil (roundtrip fil)

0 comments on commit 4b9080e

Please sign in to comment.