You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@flink.apache.org by Flink CI <fl...@foxmail.com> on 2019/11/17 08:00:15 UTC

Fixed: apache/flink#41076 (master - 2c8b4ef)

|  [

apache

/

flink

](https://travis-ci.org/apache/flink)  
---  
  
![branch icon](https://s3.amazonaws.com/travis-email-
assets/branch.png)[master](https://github.com/apache/flink/tree/master)  
  
|

![build hasfailed](https://s3.amazonaws.com/travis-email-assets/status-
passed.png)

[Build #41076 fixed](https://travis-ci.org/apache/flink/builds/613011949)

![arrow to build time](https://s3.amazonaws.com/travis-email-assets/success-
arrow.png)

![clock icon](https://s3.amazonaws.com/travis-email-assets/time.png)6 hrs, 22
mins, 39 secs  
  
---  
  
![Zhijiang
avatar](https://secure.gravatar.com/avatar/92a244cca512354365c41d947baeb69e.jpg)Zhijiang

[2c8b4ef CHANGESET
->](https://github.com/apache/flink/compare/b390e216b6b7...2c8b4ef572f0)  
  
[FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput  
  
The non-blocking output was introduced in FLINK-14396 and FLINK-14498 to solve
the problem of handling the checkpoint barrier in the case of backpressure.  
  
In order to make the whole process through, StreamInputProcessor should be
allowed to process input elements if the output is also available.  
  
The default core size of LocalBufferPool for ResultPartition should also be
increased by 1 in order not to cause stuck problem and impact the performance,  
and this tiny memory overhead could be ignored in practice.