Uploaded image for project: 'Mahout'
  1. Mahout
  2. MAHOUT-1823

Modify MahoutFlinkTestSuite to implement FlinkTestBase

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Implemented
    • Affects Version/s: 0.11.2
    • Fix Version/s: 0.12.0
    • Component/s: Flink
    • Labels:
      None

      Description

      Modify the present MahoutFlinkTestSuite to implement FlinkTestBase. This spins up a FlinkMiniCluster to execute the tests on.

        Activity

        Hide
        githubbot ASF GitHub Bot added a comment -

        GitHub user smarthi opened a pull request:

        https://github.com/apache/mahout/pull/210

        MAHOUT-1823: Modify MahoutFlinkTestSuite to implement FlinkTestBase

        You can merge this pull request into a Git repository by running:

        $ git pull https://github.com/smarthi/mahout MAHOUT-1823

        Alternatively you can review and apply these changes as the patch at:

        https://github.com/apache/mahout/pull/210.patch

        To close this pull request, make a commit to your master/trunk branch
        with (at least) the following in the commit message:

        This closes #210


        commit a820802f1f0b1fde76ba0985dad5dfc6529d2a18
        Author: smarthi <smarthi@apache.org>
        Date: 2016-04-06T04:57:05Z

        MAHOUT-1823: Modify MahoutFlinkTestSuite to implement FlinkTestBase


        Show
        githubbot ASF GitHub Bot added a comment - GitHub user smarthi opened a pull request: https://github.com/apache/mahout/pull/210 MAHOUT-1823 : Modify MahoutFlinkTestSuite to implement FlinkTestBase You can merge this pull request into a Git repository by running: $ git pull https://github.com/smarthi/mahout MAHOUT-1823 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/mahout/pull/210.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #210 commit a820802f1f0b1fde76ba0985dad5dfc6529d2a18 Author: smarthi <smarthi@apache.org> Date: 2016-04-06T04:57:05Z MAHOUT-1823 : Modify MahoutFlinkTestSuite to implement FlinkTestBase
        Hide
        smarthi Suneel Marthi added a comment -

        Still have a failing dals test that's throwing a OOM

        57766 [flink-akka.actor.default-dispatcher-5] ERROR akka.actor.ActorSystemImpl  - exception on LARS’ timer thread
        java.lang.OutOfMemoryError: GC overhead limit exceeded
        57770 [flink-akka.actor.default-dispatcher-5] ERROR akka.actor.ActorSystemImpl  - Uncaught fatal error from thread [flink-scheduler-1] shutting down ActorSystem [flink]
        java.lang.OutOfMemoryError: GC overhead limit exceeded
        - dals *** FAILED ***
          org.apache.flink.runtime.client.JobTimeoutException: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds
          at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:136)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401)
          at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:190)
          at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90)
          at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
          at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:638)
          at org.apache.flink.api.scala.DataSet.collect(DataSet.scala:546)
          at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:53)
          ...
          Cause: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/$a#372851579]] after [21474835000 ms]
          at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333)
          at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117)
          at akka.actor.LightArrayRevolverScheduler$TaskHolder.run(Scheduler.scala:476)
          at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:282)
          at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:281)
          at scala.collection.Iterator$class.foreach(Iterator.scala:727)
          at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
          at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
          at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
          at akka.actor.LightArrayRevolverScheduler.close(Scheduler.scala:280)
        
        
        Show
        smarthi Suneel Marthi added a comment - Still have a failing dals test that's throwing a OOM 57766 [flink-akka.actor. default -dispatcher-5] ERROR akka.actor.ActorSystemImpl - exception on LARS’ timer thread java.lang.OutOfMemoryError: GC overhead limit exceeded 57770 [flink-akka.actor. default -dispatcher-5] ERROR akka.actor.ActorSystemImpl - Uncaught fatal error from thread [flink-scheduler-1] shutting down ActorSystem [flink] java.lang.OutOfMemoryError: GC overhead limit exceeded - dals *** FAILED *** org.apache.flink.runtime.client.JobTimeoutException: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:136) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401) at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:190) at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90) at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855) at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:638) at org.apache.flink.api.scala.DataSet.collect(DataSet.scala:546) at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:53) ... Cause: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka: //flink/user/$a#372851579]] after [21474835000 ms] at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333) at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117) at akka.actor.LightArrayRevolverScheduler$TaskHolder.run(Scheduler.scala:476) at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:282) at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:281) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at akka.actor.LightArrayRevolverScheduler.close(Scheduler.scala:280)
        Hide
        Andrew_Palumbo Andrew Palumbo added a comment -

        Oh man.. that is failing at AtA I was hoping that fixing ABt wad going to fix the dals error. This is a more informative stack trace

        -------- Original message --------
        From: "Suneel Marthi (JIRA)" <jira@apache.org>
        Date: 04/05/2016 10:01 PM (GMT-08:00)
        To: ap.dev@outlook.com
        Subject: [jira] [Commented] (MAHOUT-1823) Modify MahoutFlinkTestSuite to implement FlinkTestBase

        [ https://issues.apache.org/jira/browse/MAHOUT-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227723#comment-15227723 ]

        Suneel Marthi commented on MAHOUT-1823:
        ---------------------------------------

        Still have a failing dals test that's throwing a OOM

        57766 [flink-akka.actor.default-dispatcher-5] ERROR akka.actor.ActorSystemImpl  - exception on LARS’ timer thread
        java.lang.OutOfMemoryError: GC overhead limit exceeded
        57770 [flink-akka.actor.default-dispatcher-5] ERROR akka.actor.ActorSystemImpl  - Uncaught fatal error from thread [flink-scheduler-1] shutting down ActorSystem [flink]
        java.lang.OutOfMemoryError: GC overhead limit exceeded
        - dals *** FAILED ***
          org.apache.flink.runtime.client.JobTimeoutException: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds
          at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:136)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409)
          at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401)
          at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:190)
          at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90)
          at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
          at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:638)
          at org.apache.flink.api.scala.DataSet.collect(DataSet.scala:546)
          at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:53)
          ...
          Cause: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/$a#372851579]] after [21474835000 ms]
          at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333)
          at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117)
          at akka.actor.LightArrayRevolverScheduler$TaskHolder.run(Scheduler.scala:476)
          at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:282)
          at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:281)
          at scala.collection.Iterator$class.foreach(Iterator.scala:727)
          at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
          at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
          at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
          at akka.actor.LightArrayRevolverScheduler.close(Scheduler.scala:280)
        
        


        This message was sent by Atlassian JIRA
        (v6.3.4#6332)

        Show
        Andrew_Palumbo Andrew Palumbo added a comment - Oh man.. that is failing at AtA I was hoping that fixing ABt wad going to fix the dals error. This is a more informative stack trace -------- Original message -------- From: "Suneel Marthi (JIRA)" <jira@apache.org> Date: 04/05/2016 10:01 PM (GMT-08:00) To: ap.dev@outlook.com Subject: [jira] [Commented] ( MAHOUT-1823 ) Modify MahoutFlinkTestSuite to implement FlinkTestBase [ https://issues.apache.org/jira/browse/MAHOUT-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227723#comment-15227723 ] Suneel Marthi commented on MAHOUT-1823 : --------------------------------------- Still have a failing dals test that's throwing a OOM 57766 [flink-akka.actor. default -dispatcher-5] ERROR akka.actor.ActorSystemImpl - exception on LARS’ timer thread java.lang.OutOfMemoryError: GC overhead limit exceeded 57770 [flink-akka.actor. default -dispatcher-5] ERROR akka.actor.ActorSystemImpl - Uncaught fatal error from thread [flink-scheduler-1] shutting down ActorSystem [flink] java.lang.OutOfMemoryError: GC overhead limit exceeded - dals *** FAILED *** org.apache.flink.runtime.client.JobTimeoutException: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:136) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401) at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:190) at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90) at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855) at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:638) at org.apache.flink.api.scala.DataSet.collect(DataSet.scala:546) at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:53) ... Cause: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka: //flink/user/$a#372851579]] after [21474835000 ms] at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333) at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117) at akka.actor.LightArrayRevolverScheduler$TaskHolder.run(Scheduler.scala:476) at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:282) at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:281) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at akka.actor.LightArrayRevolverScheduler.close(Scheduler.scala:280) – This message was sent by Atlassian JIRA (v6.3.4#6332)
        Hide
        githubbot ASF GitHub Bot added a comment -

        Github user andrewpalumbo commented on a diff in the pull request:

        https://github.com/apache/mahout/pull/210#discussion_r58652871

        — Diff: flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuite.scala —
        @@ -29,8 +34,13 @@ trait DistributedFlinkSuite extends DistributedMahoutSuite { this: Suite =>
        protected implicit var mahoutCtx: DistributedContext = _
        protected var env: ExecutionEnvironment = null

        + var cluster: Option[ForkableFlinkMiniCluster] = None
        + val parallelism = 4
        + protected val DEFAULT_AKKA_ASK_TIMEOUT: Long = 1000
        + protected var DEFAULT_TIMEOUT: FiniteDuration = new FiniteDuration(DEFAULT_AKKA_ASK_TIMEOUT, TimeUnit.SECONDS)
        +
        def initContext() {

        • env = ExecutionEnvironment.getExecutionEnvironment
          +// env = ExecutionEnvironment.getExecutionEnvironment
          // set this higher so that tests like dsqDist(X,Y) have enough available slots to pass on a single machine.
          env.setParallelism(10)
            • End diff –

        Shouldn't this setParallelism be removed?

        Show
        githubbot ASF GitHub Bot added a comment - Github user andrewpalumbo commented on a diff in the pull request: https://github.com/apache/mahout/pull/210#discussion_r58652871 — Diff: flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuite.scala — @@ -29,8 +34,13 @@ trait DistributedFlinkSuite extends DistributedMahoutSuite { this: Suite => protected implicit var mahoutCtx: DistributedContext = _ protected var env: ExecutionEnvironment = null + var cluster: Option [ForkableFlinkMiniCluster] = None + val parallelism = 4 + protected val DEFAULT_AKKA_ASK_TIMEOUT: Long = 1000 + protected var DEFAULT_TIMEOUT: FiniteDuration = new FiniteDuration(DEFAULT_AKKA_ASK_TIMEOUT, TimeUnit.SECONDS) + def initContext() { env = ExecutionEnvironment.getExecutionEnvironment +// env = ExecutionEnvironment.getExecutionEnvironment // set this higher so that tests like dsqDist(X,Y) have enough available slots to pass on a single machine. env.setParallelism(10) End diff – Shouldn't this setParallelism be removed?
        Hide
        smarthi Suneel Marthi added a comment -

        Yup,will fix it

        Show
        smarthi Suneel Marthi added a comment - Yup,will fix it
        Hide
        smarthi Suneel Marthi added a comment -

        Here's the latest stacktrace, its dspca failing now and we have seen this happen consistently

        Job execution failed.
        org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
        	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:714)
        	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
        	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
        	at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
        	at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
        	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
        	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
        	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
        	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
        	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
        Caused by: java.lang.IllegalStateException: unread block data
        	at java.io.ObjectInputStream$BlockDataInputStream.setBlockDataMode(ObjectInputStream.java:2421)
        	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1382)
        	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1990)
        	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1915)
        	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798)
        	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
        	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
        	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:290)
        	at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:248)
        	at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:282)
        	at org.apache.flink.runtime.operators.DataSourceTask.initInputFormat(DataSourceTask.java:248)
        	at org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:84)
        	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
        	at java.lang.Thread.run(Thread.java:745)
        
        
        Show
        smarthi Suneel Marthi added a comment - Here's the latest stacktrace, its dspca failing now and we have seen this happen consistently Job execution failed. org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:714) at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660) at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660) at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: java.lang.IllegalStateException: unread block data at java.io.ObjectInputStream$BlockDataInputStream.setBlockDataMode(ObjectInputStream.java:2421) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1382) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1990) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1915) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1798) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370) at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:290) at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:248) at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:282) at org.apache.flink.runtime.operators.DataSourceTask.initInputFormat(DataSourceTask.java:248) at org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:84) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) at java.lang. Thread .run( Thread .java:745)
        Hide
        githubbot ASF GitHub Bot added a comment -

        Github user smarthi commented on the pull request:

        https://github.com/apache/mahout/pull/210#issuecomment-206143210

        I am gonna commit this to the flink branch.

        Show
        githubbot ASF GitHub Bot added a comment - Github user smarthi commented on the pull request: https://github.com/apache/mahout/pull/210#issuecomment-206143210 I am gonna commit this to the flink branch.
        Hide
        githubbot ASF GitHub Bot added a comment -

        Github user smarthi commented on the pull request:

        https://github.com/apache/mahout/pull/210#issuecomment-206145483

        Merged to branch - flink-binding via commit# c1d79ff4c2e38325736f09a8a35eb7ba2625509d

        Show
        githubbot ASF GitHub Bot added a comment - Github user smarthi commented on the pull request: https://github.com/apache/mahout/pull/210#issuecomment-206145483 Merged to branch - flink-binding via commit# c1d79ff4c2e38325736f09a8a35eb7ba2625509d
        Hide
        githubbot ASF GitHub Bot added a comment -

        Github user smarthi closed the pull request at:

        https://github.com/apache/mahout/pull/210

        Show
        githubbot ASF GitHub Bot added a comment - Github user smarthi closed the pull request at: https://github.com/apache/mahout/pull/210
        Hide
        hudson Hudson added a comment -

        FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/)
        MAHOUT-1823: Modify MahoutFlinkTestSuite to implement FlinkTestBase, (smarthi: rev c1d79ff4c2e38325736f09a8a35eb7ba2625509d)

        • flink/pom.xml
        • flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuite.scala
        • flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DrmLikeSuite.scala
        • flink/src/test/scala/org/apache/mahout/flinkbindings/standard/RLikeDrmOpsSuite.scala
        • flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DrmLikeOpsSuite.scala
        • flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DistributedDecompositionsSuite.scala
        Show
        hudson Hudson added a comment - FAILURE: Integrated in Mahout-Quality #3324 (See https://builds.apache.org/job/Mahout-Quality/3324/ ) MAHOUT-1823 : Modify MahoutFlinkTestSuite to implement FlinkTestBase, (smarthi: rev c1d79ff4c2e38325736f09a8a35eb7ba2625509d) flink/pom.xml flink/src/test/scala/org/apache/mahout/flinkbindings/DistributedFlinkSuite.scala flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DrmLikeSuite.scala flink/src/test/scala/org/apache/mahout/flinkbindings/standard/RLikeDrmOpsSuite.scala flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DrmLikeOpsSuite.scala flink/src/test/scala/org/apache/mahout/flinkbindings/standard/DistributedDecompositionsSuite.scala
        Hide
        smarthi Suneel Marthi added a comment -

        Closing issues following Mahout 0.12.0 release on April 11, 2016

        Show
        smarthi Suneel Marthi added a comment - Closing issues following Mahout 0.12.0 release on April 11, 2016

          People

          • Assignee:
            smarthi Suneel Marthi
            Reporter:
            smarthi Suneel Marthi
          • Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development

                Agile