[jira] [Created] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc

2017-10-11 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7820: --- Summary: remove text related to FoldingState and FoldingStateDescriptor from doc Key: FLINK-7820 URL: https://issues.apache.org/jira/browse/FLINK-7820 Project: Flink

[jira] [Comment Edited] (FLINK-7816) Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200786#comment-16200786 ] Hai Zhou UTC+8 edited comment on FLINK-7816 at 10/12/17 5:39 AM: ---

[jira] [Created] (FLINK-7819) Check object to clean is closure

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
Hai Zhou UTC+8 created FLINK-7819: - Summary: Check object to clean is closure Key: FLINK-7819 URL: https://issues.apache.org/jira/browse/FLINK-7819 Project: Flink Issue Type: Bug Co

[jira] [Assigned] (FLINK-7475) ListState support update

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7475: --- Assignee: Bowen Li > ListState support update > > > Key: FLI

[jira] [Updated] (FLINK-7671) testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7671: Description: {code:java} org.apache.flink.runtime.jobmanager.JobManagerCleanupITCase testBlobServerCleanupCa

[jira] [Updated] (FLINK-7671) testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7671: Summary: testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build (was: JobManagerClean

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201386#comment-16201386 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144186213 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -272,4 +316,53 @@ private void decode

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201368#comment-16201368 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on the issu

[GitHub] flink issue #4533: [FLINK-7416][network] Implement Netty receiver outgoing p...

2017-10-11 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4533 `notifyCreditAvailable` would be called by three logics in `RemoteInputChannel`. They are `RemoteInputChannel#recycle`, `RemoteInputChannel#notifyBufferAvailable` and `RemoteInputChannel#onSenderB

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201353#comment-16201353 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on a diff i

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144181936 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandler.java --- @@ -330,6 +330,10 @@ else if (buffe

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201350#comment-16201350 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on the issu

[GitHub] flink issue #4533: [FLINK-7416][network] Implement Netty receiver outgoing p...

2017-10-11 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4533 @pnowojski , thanks for your reviews! I should explain the context beforehand. We present the separate `CreditBasedClientHandler` in order not to affect the current logic in mast

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201263#comment-16201263 ] ASF GitHub Bot commented on FLINK-7810: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4.x

2017-10-11 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4807 wonderful! +1 ---

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201258#comment-16201258 ] Bowen Li commented on FLINK-6951: - [~aljoscha] I believe so as I've seen a couple email th

[jira] [Commented] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201187#comment-16201187 ] ASF GitHub Bot commented on FLINK-7540: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4812: [FLINK-7540] Apply consistent hostname normalizati...

2017-10-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4812 [FLINK-7540] Apply consistent hostname normalization ## What is the purpose of the change The hostname normalization is now applied when generating the remote akka config. That way

[jira] [Created] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7818: Summary: Synchronize MetricStore access in the TaskManagersHandler Key: FLINK-7818 URL: https://issues.apache.org/jira/browse/FLINK-7818 Project: Flink Issue

[jira] [Commented] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201103#comment-16201103 ] ASF GitHub Bot commented on FLINK-7806: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4805: [FLINK-7806] [flip6] Register CurrentJobsOverviewHandler ...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4805 Not sure why the changed @zentol. I just executed the build process as it was described in the readme. ---

[jira] [Commented] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201096#comment-16201096 ] Till Rohrmann commented on FLINK-7540: -- This is indeed a big problem for setups where

[GitHub] flink pull request #4811: [FLINK-7818] Synchronize MetricStore access in Tas...

2017-10-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4811 [FLINK-7818] Synchronize MetricStore access in TaskManagersHandler ## What is the purpose of the change Synchronize MetricStore access in TaskManagersHandler ## Verifying this

[jira] [Commented] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201119#comment-16201119 ] ASF GitHub Bot commented on FLINK-7818: --- GitHub user tillrohrmann opened a pull requ

[jira] [Assigned] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7540: Assignee: Till Rohrmann > Akka hostnames are not normalised consistently >

[jira] [Commented] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1620#comment-1620 ] Till Rohrmann commented on FLINK-7818: -- Once the {{MetricStore}} is thread safe, we c

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7540: - Priority: Critical (was: Blocker) > Akka hostnames are not normalised consistently >

[GitHub] flink issue #4804: [hotfix] [kafka] Fix the config parameter names in KafkaT...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4804 thanks for catching it, merging. ---

[jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201018#comment-16201018 ] ASF GitHub Bot commented on FLINK-6703: --- Github user zentol commented on the issue:

[GitHub] flink issue #4721: [FLINK-6703][savepoint/doc] Document how to take a savepo...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4721 merging. ---

[jira] [Commented] (FLINK-7774) Deserializers are not cleaned up when closing input streams

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201015#comment-16201015 ] ASF GitHub Bot commented on FLINK-7774: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7807) HandlerUtils methods should log errors

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201007#comment-16201007 ] ASF GitHub Bot commented on FLINK-7807: --- Github user zentol closed the pull request

[GitHub] flink issue #4783: [FLINK-7774][network] fix not clearing deserializers on c...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4783 merging. ---

[GitHub] flink pull request #4799: [FLINK-7807] [REST] Log exceptions in HandlerUtils...

2017-10-11 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4799 ---

[jira] [Commented] (FLINK-7808) JobDetails constructor should check length of tasksPerState array

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201002#comment-16201002 ] ASF GitHub Bot commented on FLINK-7808: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-7661) Add credit field in PartitionRequest message

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201003#comment-16201003 ] ASF GitHub Bot commented on FLINK-7661: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-7661) Add credit field in PartitionRequest message

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7661. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 891f359d710146acf3d05cd2af3bb430a8fbc99b >

[GitHub] flink pull request #4800: [FLINK-7808] [REST] JobDetails constructor checks ...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4800 ---

[GitHub] flink pull request #4791: [hotfix] [Javadoc] Fix typos

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4791 ---

[jira] [Closed] (FLINK-7807) HandlerUtils methods should log errors

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7807. --- Resolution: Fixed 1.4: a9c13c7d90253cc59749c20e6ee6e7f790cb598a > HandlerUtils methods should

[jira] [Closed] (FLINK-7808) JobDetails constructor should check length of tasksPerState array

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7808. --- Resolution: Fixed 1.4: e2ae45b48345cf56501530e101f3c8523448ab79 > JobDetails constructor shou

[GitHub] flink pull request #4797: [hotfix][doc] Remove outdated best-practice sugges...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4797 ---

[GitHub] flink pull request #4698: [FLINK-7661][network] Add credit field in Partitio...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4698 ---

[jira] [Commented] (FLINK-6926) Add MD5/SHA1/SHA2 supported in SQL

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200980#comment-16200980 ] ASF GitHub Bot commented on FLINK-6926: --- GitHub user genged opened a pull request:

[GitHub] flink pull request #4810: [FLINK-6926] [table] Add support for MD5,SHA1 and ...

2017-10-11 Thread genged
GitHub user genged opened a pull request: https://github.com/apache/flink/pull/4810 [FLINK-6926] [table] Add support for MD5,SHA1 and SHA256 in SQL ## What is the purpose of the change This pull request implements MD5, SHA1 and SHA256 support in Flink SQL as discussed in FL

[jira] [Commented] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200822#comment-16200822 ] Aljoscha Krettek commented on FLINK-7540: - [~oty5081] Thanks a lot for reporting t

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Description: In {{NetUtils.unresolvedHostToNormalizedString()}} we lowercase hostnames, Akka

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Description: h1. Original Issue Text Hostnames in my hadoop cluster are like these: “DSJ-

[jira] [Updated] (FLINK-7540) Akka hostnames are not normalised consistently

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Summary: Akka hostnames are not normalised consistently (was: submit a job on yarn-cluster

[jira] [Commented] (FLINK-7816) Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200786#comment-16200786 ] Hai Zhou UTC+8 commented on FLINK-7816: --- Hi [~aljoscha], In *ClosureCleaner.clean(f

[jira] [Commented] (FLINK-7738) Create WebSocket handler (server)

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200785#comment-16200785 ] ASF GitHub Bot commented on FLINK-7738: --- Github user EronWright commented on the iss

[GitHub] flink issue #4767: [FLINK-7738] [flip-6] Create WebSocket handler (server, c...

2017-10-11 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4767 Updated the description based on the latest PR. ---

[jira] [Updated] (FLINK-7540) submit a job on yarn-cluster mode or start a yarn-session failed,in hadoop cluster with capitalized hostname

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7540: Component/s: Distributed Coordination > submit a job on yarn-cluster mode or start a yarn-se

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200762#comment-16200762 ] Aljoscha Krettek commented on FLINK-6951: - [~phoenixjiangnan] & [~tzulitai] Is thi

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200672#comment-16200672 ] Chesnay Schepler commented on FLINK-7608: - that's exactly what you have to impleme

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200658#comment-16200658 ] ASF GitHub Bot commented on FLINK-7791: --- Github user zentol commented on the issue:

[GitHub] flink issue #4802: [FLINK-7791] [REST][client] Integrate LIST command into R...

2017-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4802 What do you mean when you say triggerSavepoint is not a command of the ClusterClient? It does have a `triggerSavepoint` method. ---

[jira] [Commented] (FLINK-7803) Update savepoint Documentation

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200655#comment-16200655 ] ASF GitHub Bot commented on FLINK-7803: --- Github user razvan100 closed the pull reque

[GitHub] flink pull request #4808: [FLINK-7803][Documentation] Add missing informatio...

2017-10-11 Thread razvan100
Github user razvan100 closed the pull request at: https://github.com/apache/flink/pull/4808 ---

[jira] [Commented] (FLINK-7803) Update savepoint Documentation

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200652#comment-16200652 ] ASF GitHub Bot commented on FLINK-7803: --- GitHub user razvan100 opened a pull request

[GitHub] flink pull request #4809: [FLINK-7803][Documentation] Add missing savepoint ...

2017-10-11 Thread razvan100
GitHub user razvan100 opened a pull request: https://github.com/apache/flink/pull/4809 [FLINK-7803][Documentation] Add missing savepoint information This fixes FLINK-7803 by emphasizing the savepoint save location should be on a distributed file-system. You can merge this pul

[jira] [Commented] (FLINK-7803) Update savepoint Documentation

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200626#comment-16200626 ] ASF GitHub Bot commented on FLINK-7803: --- GitHub user razvan100 opened a pull request

[GitHub] flink pull request #4808: [FLINK-7803][Documentation] Add missing informatio...

2017-10-11 Thread razvan100
GitHub user razvan100 opened a pull request: https://github.com/apache/flink/pull/4808 [FLINK-7803][Documentation] Add missing information about savepoint location FLINK-7803 FLINK-7750 *Thank you very much for contributing to Apache Flink - we are happy that you want

[jira] [Comment Edited] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200585#comment-16200585 ] Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/11/17 4:54 PM: ---

[jira] [Comment Edited] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200585#comment-16200585 ] Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/11/17 4:53 PM: ---

[jira] [Comment Edited] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200585#comment-16200585 ] Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/11/17 4:52 PM: ---

[jira] [Comment Edited] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200585#comment-16200585 ] Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/11/17 4:52 PM: ---

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-11 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200585#comment-16200585 ] Hai Zhou UTC+8 commented on FLINK-7608: --- Before I start, I want discuss my idea: red

[jira] [Created] (FLINK-7817) Add TaskManagerDetailsHandler

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7817: Summary: Add TaskManagerDetailsHandler Key: FLINK-7817 URL: https://issues.apache.org/jira/browse/FLINK-7817 Project: Flink Issue Type: Sub-task Co

[jira] [Assigned] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7648: Assignee: Till Rohrmann > Port TaskManagersHandler to new REST endpoint > -

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200564#comment-16200564 ] ASF GitHub Bot commented on FLINK-7810: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-11 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4807 [FLINK-7810] Switch from custom Flakka to Akka 2.4.x ## What is the purpose of the change Drop support for Scala 2.10 and then update to a newer Akka version. Before, we were forced to st

[jira] [Created] (FLINK-7816) Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner

2017-10-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7816: --- Summary: Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner Key: FLINK-7816 URL: https://issues.apache.org/jira/browse/FLINK-7816 Project: Flink

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144025139 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -206,6 +209,53 @@ public voi

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144016699 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -104,8 +130,8 @@ public void channelI

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144052410 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandler.java --- @@ -330,6 +330,10 @@ else if (buffe

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200523#comment-16200523 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144013921 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -37,18 +43,29 @@ import ja

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144025089 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -206,6 +209,53 @@ public voi

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200522#comment-16200522 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200527#comment-16200527 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144014064 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -37,18 +43,29 @@ import ja

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-10-11 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r144022698 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -272,4 +316,53 @@ private void decode

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200524#comment-16200524 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200526#comment-16200526 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200528#comment-16200528 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200525#comment-16200525 ] ASF GitHub Bot commented on FLINK-7416: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200519#comment-16200519 ] ASF GitHub Bot commented on FLINK-7653: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4793: [FLINK-7653] Properly implement Dispatcher#requestCluster...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4793 Thanks for the review @zentol. Rebasing onto the latest master and merging after Travis gives green light. ---

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200509#comment-16200509 ] ASF GitHub Bot commented on FLINK-7791: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #4802: [FLINK-7791] [REST][client] Integrate LIST command into R...

2017-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4802 But `triggerSavepoint` is not a command of the `ClusterClient` but of the `CliFrontend`. All other `ClusterClient` commands like `stop` and `cancel` behave differently. ---

[jira] [Commented] (FLINK-7815) Remove grouping from MultipleJobsDetails

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200496#comment-16200496 ] ASF GitHub Bot commented on FLINK-7815: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4806: [FLINK-7815] Remove grouping from MultipleJobsDeta...

2017-10-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4806 [FLINK-7815] Remove grouping from MultipleJobsDetails ## What is the purpose of the change With this commit the MultipleJobsDetails instance only contains a list of all jobs which

[jira] [Commented] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200490#comment-16200490 ] ASF GitHub Bot commented on FLINK-7806: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4805: [FLINK-7806] [flip6] Register CurrentJobsOverviewH...

2017-10-11 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4805 [FLINK-7806] [flip6] Register CurrentJobsOverviewHandler under /jobs/overview ## What is the purpose of the change This PR changes the REST endpoint URL of the `CurrentJobsOverviewHand

[jira] [Created] (FLINK-7815) Remove grouping from MultipleJobsDetails

2017-10-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7815: Summary: Remove grouping from MultipleJobsDetails Key: FLINK-7815 URL: https://issues.apache.org/jira/browse/FLINK-7815 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7770) Hide Queryable State behind a proxy.

2017-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200486#comment-16200486 ] ASF GitHub Bot commented on FLINK-7770: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4778: [FLINK-7770][FLINK-7769][Queryable State] Refactor...

2017-10-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4778 ---

[jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely

2017-10-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200409#comment-16200409 ] Aljoscha Krettek commented on FLINK-7731: - Ah yes, sorry for not noticing that ear

  1   2   3   >