[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

[zhijiangW]

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

    https://github.com/apache/flink/pull/5400#discussion_r165998584
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java
 ---
    @@ -131,10 +131,14 @@ public StreamInputProcessor(
                        long maxAlign = 
taskManagerConfig.getLong(TaskManagerOptions.TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT);
                        if (!(maxAlign == -1 || maxAlign > 0)) {
                                throw new IllegalConfigurationException(
    -                                           
TaskManagerOptions.TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT.key()
    -                                           + " must be positive or -1 
(infinite)");
    +                                   
TaskManagerOptions.TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT.key()
    --- End diff --
    
    yes, i will consider a proper way


---