flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Base Scala Code for Flink 0.7
Date Fri, 26 Sep 2014 09:06:35 GMT
Hi,
since the 0.7 is just the latest snapshot release the quickstart
script is not yet updated to create a 0.7 project.

If you want, you can create a 0.7 quickstart using:
curl https://raw.githubusercontent.com/apache/incubator-flink/master/flink-quickstart/quickstart-scala-SNAPSHOT.sh
| bash

There are complete Scala API examples here:
http://flink.incubator.apache.org/docs/0.7-incubating/examples.html.
Just click the Scala Tab.

Let us know if you need more information.

Cheres,
Aljoscha

On Fri, Sep 26, 2014 at 10:20 AM, Maximilian Alber
<alber.maximilian@gmail.com> wrote:
> Hi Flinkers,
>
> I tried to migrate to 0.7 for new features aka Broadcast Variables in Scala.
> Unfortunately the code structure seemed to have changed:
>
> [INFO] Compiling 2 source files to
> /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/target/classes
> at 1411719085848
> [ERROR]
> /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:7:
> error: object TextFile is not a member of package org.apache.flink.api.scala
> [ERROR] import org.apache.flink.api.scala.TextFile
> [ERROR] ^
> [ERROR]
> /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:8:
> error: object ScalaPlan is not a member of package
> org.apache.flink.api.scala
> [ERROR] import org.apache.flink.api.scala.ScalaPlan
> [ERROR] ^
> [ERROR]
> /media/alber_disk/alber/Arbeit/Uni/Kurse/MA/repo/flink/bump_boost/src/main/scala/bumpboost/BumpBoost.scala:13:
> error: object functions is not a member of package
> org.apache.flink.api.scala
> [ERROR] import org.apache.flink.api.scala.functions.MapFunction
>
>
> Thus I tried to examine the new quickstart code on
> https://flink.incubator.apache.org/docs/0.7-incubating/scala_api_quickstart.html
> Unfortunately the quickstart script still creates a project for 0.6 and
> using Maven results in an error too:
>
> [INFO] --- maven-archetype-plugin:2.2:generate (default-cli) @
> standalone-pom ---
> [INFO] Generating project in Interactive mode
> [INFO] Archetype repository missing. Using the one from
> [org.apache.flink:flink-quickstart-scala:0.6.1-incubating] found in catalog
> remote
> Downloading:
> http://repo.maven.apache.org/maven2/org/apache/flink/flink-quickstart-scala/0.7-incubating/flink-quickstart-scala-0.7-incubating.jar
> [INFO]
> ------------------------------------------------------------------------
> [INFO] BUILD FAILURE
> [INFO]
> ------------------------------------------------------------------------
> [INFO] Total time: 18.857s
> [INFO] Finished at: Fri Sep 26 10:17:49 CEST 2014
> [INFO] Final Memory: 12M/104M
> [INFO]
> ------------------------------------------------------------------------
> [ERROR] Failed to execute goal
> org.apache.maven.plugins:maven-archetype-plugin:2.2:generate (default-cli)
> on project standalone-pom: The desired archetype does not exist
> (org.apache.flink:flink-quickstart-scala:0.7-incubating) -> [Help 1]
>
>
> Is there some explanation how to move code from 0.6 to 0.7? Or an example
> which creates a Plan?
>
> Thanks!
> Cheers,
> Max
>
>

Mime
View raw message