Hi everyone,
I'm working to upgrade my environment to Flink v.1.6.0 and I'm facing an
issue. We're using TwoInputStreamOperatorTestHarness in our tests and after
upgrade to 1.6.0 my project compilation fails with "cannot find symbol
TwoInputStreamOperatorTestHarness".
I've reproduced the problem on a clean environment with a template project
created from maven archetype. If you include additional dependency of
TwoInputStreamOperatorTestHarness it's not able to find it. Here is the
sample program:
```
package com.five9.streaming;
import
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness;
public class StreamingJob {
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.execute("Example");
}
}
```
Maven `mvn clean package` fails with:
Caused by: org.apache.maven.plugin.compiler.CompilationFailureException:
Compilation failure
/home/dminaev/projects/belka/src/main/java/com/five9/streaming/StreamingJob.java:[22,39]
cannot find symbol
symbol: class TwoInputStreamOperatorTestHarness
location: package org.apache.flink.streaming.util
I looked up in the ".m2" local cache and found out that v.1.4.0 contains
"flink-streaming-java_2.11-1.4.0-tests.jar" which has
TwoInputStreamOperatorTestHarness.class, however, there is no
"flink-streaming-java_2.11-1.6.0-tests.jar"
included in v.1.6.0
Am I missing something and this class is deprecated or moved somewhere? I
cannot find any reference to that.
Please let me know if you have any ideas on how to fix the issue?
Kind regards,
Dmitry
--
--
Dmitry
