[GitHub] flink pull request #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFu...

[kl0u]

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

    https://github.com/apache/flink/pull/5500#discussion_r171253672
  
    --- Diff: 
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
 ---
    @@ -801,12 +788,12 @@ public long extractTimestamp(String element, long 
previousElementTimestamp) {
                                new BroadcastProcessFunction<Long, String, 
String>() {
                                        @Override
                                        public void 
processBroadcastElement(String value, Context ctx, Collector<String> out) 
throws Exception {
    -                                           // do nothing
    +                                           // Do nothing
    --- End diff --
    
    Remove reformatting.


---