andrewpalumbo commented on a change in pull request #394:
URL: https://github.com/apache/mahout/pull/394#discussion_r414097746
##########
File path:
community/community-engines/flink-batch/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
##########
@@ -62,17 +62,16 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val
ds: DrmDataSet[K],
// this is extra I/O for each cache call. this needs to be moved somewhere
where it is called
// only once. Possibly FlinkDistributedEngine.
- GlobalConfiguration.loadConfiguration(mahoutHome + "/conf/flink-config.yaml")
+ GlobalConfiguration.loadConfiguration(mahoutHome + "/conf/")
Review comment:
verified missing `./conf/flink-config.yaml` :
```
[INFO] Forking ScalaTest via: /bin/sh -c cd
'/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch'
&& 'java'
'-Djava.home=/Library/Java/JavaVirtualMachines/jdk1.8.0_201.jdk/Contents/Home/jre'
'-Djdk.lang.Process.launchMechanism=FORK'
'-Dmahout.home=/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch/target/test-classes'
'-Dbasedir=/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch'
'-Xmx4g' 'org.scalatest.tools.Runner' '-R'
'/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch/target/classes
/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch/target/test-classes'
'-o' '-fWDF'
'/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch/target/surefire-reports/TestSuite.txt'
'-u'
'/Users/colleenpalumbo/sandbox/mahout/community/community-engines/flink-batch/target/surefire-reports/.'
Discovery starting.
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
Discovery completed in 438 milliseconds.
Run starting. Expected test count is: 114
DrmLikeOpsSuite:
org.apache.mahout.flinkbindings.DrmLikeOpsSuite *** ABORTED ***
org.apache.flink.configuration.IllegalConfigurationException: The Flink
config file '/Users/colleenpalumbo/sandbox/mahout/conf/flink-conf.yaml'
(/Users/colleenpalumbo/sandbox/mahout/conf) does not exist.
at
org.apache.flink.configuration.GlobalConfiguration.loadConfiguration(GlobalConfiguration.java:124)
at org.apache.flink.configuration.```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
