[GitHub] flink pull request #4915: [FLINK-7838] Bunch of hotfixes and fix missing syn...

[GJL]

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

    https://github.com/apache/flink/pull/4915#discussion_r147689963
  
    --- Diff: 
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
 ---
    @@ -483,11 +478,6 @@ public void setLogFailuresOnly(boolean 
logFailuresOnly) {
         */
        @Override
        public void open(Configuration configuration) throws Exception {
    -           if (semantic != Semantic.NONE && !((StreamingRuntimeContext) 
this.getRuntimeContext()).isCheckpointingEnabled()) {
    --- End diff --
    
    ok


---