[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout {co

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout {co

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849540#comment-16849540 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:47 AM: -

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout {co

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849541#comment-16849541 ] Aljoscha Krettek commented on FLINK-12619: -- Before starting work on this, could

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849540#comment-16849540 ] lamber-ken commented on FLINK-12302: By the way, can you help me to review my anothe

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} // code placeholder {code} `org.apache.flink.runtime.rest.RestClientTe

[jira] [Created] (FLINK-12646) Fix broken tests of RestClientTest

Victor Wong created FLINK-12646: --- Summary: Fix broken tests of RestClientTest Key: FLINK-12646 URL: https://issues.apache.org/jira/browse/FLINK-12646 Project: Flink Issue Type: Bug Co

[jira] [Assigned] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken reassigned FLINK-12302: -- Assignee: (was: lamber-ken) > Fixed the wrong finalStatus of yarn application when applic

[GitHub] [flink] lamber-ken closed pull request #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished

lamber-ken closed pull request #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished URL: https://github.com/apache/flink/pull/8265 This is an automated message from the Apac

[GitHub] [flink] aljoscha commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

aljoscha commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8280#issuecomment-496444636 Thanks for your contribution, I'm on vacation for the end of this week but I will review when I get back next week. 👌

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:43 AM: -

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r288014488 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.j

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:42 AM: -

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r288014074 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.j

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r288015417 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.j

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537 ] lamber-ken commented on FLINK-12302: Hi [~gjy], Thanks for your detail explain. I

[jira] [Commented] (FLINK-12578) Use secure URLs for Maven repositories

[ https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849528#comment-16849528 ] Chesnay Schepler commented on FLINK-12578: -- Got nothing to report yet. > Use s

[jira] [Commented] (FLINK-12578) Use secure URLs for Maven repositories

[ https://issues.apache.org/jira/browse/FLINK-12578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849523#comment-16849523 ] Till Rohrmann commented on FLINK-12578: --- Any updates on this? > Use secure URLs f

[GitHub] [flink] dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system

dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555#discussion_r287956447 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/ty

[GitHub] [flink] dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system

dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555#discussion_r287961719 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/ty

[GitHub] [flink] dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system

dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555#discussion_r287971465 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/ty

[GitHub] [flink] dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system

dawidwys commented on a change in pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555#discussion_r287955235 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/ty

[GitHub] [flink] tillrohrmann commented on issue #8011: [FLINK-11958][on-yarn] fix flink on windows yarn deploy failed

tillrohrmann commented on issue #8011: [FLINK-11958][on-yarn] fix flink on windows yarn deploy failed URL: https://github.com/apache/flink/pull/8011#issuecomment-496438119 @Matrix42 are you gonna fix both problems now? This i

[jira] [Closed] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode

[ https://issues.apache.org/jira/browse/FLINK-12600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12600. -- Resolution: Implemented Fix Version/s: 1.9.0 merged in 1.9.0: b333ddc16967ae7428229d659130b61de

[GitHub] [flink] KurtYoung merged pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode

KurtYoung merged pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode URL: https://github.com/apache/flink/pull/8520 This is an automated message from the A

[jira] [Commented] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849515#comment-16849515 ] Chesnay Schepler commented on FLINK-12642: -- Checking for null is a fair solutio

[jira] [Updated] (FLINK-11107) Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11107: Fix Version/s: 1.8.1 > Avoid memory stateBackend to create arbitrary folders under

[jira] [Commented] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849508#comment-16849508 ] zhijiang commented on FLINK-12642: -- Thanks for reporting this [~Zentol]! I think we co

[GitHub] [flink] zentol commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml

zentol commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml URL: https://github.com/apache/flink/pull/8526#issuecomment-496428778 We have to update the documentation somehow. Either remove it entirely, blank it if you want to re-use the pages later on, or

[GitHub] [flink] Aitozi commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

Aitozi commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287987505 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tas

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849473#comment-16849473 ] Gary Yao commented on FLINK-12302: -- Hi [~lamber-ken], Thanks for the update. If I unde

[jira] [Created] (FLINK-12645) high parallelism e2e test fails due to missing disk space

Chesnay Schepler created FLINK-12645: Summary: high parallelism e2e test fails due to missing disk space Key: FLINK-12645 URL: https://issues.apache.org/jira/browse/FLINK-12645 Project: Flink

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287981908 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287981228 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287808919 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287728381 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287716344 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287982473 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287730068 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

StefanRRichter commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r287809969 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[jira] [Updated] (FLINK-12643) Implement ExecutionGraph to FailoverTopology Adapter

[ https://issues.apache.org/jira/browse/FLINK-12643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-12643: Description: Implement an adapter, which adapts the ExecutionGraph and its sub-components(ExecutionVertex

[GitHub] [flink] StefanRRichter commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

StefanRRichter commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r287979434 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityListe

[jira] [Created] (FLINK-12643) Implement ExecutionGraph to FailoverTopology Adapter

Zhu Zhu created FLINK-12643: --- Summary: Implement ExecutionGraph to FailoverTopology Adapter Key: FLINK-12643 URL: https://issues.apache.org/jira/browse/FLINK-12643 Project: Flink Issue Type: Task

[GitHub] [flink] StefanRRichter commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

StefanRRichter commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r287978776 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityListe

[jira] [Created] (FLINK-12644) Setup Java 9 cron jobs

Chesnay Schepler created FLINK-12644: Summary: Setup Java 9 cron jobs Key: FLINK-12644 URL: https://issues.apache.org/jira/browse/FLINK-12644 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849455#comment-16849455 ] Chesnay Schepler edited comment on FLINK-12642 at 5/28/19 8:08 AM: ---

[jira] [Commented] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849455#comment-16849455 ] Chesnay Schepler commented on FLINK-12642: -- [~zjwang][~azagrebin] > OutputBuff

[jira] [Created] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE

Chesnay Schepler created FLINK-12642: Summary: OutputBufferPoolUsageGauge can fail with NPE Key: FLINK-12642 URL: https://issues.apache.org/jira/browse/FLINK-12642 Project: Flink Issue Ty

[GitHub] [flink] dianfu commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

dianfu commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API URL: https://github.com/apache/flink/pull/8532#issuecomment-496409121 @sunjincheng121 Great, I have rebased the PR. Thi

[jira] [Assigned] (FLINK-12638) Expose max parallelism via the REST API and via the Web UI

[ https://issues.apache.org/jira/browse/FLINK-12638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-12638: Assignee: vinoyang > Expose max parallelism via the REST API and via the Web UI > ---

[jira] [Commented] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

[ https://issues.apache.org/jira/browse/FLINK-11970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849439#comment-16849439 ] Jeff Zhang commented on FLINK-11970: ping [~tiwalter] What do you think about this f

[jira] [Assigned] (FLINK-9699) Add api to replace registered table

[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-9699: - Assignee: (was: Jeff Zhang) > Add api to replace registered table >

[jira] [Created] (FLINK-12641) Add partition release logic from JM -> TM

Chesnay Schepler created FLINK-12641: Summary: Add partition release logic from JM -> TM Key: FLINK-12641 URL: https://issues.apache.org/jira/browse/FLINK-12641 Project: Flink Issue Type:

[GitHub] [flink] sunjincheng121 commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

sunjincheng121 commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API URL: https://github.com/apache/flink/pull/8532#issuecomment-496402440 Thanks for your PR. @dianfu! I have merged the https://issues.apache.org/jira/browse/FLINK-12327, so pl

[jira] [Closed] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

[ https://issues.apache.org/jira/browse/FLINK-12327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12327. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 8510e294802c096418cdc121b21d64de630c2

[GitHub] [flink] asfgit closed pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

asfgit closed pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472 This is an automated message from the Apache Git Service. To r

[jira] [Created] (FLINK-12640) mvn install flink-shaded-hadoop2-uber: Error creating shaded jar: null

xiezhiqiang created FLINK-12640: --- Summary: mvn install flink-shaded-hadoop2-uber: Error creating shaded jar: null Key: FLINK-12640 URL: https://issues.apache.org/jira/browse/FLINK-12640 Project: Flink

[jira] [Commented] (FLINK-9465) Separate timeout for savepoint and checkpoint

[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849406#comment-16849406 ] vinoyang commented on FLINK-9465: - Hi [~till.rohrmann] [~srichter] and [~gyfora] What do

[jira] [Closed] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10884. Resolution: Won't Fix See https://github.com/apache/flink/pull/7185#issuecomment-447890879 > Flink on yar

[GitHub] [flink] GJL commented on issue #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

GJL commented on issue #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185#issuecomment-496394685 I am closing this PR for now. Feel free to reopen if needed. ---

[GitHub] [flink] GJL closed pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

GJL closed pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185 This is an automated message from the Apache

[GitHub] [flink] godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode

godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode URL: https://github.com/apache/flink/pull/8520#discussion_r287949754 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] pnowojski commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

pnowojski commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r287955940 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityListener.j

[jira] [Created] (FLINK-12639) FLIP-42: Rework Documentation

Konstantin Knauf created FLINK-12639: Summary: FLIP-42: Rework Documentation Key: FLINK-12639 URL: https://issues.apache.org/jira/browse/FLINK-12639 Project: Flink Issue Type: Improvement

<    1   2   3