From 0df939ef56d7afc8755be3f1f62f032091ebe275 Mon Sep 17 00:00:00 2001 From: shashank734 Date: Sat, 3 Jun 2017 13:54:08 +0530 Subject: [PATCH 1/4] Fixed HalfPlusTwo, modified dependency to ExampleBuilder from FlinkTestBase --- .../apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala | 2 +- .../org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala index cf351a5..3292f9b 100644 --- a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala +++ b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala @@ -1,7 +1,7 @@ package org.apache.flink.contrib.tensorflow.io import org.apache.flink.contrib.tensorflow.models.savedmodel.DefaultSavedModelLoader -import org.apache.flink.contrib.tensorflow.util.{FlinkTestBase, RegistrationUtils} +import org.apache.flink.contrib.tensorflow.util.{ExampleBuilder, RegistrationUtils} import org.apache.flink.core.fs.Path import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.junit.runner.RunWith diff --git a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala index 2feda27..3b18261 100644 --- a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala +++ b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala @@ -7,7 +7,7 @@ import org.apache.flink.configuration.Configuration import org.apache.flink.contrib.tensorflow.ml.signatures.RegressionMethod._ import org.apache.flink.contrib.tensorflow.types.TensorInjections.{message2Tensor, messages2Tensor} import org.apache.flink.contrib.tensorflow.util.TestData._ -import org.apache.flink.contrib.tensorflow.util.{FlinkTestBase, RegistrationUtils} +import org.apache.flink.contrib.tensorflow.util.{ExampleBuilder, RegistrationUtils} import org.apache.flink.core.fs.Path import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink.util.Collector From 26ae07941c2328d136bb9cc1c60983dfbbfe8753 Mon Sep 17 00:00:00 2001 From: shashank734 Date: Sat, 3 Jun 2017 13:56:57 +0530 Subject: [PATCH 2/4] Updated flink version to 1.2.1 and tensorflow to 1.2.0-rc1 and tested --- pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index be59125..0f112ac 100644 --- a/pom.xml +++ b/pom.xml @@ -51,8 +51,8 @@ under the License. UTF-8 - 1.1.0 - 1.2.0 + 1.2.0-rc1 + 1.2.1 5.0.4 1.7.7 1.2.17 From 7d56236a3e0389009dc9e4e956ef0b6b4bc318cc Mon Sep 17 00:00:00 2001 From: shashank734 Date: Sat, 3 Jun 2017 15:09:29 +0530 Subject: [PATCH 3/4] Updated readme with installation instructions. Added Installation instructions for Maven and SBT. --- README.md | 33 +++++++++++++++++++++++++++++++++ 1 file changed, 33 insertions(+) diff --git a/README.md b/README.md index 259bd09..fbda7f8 100644 --- a/README.md +++ b/README.md @@ -10,6 +10,39 @@ Want to learn more? [See the wiki](https://github.com/cookieai/flink-tensorflow/ Help wanted! See [the project board](https://github.com/cookieai/flink-tensorflow/projects) and [the issues section](https://github.com/cookieai/flink-tensorflow/issues) for specifics. Feel free to join [the chat channel](https://gitter.im/flink-tensorflow/Lobby). +## Installation process for Maven and SBT (Local) : + +- Clone repository (Run on Terminal) +``` +git clone https://github.com/FlinkML/flink-tensorflow.git +``` + +- Publish it in local maven repository (Run on Terminal) +``` +mvn clean install +``` +Than follow : + +### For SBT +Add dependency in build.sbt +``` +libraryDependencies += "ai.cookie" %% "flink-tensorflow" % "0.1-SNAPSHOT" +``` + +**Note:** Make sure you have local maven resolver defined in build.sbt ```resolvers in ThisBuild ++= Seq(Resolver.mavenLocal)``` and ```scalaVersion in ThisBuild := "2.11.*"``` by default build has Scala 2.11 dependency. If you wants you can modify it in pom.xml and rebuild with different Scala version. + + +### For Maven +Add dependency in pom.xml +``` + + ai.cookie + flink-tensorflow_2.11 + 0.1-SNAPSHOT + +``` + + ## Disclaimer Apache®, Apache Flink™, Flink™, and the Apache feather logo are trademarks of [The Apache Software Foundation](http://apache.org). From eb4a358699b26cdece63080a30fb8ae9162fdd7f Mon Sep 17 00:00:00 2001 From: shashank734 Date: Sat, 3 Jun 2017 15:30:59 +0530 Subject: [PATCH 4/4] Revert back to FlinkTestBase as confused last time due to running in main class --- .../apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala | 2 +- .../org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala index 3292f9b..cf351a5 100644 --- a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala +++ b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/io/DefaultSaverITCase.scala @@ -1,7 +1,7 @@ package org.apache.flink.contrib.tensorflow.io import org.apache.flink.contrib.tensorflow.models.savedmodel.DefaultSavedModelLoader -import org.apache.flink.contrib.tensorflow.util.{ExampleBuilder, RegistrationUtils} +import org.apache.flink.contrib.tensorflow.util.{FlinkTestBase, RegistrationUtils} import org.apache.flink.core.fs.Path import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.junit.runner.RunWith diff --git a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala index 3b18261..2feda27 100644 --- a/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala +++ b/flink-tensorflow/src/test/scala/org/apache/flink/contrib/tensorflow/ml/RegressITCase.scala @@ -7,7 +7,7 @@ import org.apache.flink.configuration.Configuration import org.apache.flink.contrib.tensorflow.ml.signatures.RegressionMethod._ import org.apache.flink.contrib.tensorflow.types.TensorInjections.{message2Tensor, messages2Tensor} import org.apache.flink.contrib.tensorflow.util.TestData._ -import org.apache.flink.contrib.tensorflow.util.{ExampleBuilder, RegistrationUtils} +import org.apache.flink.contrib.tensorflow.util.{FlinkTestBase, RegistrationUtils} import org.apache.flink.core.fs.Path import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink.util.Collector