Hi Dmitry,
I confirmed that this class is included in the source code of Flink-1.6 [1].
I just downloaded the source code of Flink-1.6 [2], and then run *mvn
package -DskipTests* directly in the flink-streaming-java directory.
The package is successful and decompiled to see that this class exists
I wanted to follow up on this thread one last time as we found a solution for
the recovery time that worked well for us.
Originally, we were running job by using a jar that shaded in all of our
dependencies. We switched to a more lightweight jar for the job itself and made
the dependency jar an
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
