Comments (4)
Hi @Harish-Sridhar, could you show me your build.sbt or the dependencies file you're using?
Anyway, I tried to reproduce the error on my local machine, with this build.sbt:
ThisBuild / resolvers ++= Seq(
"Apache Development Snapshot Repository" at "https://repository.apache.org/content/repositories/snapshots/",
Resolver.mavenLocal
)
name := "flink-with-jpmml"
version := "0.1-SNAPSHOT"
organization := "io.ffrontera"
ThisBuild / scalaVersion := "2.11.12"
val flinkVersion = "1.6.2"
val flinkDependencies = Seq(
"org.apache.flink" %% "flink-scala" % flinkVersion % "provided",
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion % "provided",
"io.radicalbit" %% "flink-jpmml-scala" % "0.6.3"
)
lazy val root = (project in file(".")).
settings(
libraryDependencies ++= flinkDependencies
)
assembly / mainClass := Some("io.ffrontera.Job")
// make run command include the provided dependencies
Compile / run := Defaults.runTask(Compile / fullClasspath,
Compile / run / mainClass,
Compile / run / runner
).evaluated
// stays inside the sbt console when we press "ctrl-c" while a Flink programme executes with "run" or "runMain"
Compile / run / fork := true
Global / cancelable := true
// exclude Scala library from assembly
assembly / assemblyOption := (assembly / assemblyOption).value.copy(includeScala = false)
The error same not appear, when build the project.
Regards,
Francesco.
from flink-jpmml.
@Harish-Sridhar any update on this?
Were you able to solve this?
from flink-jpmml.
Hi,
When I use the below SBT configuration, the build was successful, but when I run the program I was getting error about JPMML modules not existing in classpath.
name := "flink-jpmml-test"
version := "0.1"
scalaVersion := "2.11.11"
resolvers ++= Seq(
"Radicalbit Releases" at "https://tools.radicalbit.io/artifactory/public-release/"
)
libraryDependencies ++= Seq("io.radicalbit" %% "flink-jpmml-scala" % "0.6.3",
"org.apache.flink" %% "flink-streaming-scala" % "1.7.2",
"org.apache.flink" %% "flink-scala" % "1.7.2"
)
But when I added the necessary dependencies it all went fine.
Following build configuration worked.
name := "flink-jpmml-test"
version := "0.1"
scalaVersion := "2.11.11"
resolvers ++= Seq(
"Radicalbit Releases" at "https://tools.radicalbit.io/artifactory/public-release/"
)
libraryDependencies ++= Seq("io.radicalbit" %% "flink-jpmml-scala" % "0.6.3",
"org.apache.flink" %% "flink-streaming-scala" % "1.7.2",
"org.apache.flink" %% "flink-scala" % "1.7.2",
"org.jpmml" % "pmml-evaluator" % "1.3.9",
// I needed to provided the below dependency because I was using Java10.
"org.glassfish.jaxb" % "jaxb-runtime" % "2.3.2"
)
from flink-jpmml.
HI @Harish-Sridhar, I tried to run your github project without the listed dependencies:
name := "flink-jpmml-test"
version := "0.1"
scalaVersion := "2.11.11"
resolvers ++= Seq(
"Radicalbit Releases" at "https://tools.radicalbit.io/artifactory/public-release/",
//"Sonatype OSS Snapshots" at "https://oss.sonatype.org/content/repositories/snapshots"
)
libraryDependencies ++= Seq("io.radicalbit" %% "flink-jpmml-scala" % "0.6.3",
"org.apache.flink" %% "flink-streaming-scala" % "1.7.2",
"org.apache.flink" %% "flink-scala" % "1.7.2",
/*"org.jpmml" % "pmml-evaluator" % "1.3.9",*/
/*"org.glassfish.jaxb" % "jaxb-runtime" % "2.3.2",*/
"org.apache.kafka" % "kafka-clients" % "2.1.0",
"com.storm-enroute" %% "scalameter" % "0.17"
//, "org.slf4j" % "slf4j-simple" % "1.7.9"
)
mainClass in assembly := Some("org.hs.flink.jpmml.test.AppsDTree")
testFrameworks += new TestFramework(
"org.scalameter.ScalaMeterFramework")
logBuffered := false
parallelExecution in Test := false
The run it's done correctly in my local machine. I recommend you to run sbt clean
and reload
before run the project.
Regards,
Francesco.
from flink-jpmml.
Related Issues (20)
- Exposing summary method on PmmlModel
- Ensure tests execution during sbt assembly
- Move all the exceptions in a separate package
- Employing flink-spec as a separate library HOT 2
- Refactoring ControlStream management
- Adding Changelog file
- Enrich Exception description in README file
- Add maven libraries version badges HOT 1
- Override `toString` method in `ModelId`
- Remove requirement for `streaming-scala` Flink library on ServingMessage import
- Quick evaluate method should have a different name in respect of the traditional one
- Update flink version
- Update jpmml version to 1.4.0
- Update flink 1.3 to latest minor version
- Unresolved Dependencies io.radicalbit#flink-streaming-spec_2.11;0.3.0: not found HOT 3
- Integer Type Target value not supported HOT 1
- Can't load models in a Flink Cluster setup HOT 2
- Evaluate removing hadoop dependencies
- README.md - Library imports
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from flink-jpmml.