From 1ec5b51fbcb3c908bb8cb705b8e2a185cae0289e Mon Sep 17 00:00:00 2001 From: "P. Oscar Boykin" Date: Wed, 20 Nov 2013 16:31:23 -0800 Subject: [PATCH] add timestamps --- .../com/twitter/summingbird/scalding/ScaldingPlatform.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/ScaldingPlatform.scala b/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/ScaldingPlatform.scala index 5cbdaf9f0..e58bf1b9b 100644 --- a/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/ScaldingPlatform.scala +++ b/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/ScaldingPlatform.scala @@ -546,6 +546,11 @@ class Scalding( // Store the options used: conf.set("summingbird.options", options.toString) conf.set("summingbird.jobname", jobName) + // legacy name to match scalding + conf.set("scalding.flow.submitted.timestamp", + System.currentTimeMillis.toString) + conf.set("summingbird.submitted.timestamp", + System.currentTimeMillis.toString) def ifUnset(k: String, v: String) { if(null == conf.get(k)) { conf.set(k, v) } } // Set the mapside cache size, this is important to not be too small