flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: MiniClusterResource class not found using AbstractTestBase
Date Tue, 23 Jul 2019 09:51:23 GMT
Hi Juan,

Which Flink version do you use?

Best, Fabian

Am Di., 23. Juli 2019 um 06:49 Uhr schrieb Juan Rodríguez Hortalá <
juan.rodriguez.hortala@gmail.com>:

> Hi,
>
> I'm trying to use AbstractTestBase in a test in order to use the mini
> cluster. I'm using specs2 with Scala, so I cannot extend AbstractTestBase
> because I also have to extend org.specs2.Specification, so I'm trying to
> access the mini cluster directly using Specs2 BeforeAll to initialize it as
> follows
>
> private val miniClusterResource = AbstractTestBase.miniClusterResource
> miniClusterResource.before()
>
>
> The problem is that the code doesn't even compile, because it fails to
> locate `org.apache.flink.runtime.testutils.MiniClusterResource`
>
> ```
> [warn] Class org.apache.flink.runtime.testutils.MiniClusterResource not
> found - continuing with a stub.
> [warn] Class
> org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration not
> found - continuing with a stub.
> [error] Class org.apache.flink.runtime.testutils.MiniClusterResource not
> found - continuing with a stub.
> [warn] two warnings found
> [error] one error found
> [error] (Compile / compileIncremental) Compilation failed
> [error] Total time: 1 s, completed Jul 22, 2019 9:38:49 PM
> ```
>
> I'm importing the following libraries in build.sbt
>
> "org.apache.flink" %% "flink-test-utils"  % flinkVersion,
> "org.apache.flink" %% "flink-runtime"  % flinkVersion
>
>
> Am I missing some additional library?
>
> Thanks,
>
> Juan
>

Mime
View raw message