You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "eugen yushin (JIRA)" <ji...@apache.org> on 2018/12/19 10:47:00 UTC
[jira] [Updated] (FLINK-11201) flink-test-utils dependency issue
[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
eugen yushin updated FLINK-11201:
---------------------------------
Description:
Starting with Flink 1.7, there's lack of `runtime.testutils.MiniClusterResource` class in `flink-test-utils` distribution.
Steps to reproduce (Scala code)
build.sbt
{code}
name := "flink-17-test-issue"
organization := "x.y.z"
scalaVersion := "2.11.12"
val flinkVersion = "1.7.0"
libraryDependencies ++= Seq(
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion % Provided,
"org.scalatest" %% "scalatest" % "3.0.5" % Test,
"org.apache.flink" %% "flink-test-utils" % flinkVersion % Test
// ,"org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier Artifact.TestsClassifier
)
{code}
test class:
{code}
class SimpleTest extends AbstractTestBase with FlatSpecLike {
implicit val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
env.setParallelism(1)
env.setRestartStrategy(RestartStrategies.noRestart())
"SimpleTest" should "work" in {
val inputDs = env.fromElements(1,2,3)
inputDs.print()
env.execute()
}
}
{code}
Results in:
{code}
A needed class was not found. This could be due to an error in your runpath. Missing class: org/apache/flink/runtime/testutils/MiniClusterResource
java.lang.NoClassDefFoundError: org/apache/flink/runtime/testutils/MiniClusterResource
...
Caused by: java.lang.ClassNotFoundException: org.apache.flink.runtime.testutils.MiniClusterResource
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 31 more
{code}
This can be fixed by adding flink-runtime distribution with test classifier into dependencies list.
was:
Starting with Flink 1.7, there's lack of `runtime.testutils.MiniClusterResource` class in `flink-test-utils` distribution.
Steps to reproduce (Scala code)
build.sbt
{code}
name := "flink-17-test-issue"
organization := "x.y.z"
scalaVersion := "2.11.12"
val flinkVersion = "1.7.0"
libraryDependencies ++= Seq(
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion % Provided,
"org.scalatest" %% "scalatest" % "3.0.5" % Test,
"org.apache.flink" %% "flink-test-utils" % flinkVersion % Test
// ,"org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier Artifact.TestsClassifier
)
{code}
test class:
{code}
class SimpleTest extends AbstractTestBase with FlatSpecLike {
implicit val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
env.setParallelism(1)
env.setRestartStrategy(RestartStrategies.noRestart())
"SimpleTest" should "work" in {
val inputDs = env.fromElements(1,2,3)
inputDs.print()
env.execute()
}
}
{code}
Results in:
{code}
A needed class was not found. This could be due to an error in your runpath. Missing class: org/apache/flink/runtime/testutils/MiniClusterResource
java.lang.NoClassDefFoundError: org/apache/flink/runtime/testutils/MiniClusterResource
...
Caused by: java.lang.ClassNotFoundException: org.apache.flink.runtime.testutils.MiniClusterResource
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 31 more
{code}
This can be fixed by flink-runtime distribution with test classifier.
> flink-test-utils dependency issue
> ---------------------------------
>
> Key: FLINK-11201
> URL: https://issues.apache.org/jira/browse/FLINK-11201
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.7.0
> Reporter: eugen yushin
> Priority: Major
>
> Starting with Flink 1.7, there's lack of `runtime.testutils.MiniClusterResource` class in `flink-test-utils` distribution.
> Steps to reproduce (Scala code)
> build.sbt
> {code}
> name := "flink-17-test-issue"
> organization := "x.y.z"
> scalaVersion := "2.11.12"
> val flinkVersion = "1.7.0"
> libraryDependencies ++= Seq(
> "org.apache.flink" %% "flink-streaming-scala" % flinkVersion % Provided,
> "org.scalatest" %% "scalatest" % "3.0.5" % Test,
> "org.apache.flink" %% "flink-test-utils" % flinkVersion % Test
> // ,"org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier Artifact.TestsClassifier
> )
> {code}
> test class:
> {code}
> class SimpleTest extends AbstractTestBase with FlatSpecLike {
> implicit val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
> env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
> env.setParallelism(1)
> env.setRestartStrategy(RestartStrategies.noRestart())
> "SimpleTest" should "work" in {
> val inputDs = env.fromElements(1,2,3)
> inputDs.print()
> env.execute()
> }
> }
> {code}
> Results in:
> {code}
> A needed class was not found. This could be due to an error in your runpath. Missing class: org/apache/flink/runtime/testutils/MiniClusterResource
> java.lang.NoClassDefFoundError: org/apache/flink/runtime/testutils/MiniClusterResource
> ...
> Caused by: java.lang.ClassNotFoundException: org.apache.flink.runtime.testutils.MiniClusterResource
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> ... 31 more
> {code}
> This can be fixed by adding flink-runtime distribution with test classifier into dependencies list.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)