[jira] [Assigned] (FLINK-8139) Check for proper equals() and hashCode() when registering a table

[ https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned FLINK-8139: --- Assignee: Aegeaner > Check for proper equals() and hashCode() when registering a table >

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264969#comment-16264969 ] ASF GitHub Bot commented on FLINK-7406: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #4509: [FLINK-7406][network] Implement Netty receiver incoming p...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4509 @NicoK , thanks for your reviews on Thanksgiving day. I have updated the codes addressed your comments. : ) ---

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264930#comment-16264930 ] ASF GitHub Bot commented on FLINK-7406: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152899386 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[jira] [Resolved] (FLINK-7877) Fix compilation against the Hadoop 3 beta1 release

[ https://issues.apache.org/jira/browse/FLINK-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-7877. --- Resolution: Cannot Reproduce The UtilsTest code has been refactored. > Fix compilation against the Hadoop 3

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264911#comment-16264911 ] ASF GitHub Bot commented on FLINK-7406: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152894450 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[jira] [Updated] (FLINK-7795) Utilize error-prone to discover common coding mistakes

[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7795: -- Description: http://errorprone.info/ is a tool which detects common coding mistakes. We should incorporate

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264906#comment-16264906 ] ASF GitHub Bot commented on FLINK-7406: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152893996 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -572,20 +560,53 @@ void

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264905#comment-16264905 ] ASF GitHub Bot commented on FLINK-7406: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152893854 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -475,16 +515,10 @@ public

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264832#comment-16264832 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4581: [FLINK-7499][io] fix double buffer release in SpillableSu...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4581 ok, fixed ---

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264825#comment-16264825 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4581: [FLINK-7499][io] fix double buffer release in SpillableSu...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4581 ok, now I'm using the buffer incorrectly in `SpillableSubpartition#add`...let me re-think it once more ---

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264718#comment-16264718 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264722#comment-16264722 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264721#comment-16264721 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264719#comment-16264719 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264720#comment-16264720 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152860672 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -301,81 +306,388 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152861040 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -465,7 +505,7 @@ public Void

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152862469 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -475,16 +515,10 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152860980 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -506,36 +540,22 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152861029 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -440,21 +476,25 @@ public

[jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler

[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264709#comment-16264709 ] ASF GitHub Bot commented on FLINK-7694: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4757: [FLINK-7694][REST][Webfrontend]Port JobMetricsHandler to ...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4757 Hi @GJL , you can take over this PR ---

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264706#comment-16264706 ] ASF GitHub Bot commented on FLINK-6505: --- Github user bowenli86 closed the pull request at:

[GitHub] flink pull request #4798: [FLINK-6505] Proactively cleanup local FS for Rock...

Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4798 ---

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264697#comment-16264697 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264696#comment-16264696 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264701#comment-16264701 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152859769 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -715,4 +686,58 @@ private

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264692#comment-16264692 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152858602 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152836741 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -572,20 +560,53 @@ void

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264699#comment-16264699 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264695#comment-16264695 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264691#comment-16264691 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152856498 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152855823 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152859775 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -715,4 +686,58 @@ private

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152857580 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264690#comment-16264690 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152853208 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -572,20 +560,53 @@ void

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264698#comment-16264698 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152859069 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -301,81 +306,388 @@ public

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264689#comment-16264689 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152852133 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -572,20 +560,53 @@ void

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264694#comment-16264694 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264700#comment-16264700 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152854762 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -306,51 +306,88 @@ public

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264693#comment-16264693 ] ASF GitHub Bot commented on FLINK-7406: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152859784 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -715,4 +686,58 @@ private

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r152860104 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -301,81 +306,388 @@ public

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264667#comment-16264667 ] ASF GitHub Bot commented on FLINK-8125: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5059: [FLINK-8125] [core] Introduce limiting of file system con...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5059 Addressed the comment. ---

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264664#comment-16264664 ] ASF GitHub Bot commented on FLINK-8125: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5059: [FLINK-8125] [core] Introduce limiting of file sys...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5059#discussion_r152856201 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java --- @@ -0,0 +1,1097 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264659#comment-16264659 ] ASF GitHub Bot commented on FLINK-8125: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5059: [FLINK-8125] [core] Introduce limiting of file sys...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5059#discussion_r152854733 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java --- @@ -0,0 +1,1097 @@ +/* + * Licensed to the

[GitHub] flink pull request #5059: [FLINK-8125] [core] Introduce limiting of file sys...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5059#discussion_r152854163 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java --- @@ -0,0 +1,1097 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264655#comment-16264655 ] ASF GitHub Bot commented on FLINK-8125: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-8125) Support limiting the number of open FileSystem connections

[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264652#comment-16264652 ] ASF GitHub Bot commented on FLINK-8125: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5059: [FLINK-8125] [core] Introduce limiting of file sys...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5059#discussion_r152853859 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java --- @@ -0,0 +1,1097 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264638#comment-16264638 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264633#comment-16264633 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152850290 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -320,4 +559,40 @@ void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264629#comment-16264629 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152849820 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264620#comment-16264620 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152849113 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264605#comment-16264605 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152847273 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264593#comment-16264593 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152845922 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java --- @@ -145,6 +165,45 @@ protected void

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152842686 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java --- @@ -95,20 +95,23 @@ public boolean

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264573#comment-16264573 ] ASF GitHub Bot commented on FLINK-7499: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152841030 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java --- @@ -267,28 +268,29 @@ public ResultPartitionType

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264559#comment-16264559 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152829734 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -320,4 +559,40 @@ void

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152822778 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java --- @@ -95,20 +95,23 @@ public boolean

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152826013 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java --- @@ -145,6 +165,45 @@ protected void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264557#comment-16264557 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152826521 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264553#comment-16264553 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264552#comment-16264552 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264558#comment-16264558 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152825430 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java --- @@ -267,28 +268,29 @@ public

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152827018 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152826839 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264556#comment-16264556 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264554#comment-16264554 ] ASF GitHub Bot commented on FLINK-7499: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4581: [FLINK-7499][io] fix double buffer release in Spil...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4581#discussion_r152837725 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -300,6 +315,230 @@ public void

[jira] [Commented] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264547#comment-16264547 ] ASF GitHub Bot commented on FLINK-7718: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5055: [FLINK-7718] [flip6] Add JobVertexMetricsHandler t...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5055#discussion_r152837007 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/metrics/MetricsFilterParameterTest.java --- @@ -0,0 +1,51 @@ +/* + *

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16264526#comment-16264526 ] ASF GitHub Bot commented on FLINK-6094: --- Github user twalthr commented on a diff in the pull

  1   2   3   >