[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

[twalthr]

Github user twalthr commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5688#discussion_r190141550
  
    --- Diff: 
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedOneInputStreamOperatorTestHarness.java
 ---
    @@ -78,6 +82,20 @@ public int numKeyedStateEntries() {
                }
        }
     
    +   public <S extends State> S getState(K key, StateDescriptor<S, ?> 
stateDesc) throws Exception {
    --- End diff --
    
    Is this change necessary? We should only modify code outside of 
`flink-table` if it is urgently needed.


---