[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299005273 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/cons

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299005273 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/cons

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299012895 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/cons

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299018909 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299020912 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-07-01 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r299018794 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297625182 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297626993 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297625182 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297636767 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/St

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297632482 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297630119 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

2019-06-26 Thread GitBox
1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297633411 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/Strea