Hi team, I’m trying to write a unit test for my flink 1.16.1 application using

KeyedTwoInputStreamOperatorTestHarness

based on these docs. However I run into trouble when I try including the dependencies in my

build.sbt

"org.apache.flink" % "flink-test-utils" % "1.16.1" % _Test_

doesn’t have the class. I’ve tried looking at other peoples code and the only one that seems to work for me is

"org.apache.flink" % "flink-test-utils" % "1.19-SNAPSHOT

but this presents a lot of dependency conflicts. I see some code examples where people were including

ache.flink" % "flink-test-utils_2.11" % "1.14.2" % _Test_

which is where I assume they are getting the test harness from. Was this moved to a different package for 1.16.1 or am I going about this all wrong.