wip: use properties from /home/andy/sandbox/mahout/conf/flink-config.yaml
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/b96918bb Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/b96918bb Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/b96918bb Branch: refs/heads/master Commit: b96918bba9855fba5cefc11e1c4153b9419509cb Parents: 100d343 Author: Andrew Palumbo <[email protected]> Authored: Fri Mar 25 20:33:22 2016 -0400 Committer: Andrew Palumbo <[email protected]> Committed: Fri Mar 25 20:33:22 2016 -0400 ---------------------------------------------------------------------- .../apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/b96918bb/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala ---------------------------------------------------------------------- diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala index a5bbbb5..b0ca4c4 100644 --- a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala +++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala @@ -55,6 +55,7 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val ds: DrmDataSet[K], var cacheFileName: String = "undefinedCacheName" var isCached: Boolean = false var parallelismDeg: Int = -1 + var persistanceRootDir: String = _ // need to make sure that this is actually getting the correct propertirs for {{taskmanager.tmp.dirs}} val mahoutHome = System.getProperty("MAHOUT_HOME") @@ -64,9 +65,9 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val ds: DrmDataSet[K], val conf = GlobalConfiguration.getConfiguration() if (!(conf == null )) { - val persistanceRootDir = conf.getString("taskmanager.tmp.dirs", "/tmp/") + persistanceRootDir = conf.getString("taskmanager.tmp.dirs", "/tmp/") } else { - val persistanceRootDir = "/tmp/" + persistanceRootDir = "/tmp/" }
