[jira] [Assigned] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7716: --- Assignee: Bowen Li > Port JobManagerMetricsHandler to new REST endpoint >

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

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7718: --- Assignee: Bowen Li > Port JobVertixMetricsHandler to new REST endpoint >

[GitHub] flink issue #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler to supp...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4700 Thanks for the review @zentol. Rebasing onto the latest #4697 version. ---

[GitHub] flink issue #4697: [FLINK-7650] [flip6] Port JobCancellationHandler to new R...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4697 Thanks for the review @zentol. I've rebased it and wait for Travis. ---

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182826#comment-16182826 ] ASF GitHub Bot commented on FLINK-7650: --- Github user tillrohrmann commented on the issue:

[jira] [Updated] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

2017-09-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7699: --- Summary: Define the BufferListener interface to replace EventListener in BufferProvider (was: Define

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182812#comment-16182812 ] ASF GitHub Bot commented on FLINK-7699: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182817#comment-16182817 ] ASF GitHub Bot commented on FLINK-7663: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

2017-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4699 ---

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182814#comment-16182814 ] ASF GitHub Bot commented on FLINK-7699: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182815#comment-16182815 ] ASF GitHub Bot commented on FLINK-7699: --- Github user NicoK commented on a diff in the pull request:

[jira] [Closed] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

2017-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7663. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 9a97dcdff6c7d383c3bb9c9aa7b83bde7ea5fd64 >

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182811#comment-16182811 ] ASF GitHub Bot commented on FLINK-7699: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141393650 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -87,6 +88,12 @@ /** The

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141392162 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -313,6 +320,49 @@ public int

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182813#comment-16182813 ] ASF GitHub Bot commented on FLINK-7699: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141392529 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -87,6 +88,12 @@ /** The

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141387553 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -313,6 +320,49 @@ public int

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141388702 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java --- @@ -211,10 +210,15 @@ public void

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182808#comment-16182808 ] ASF GitHub Bot commented on FLINK-7663: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if HandlerRequest...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4699 Thanks for the review @zentol. Failing test is unrelated. Merging this PR. ---

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182807#comment-16182807 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182801#comment-16182801 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #4728: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph b...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4728 Thanks for the review @zentol and @tzulitai. @zentol yes you are right. The Flip-6 `JobMaster` will only return the `ArchivedExecutionGraph`. I intend to set the `timeToLive` for the

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141392589 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141392208 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182797#comment-16182797 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182790#comment-16182790 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141391659 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182787#comment-16182787 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141391097 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182784#comment-16182784 ] ASF GitHub Bot commented on FLINK-7683: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141390556 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -190,6 +193,39 @@ protected

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182781#comment-16182781 ] ASF GitHub Bot commented on FLINK-7683: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141390478 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -190,6 +193,39 @@ protected

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141389893 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/JobConfigHandler.java --- @@ -42,7 +42,7 @@ private

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182778#comment-16182778 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182776#comment-16182776 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182774#comment-16182774 ] ASF GitHub Bot commented on FLINK-7668: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141389580 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,182 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141389329 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,180 @@ +/* + *

[jira] [Commented] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN

2017-09-27 Thread Mikhail Pryakhin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182768#comment-16182768 ] Mikhail Pryakhin commented on FLINK-6950: - [~rmetzger] Hi Robert, yes I am, shall I assign the

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182764#comment-16182764 ] ASF GitHub Bot commented on FLINK-7650: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4697: [FLINK-7650] [flip6] Port JobCancellationHandler to new R...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4697 I guess some of the problems like taking a savepoint could still be served under `/jobs/:jobid/savepoints/:savepointid` because this resource will be removed upon first request anyway.

[jira] [Created] (FLINK-7720) Centralize creation of backends and state related resources

2017-09-27 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-7720: - Summary: Centralize creation of backends and state related resources Key: FLINK-7720 URL: https://issues.apache.org/jira/browse/FLINK-7720 Project: Flink

[jira] [Created] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming

2017-09-27 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-7719: - Summary: Send checkpoint id to task as part of deployment descriptor when resuming Key: FLINK-7719 URL: https://issues.apache.org/jira/browse/FLINK-7719 Project:

[jira] [Commented] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182748#comment-16182748 ] ASF GitHub Bot commented on FLINK-7371: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-09-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4736 [FLINK-7371] [table] Add support for constant parameters in OVER aggregate ## What is the purpose of the change This PR allows to pass constants to OVER window aggregates. E.g.

[jira] [Commented] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182743#comment-16182743 ] ASF GitHub Bot commented on FLINK-7514: --- Github user NicoK commented on the issue:

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

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

[GitHub] flink issue #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerITCase re...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4591 rebased to make it mergable again ---

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

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141380216 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java --- @@ -193,7 +193,8 @@ private void

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

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141380483 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -169,95 +182,19 @@ public

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

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182740#comment-16182740 ] 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...

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141380052 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

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

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

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

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182728#comment-16182728 ] 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...

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141378307 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

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

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

[jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7713: -- Assignee: Tzu-Li (Gordon) Tai > Port JarUploadHandler to new REST endpoint >

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

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141377249 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

[jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7711: -- Assignee: Tzu-Li (Gordon) Tai > Port JarListHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7714: -- Assignee: Tzu-Li (Gordon) Tai > Port JarPlanHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7712: -- Assignee: Tzu-Li (Gordon) Tai > Port JarDeleteHandler to new REST endpoint >

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

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182731#comment-16182731 ] 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...

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141377976 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

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

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141377486 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

[jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7715: -- Assignee: Tzu-Li (Gordon) Tai > Port JarRunHandler to new REST endpoint >

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

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

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

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182724#comment-16182724 ] 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...

2017-09-27 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141376844 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + *

[jira] [Commented] (FLINK-7428) avoid one additional buffer copy when receiving messages

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182715#comment-16182715 ] ASF GitHub Bot commented on FLINK-7428: --- Github user NicoK commented on the issue:

[jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-09-27 Thread Martin Luy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182713#comment-16182713 ] Martin Luy edited comment on FLINK-5506 at 9/27/17 3:14 PM: Same problem here

[GitHub] flink issue #4529: [FLINK-7428][network] avoid buffer copies when receiving ...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4529 I haven't had time to test this yet - I doubt that this is simply solved by using our memory segments but I need to understand the problem better. Maybe this also goes away with [flow

[jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-09-27 Thread Martin Luy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182713#comment-16182713 ] Martin Luy edited comment on FLINK-5506 at 9/27/17 3:12 PM: Same problem here:

[jira] [Commented] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-09-27 Thread Martin Luy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182713#comment-16182713 ] Martin Luy commented on FLINK-5506: --- Same problem here: {code:scala} val env =

[jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-09-27 Thread Martin Luy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182713#comment-16182713 ] Martin Luy edited comment on FLINK-5506 at 9/27/17 3:12 PM: Same problem here:

[jira] [Created] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7716: -- Summary: Port JobManagerMetricsHandler to new REST endpoint Key: FLINK-7716 URL: https://issues.apache.org/jira/browse/FLINK-7716 Project: Flink

[jira] [Created] (FLINK-7715) Port JarRunHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7715: -- Summary: Port JarRunHandler to new REST endpoint Key: FLINK-7715 URL: https://issues.apache.org/jira/browse/FLINK-7715 Project: Flink Issue

[GitHub] flink pull request #4518: [FLINK-7412][network] optimise NettyMessage.TaskEv...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4518#discussion_r141373324 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -440,12 +440,11 @@ ByteBuf write(ByteBufAllocator

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7718: -- Summary: Port JobVertixMetricsHandler to new REST endpoint Key: FLINK-7718 URL: https://issues.apache.org/jira/browse/FLINK-7718 Project: Flink

[jira] [Created] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7717: -- Summary: Port TaskManagerMetricsHandler to new REST endpoint Key: FLINK-7717 URL: https://issues.apache.org/jira/browse/FLINK-7717 Project: Flink

[jira] [Commented] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182704#comment-16182704 ] ASF GitHub Bot commented on FLINK-7412: --- Github user NicoK commented on a diff in the pull request:

[jira] [Created] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7712: -- Summary: Port JarDeleteHandler to new REST endpoint Key: FLINK-7712 URL: https://issues.apache.org/jira/browse/FLINK-7712 Project: Flink Issue

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182698#comment-16182698 ] ASF GitHub Bot commented on FLINK-7411: --- Github user NicoK commented on the issue:

[jira] [Created] (FLINK-7714) Port JarPlanHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7714: -- Summary: Port JarPlanHandler to new REST endpoint Key: FLINK-7714 URL: https://issues.apache.org/jira/browse/FLINK-7714 Project: Flink Issue

[jira] [Created] (FLINK-7711) Port JarListHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7711: -- Summary: Port JarListHandler to new REST endpoint Key: FLINK-7711 URL: https://issues.apache.org/jira/browse/FLINK-7711 Project: Flink Issue

[jira] [Created] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7713: -- Summary: Port JarUploadHandler to new REST endpoint Key: FLINK-7713 URL: https://issues.apache.org/jira/browse/FLINK-7713 Project: Flink Issue

[GitHub] flink issue #4517: [FLINK-7411][network] minor performance improvements in N...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4517 how about now? ---

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182684#comment-16182684 ] ASF GitHub Bot commented on FLINK-7650: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141370485 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed

[jira] [Created] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7710: -- Summary: Port CheckpointStatsHandler to new REST endpoint Key: FLINK-7710 URL: https://issues.apache.org/jira/browse/FLINK-7710 Project: Flink

[jira] [Created] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7709: -- Summary: Port CheckpointStatsDetailsHandler to new REST endpoint Key: FLINK-7709 URL: https://issues.apache.org/jira/browse/FLINK-7709 Project: Flink

[jira] [Created] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7708: -- Summary: Port CheckpointConfigHandler to new REST endpoint Key: FLINK-7708 URL: https://issues.apache.org/jira/browse/FLINK-7708 Project: Flink

[jira] [Created] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7707: -- Summary: Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint Key: FLINK-7707 URL: https://issues.apache.org/jira/browse/FLINK-7707 Project:

[jira] [Created] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7706: -- Summary: Port JobAccumulatorsHandler to new REST endpoint Key: FLINK-7706 URL: https://issues.apache.org/jira/browse/FLINK-7706 Project: Flink

[jira] [Created] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7705: -- Summary: Port JobDetailsHandler to new REST endpoint Key: FLINK-7705 URL: https://issues.apache.org/jira/browse/FLINK-7705 Project: Flink Issue

[jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Labels: flip-6 (was: ) > Port JobExceptionsHandler to new REST endpoint >

[jira] [Created] (FLINK-7704) Port JobPlanHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7704: -- Summary: Port JobPlanHandler to new REST endpoint Key: FLINK-7704 URL: https://issues.apache.org/jira/browse/FLINK-7704 Project: Flink Issue

[jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Description: Port existing {{JobExceptionsHandler}} to new REST endpoint. > Port

<    1   2   3   4   5   >