Re: Re: MiniClusterResource class not found using AbstractTestBase

2019-07-23 Thread Juan Rodríguez Hortalá
Using that classifier worked, the code builds fine now, thanks a lot. I'm
using 1.8.0 by the way

Greetings,

Juan

On Tue, Jul 23, 2019 at 5:06 AM Haibo Sun  wrote:

> Hi,  Juan
>
> It is dependent on "flink-runtime-*-tests.jar", so build.sbt should be
> modified as follows:
>
> *scalaVersion := "2.11.0"*
>
> *val flinkVersion = "1.8.1"*
>
> *libraryDependencies ++= Seq(*
> *  "org.apache.flink" %% "flink-test-utils" % flinkVersion % Test,*
> *  "org.apache.flink" %% "flink-runtime" % flinkVersion % Test **classifier
> "tests"*
> *)*
>
> Best,
> Haibo
>
> At 2019-07-23 17:51:23, "Fabian Hueske"  wrote:
>
> 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.hort...@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
>>
>


Re:Re: MiniClusterResource class not found using AbstractTestBase

2019-07-23 Thread Haibo Sun
Hi,  Juan  


It is dependent on "flink-runtime-*-tests.jar", so build.sbt should be modified 
as follows: 


scalaVersion := "2.11.0"


val flinkVersion = "1.8.1"


libraryDependencies ++= Seq(
  "org.apache.flink" %% "flink-test-utils" % flinkVersion % Test,
  "org.apache.flink" %% "flink-runtime" % flinkVersion % Test classifier "tests"
)


Best,
Haibo

At 2019-07-23 17:51:23, "Fabian Hueske"  wrote:

Hi Juan,


Which Flink version do you use?


Best, Fabian



Am Di., 23. Juli 2019 um 06:49 Uhr schrieb Juan Rodríguez Hortalá 
:

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


Re: MiniClusterResource class not found using AbstractTestBase

2019-07-23 Thread Fabian Hueske
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.hort...@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
>


MiniClusterResource class not found using AbstractTestBase

2019-07-22 Thread Juan Rodríguez Hortalá
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