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

Adding support for Apache Flink as a backend for the Mahout DSL

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Implemented
    • 0.11.2
    • 0.12.0
    • classic

    Description

      With the finalized abstraction of the Mahout DSL plans from the backend operations (MAHOUT-1529), it should be possible to integrate further backends for the Mahout DSL. Apache Flink would be a suitable candidate to act as a good execution backend.

      With respect to the implementation, the biggest difference between Spark and Flink at the moment is probably the incremental rollout of plans, which is triggered by Spark's actions and which is not supported by Flink yet. However, the Flink community is working on this issue. For the moment, it should be possible to circumvent this problem by writing intermediate results required by an action to HDFS and reading from there.

      Attachments

        Issue Links

          incorporates

          Bug - A problem which impairs or prevents the functions of the product. MAHOUT-1809 Failing tests in Flink-bindings: dals and dspca

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. MAHOUT-1810 Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. MAHOUT-1815 dsqDist(X,Y) and dsqDist(X) failing in flink tests.

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. MAHOUT-1811 Fix calculation of second norm of DRM in Flink

          • Major - Major loss of function.
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. MAHOUT-1812 Implement drmParallelizeEmptyLong(...) in flink Bindings

          • Major - Major loss of function.
          • Closed

          New Feature - A new feature of the product, which has yet to be developed. MAHOUT-1804 Implement drmParallelizeWithRowLabels(...) in flink

          • Major - Major loss of function.
          • Closed

          New Feature - A new feature of the product, which has yet to be developed. MAHOUT-1805 Implement allreduceBlock(...) in flink bindings

          • Major - Major loss of function.
          • Closed

          New Feature - A new feature of the product, which has yet to be developed. MAHOUT-1814 Implement drm2intKeyed in flink bindings

          • Major - Major loss of function.
          • Closed

          Task - A task that needs to be done. MAHOUT-1701 Mahout DSL for Flink: implement AtB ABt and AtA operators

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1702 Mahout DSL for Flink: implement element-wise operators

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1703 Mahout DSL for Flink: implement cbind and rbind

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1709 Mahout DSL for Flink: implement slicing

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1710 Mahout DSL for Flink: implement right in-core matrix multiplication

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1711 Mahout DSL for Flink: implement broadcasting

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1712 Mahout DSL for Flink: implement operators At, Ax, Atx

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1734 Mahout DSL for Flink: implement I/O

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1747 Mahout DSL for Flink: add support for different types of indexes (String, long, etc)

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1748 Mahout DSL for Flink: switch to Flink Scala API

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1755 Mahout DSL for Flink: Flush intermediate results to FS

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1764 Mahout DSL for Flink: Add standard backend tests for Flink

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Task - A task that needs to be done. MAHOUT-1765 Mahout DSL for Flink: Add some documentation about Flink backend

          • Trivial - Cosmetic problem like misspelt words or misaligned text.
          • Closed
          relates to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-393 Create Stratosphere Machine Learning Library

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              smarthi Suneel Marthi
              trohrmann Till Rohrmann
              Votes:
              1 Vote for this issue
              Watchers:
              11 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: