Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6097#discussion_r191460728
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java
---
@@ -50,6 +52,30 @@
@Rule
public ExpectedException expectedException = ExpectedException.none();
+ @Test
+ public void testKeyQuerying() throws Exception {
+
+ KeyedProcessOperator<Integer, Tuple2<Integer, String>, String>
operator =
+ new KeyedProcessOperator<>(new
KeyQueryingProcessFunction());
+
+ OneInputStreamOperatorTestHarness<Tuple2<Integer, String>,
String> testHarness =
+ new KeyedOneInputStreamOperatorTestHarness<>(operator,
(in) -> in.f0 , BasicTypeInfo.INT_TYPE_INFO);
+
--- End diff --
same here.
---
