[GitHub] flink issue #2811: [FLINK-5159] Improve perfomance of inner joins with a sin...

2016-11-30 Thread AlexanderShoshin
Github user AlexanderShoshin commented on the issue: https://github.com/apache/flink/pull/2811 Hi, @fhueske. I've made the corrections that you asked. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15711203#comment-15711203 ] ASF GitHub Bot commented on FLINK-5159: --- Github user AlexanderShoshin commented on the issue:

[jira] [Assigned] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date

2016-11-30 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei reassigned FLINK-4523: -- Assignee: Wei-Che Wei > Allow Kinesis Consumer to start from specific timestamp / Date >

[jira] [Comment Edited] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710644#comment-15710644 ] Kurt Young edited comment on FLINK-5185 at 12/1/16 2:45 AM: Hi [~fhueske],

[jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710644#comment-15710644 ] Kurt Young commented on FLINK-5185: --- Hi [~fhueske], thanks for the reply. Actually, this issue reflects

[jira] [Comment Edited] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710644#comment-15710644 ] Kurt Young edited comment on FLINK-5185 at 12/1/16 2:44 AM: Hi [~fhueske],

[jira] [Commented] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

2016-11-30 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710512#comment-15710512 ] Xiaogang Shi commented on FLINK-5214: - I opened FLINK-5086 to report a similar problem, but I do not

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710479#comment-15710479 ] ASF GitHub Bot commented on FLINK-5091: --- GitHub user EronWright opened a pull request:

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-11-30 Thread EronWright
GitHub user EronWright opened a pull request: https://github.com/apache/flink/pull/2915 [FLINK-5091] Formalize the Mesos AppMaster environment for docker compatibility Fixes FLINK-5091. - introduced ContainerSpecification. - reworked how the TM container environment is

[jira] [Comment Edited] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709903#comment-15709903 ] Fabian Hueske edited comment on FLINK-5185 at 11/30/16 9:56 PM: I assume,

[jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709903#comment-15709903 ] Fabian Hueske commented on FLINK-5185: -- I assume, you are proposing this in order to create a

[jira] [Closed] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-11-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3719. - Resolution: Implemented Implemented in bd62fe14ac3e8c382b72c7c16ce1f0a6ee7db77d > WebInterface: Moving

[jira] [Closed] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3680. - Resolution: Fixed 1.1: 7b5d769aded2b653ac4e573bf0d9c63e250ef684 1.2:

[jira] [Updated] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-11-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3719: -- Fix Version/s: 1.2.0 > WebInterface: Moving the barrier between graph and stats >

[GitHub] flink pull request #2457: [FLINK-3680][web frontend] Remove "(not set)" text...

2016-11-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2457 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

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

[GitHub] flink pull request #2467: [FLINK-3719][web frontend] Moving the barrier betw...

2016-11-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2467 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

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

[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-11-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 11/30/16 9:38 PM: - There is similar issue

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

2016-11-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709854#comment-15709854 ] Ted Yu commented on FLINK-5002: --- lgtm > Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers >

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709735#comment-15709735 ] ASF GitHub Bot commented on FLINK-3719: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

2016-11-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2467 Merging this ... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709675#comment-15709675 ] ASF GitHub Bot commented on FLINK-5069: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709650#comment-15709650 ] ASF GitHub Bot commented on FLINK-3680: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2457 Merging this ... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[jira] [Commented] (FLINK-4705) Instrument FixedLengthRecordSorter

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709603#comment-15709603 ] ASF GitHub Bot commented on FLINK-4705: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2617: [FLINK-4705] Instrument FixedLengthRecordSorter

2016-11-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2617 Hi @StephanEwen, should we endeavor to get this into 1.2 or defer to the next release? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-5188) Shade dependency

2016-11-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709586#comment-15709586 ] Anton Solovev commented on FLINK-5188: -- Exactly > Shade dependency > > >

[jira] [Updated] (FLINK-5188) Shade dependency

2016-11-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5188: - Summary: Shade dependency (was: Redirect dependencies) > Shade dependency > > >

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709567#comment-15709567 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709566#comment-15709566 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709571#comment-15709571 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709570#comment-15709570 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709569#comment-15709569 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709568#comment-15709568 ] ASF GitHub Bot commented on FLINK-5069: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90306654 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -957,4 +969,65 @@ public void run() {

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90303696 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -40,15 +43,21 @@ import org.slf4j.Logger;

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90305721 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/stats/PendingCheckpointStats.java --- @@ -0,0 +1,187 @@ +/* + * Licensed

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90312273 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -957,4 +969,65 @@ public void run() {

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90308555 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -214,6 +224,8 @@ public CheckpointCoordinator(

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2809#discussion_r90306783 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/stats/PendingCheckpointStats.java --- @@ -0,0 +1,187 @@ +/* + * Licensed

[jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

2016-11-30 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5216: --- Summary: CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion Key: FLINK-5216 URL:

[jira] [Commented] (FLINK-5188) Redirect dependencies

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709313#comment-15709313 ] Stephan Ewen commented on FLINK-5188: - What does "redirect dependencies" mean? > Redirect

[jira] [Comment Edited] (FLINK-5188) Redirect dependencies

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709313#comment-15709313 ] Stephan Ewen edited comment on FLINK-5188 at 11/30/16 6:14 PM: --- What does

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709299#comment-15709299 ] ASF GitHub Bot commented on FLINK-5091: --- Github user EronWright closed the pull request at:

[GitHub] flink pull request #2904: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-11-30 Thread EronWright
Github user EronWright closed the pull request at: https://github.com/apache/flink/pull/2904 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4826) Add keytab based kerberos support for Mesos environment

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

[GitHub] flink pull request #2900: Rebased: Keytab & TLS support for Flink on Mesos S...

2016-11-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2900 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2734: Keytab & TLS support for Flink on Mesos Setup

2016-11-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2734 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2900: Rebased: Keytab & TLS support for Flink on Mesos Setup

2016-11-30 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2900 Tests passed. Merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[GitHub] flink pull request #2914: [FLINK-4611] Make "AUTO" credential provider as de...

2016-11-30 Thread tony810430
GitHub user tony810430 opened a pull request: https://github.com/apache/flink/pull/2914 [FLINK-4611] Make "AUTO" credential provider as default for Kinesis C… You can merge this pull request into a Git repository by running: $ git pull https://github.com/tony810430/flink

[jira] [Assigned] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

2016-11-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5214: Assignee: Till Rohrmann > Clean up checkpoint files when failing checkpoint operation on

[jira] [Created] (FLINK-5215) Close checkpoint streams upon cancellation

2016-11-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5215: Summary: Close checkpoint streams upon cancellation Key: FLINK-5215 URL: https://issues.apache.org/jira/browse/FLINK-5215 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709154#comment-15709154 ] ASF GitHub Bot commented on FLINK-4611: --- GitHub user tony810430 opened a pull request:

[jira] [Created] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

2016-11-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5214: Summary: Clean up checkpoint files when failing checkpoint operation on TM Key: FLINK-5214 URL: https://issues.apache.org/jira/browse/FLINK-5214 Project: Flink

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-11-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709120#comment-15709120 ] Greg Hogan commented on FLINK-3160: --- For large parallelism (> 1000, depending on device and browser) the

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-11-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709119#comment-15709119 ] Greg Hogan commented on FLINK-3160: --- For large parallelism (> 1000, depending on device and browser) the

[jira] [Resolved] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2644. - Resolution: Fixed Fix Version/s: 1.0.1 Fixed a few versions back... > State partitioning

[jira] [Closed] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2644. --- > State partitioning does not respect the different partitioning of multiple > inputs >

[jira] [Resolved] (FLINK-2999) Support connected keyed streams

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2999. - Resolution: Fixed Fix Version/s: 1.0.1 This has been implemented a while back already. >

[jira] [Commented] (FLINK-4855) Add partitionedKeyBy to DataStream

2016-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709090#comment-15709090 ] Stephan Ewen commented on FLINK-4855: - I think this is a good idea, I have heard this being asked a

[jira] [Commented] (FLINK-5209) Fix TaskManager metrics

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709072#comment-15709072 ] ASF GitHub Bot commented on FLINK-5209: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5209) Fix TaskManager metrics

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709073#comment-15709073 ] ASF GitHub Bot commented on FLINK-5209: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-5209) Fix TaskManager metrics

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709074#comment-15709074 ] ASF GitHub Bot commented on FLINK-5209: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2902#discussion_r90274186 --- Diff: flink-runtime-web/web-dashboard/app/partials/taskmanager/taskmanager.metrics.jade --- @@ -75,18 +75,18 @@ div(ng-if="metrics.id") tbody

[GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2902#discussion_r90273043 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -124,13 +124,21 @@ public String

[GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics

2016-11-30 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2902#discussion_r90272935 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagersHandler.java --- @@ -124,13 +124,21 @@ public String

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708913#comment-15708913 ] ASF GitHub Bot commented on FLINK-5158: --- Github user uce commented on a diff in the pull request:

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708912#comment-15708912 ] ASF GitHub Bot commented on FLINK-5158: --- Github user uce commented on a diff in the pull request:

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708911#comment-15708911 ] ASF GitHub Bot commented on FLINK-5158: --- Github user uce commented on a diff in the pull request:

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708914#comment-15708914 ] ASF GitHub Bot commented on FLINK-5158: --- Github user uce commented on a diff in the pull request:

[GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti...

2016-11-30 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2873#discussion_r90258638 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -731,46 +700,100 @@ public boolean

[GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti...

2016-11-30 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2873#discussion_r90258544 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -731,46 +700,100 @@ public boolean

[GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti...

2016-11-30 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2873#discussion_r90258796 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -731,46 +700,100 @@ public boolean

[GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti...

2016-11-30 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2873#discussion_r90257889 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -651,64 +651,33 @@ public boolean

[GitHub] flink pull request #2899: Various logging improvements

2016-11-30 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/2899 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-11-30 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708872#comment-15708872 ] Ufuk Celebi commented on FLINK-3160: Maybe I'm misunderstanding something, too. ;-) To me it looks

[jira] [Closed] (FLINK-5213) Missing @Override in Task

2016-11-30 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5213. -- Resolution: Fixed Fixed in 8cdb406 (master). > Missing @Override in Task > - >

[jira] [Created] (FLINK-5213) Missing @Override in Task

2016-11-30 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5213: -- Summary: Missing @Override in Task Key: FLINK-5213 URL: https://issues.apache.org/jira/browse/FLINK-5213 Project: Flink Issue Type: Improvement

[GitHub] flink issue #2899: Various logging improvements

2016-11-30 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2899 Added `FlinkUntypedActor` as well and addressed the comments, Till. I would like to merge this now. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #2912: [FLINK-5114] [network] Handle partition producer s...

2016-11-30 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2912 [FLINK-5114] [network] Handle partition producer state check for unregistered executions If a partition state request is triggered for a producer that terminates before the request arrives, the

[GitHub] flink pull request #2913: [backport] [FLINK-5114] [network] Handle partition...

2016-11-30 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2913 [backport] [FLINK-5114] [network] Handle partition producer state check for unregistered executions This is a backport of #2912. Code between 1.1 and 1.2 slightly changed. I decided to further

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708824#comment-15708824 ] ASF GitHub Bot commented on FLINK-5114: --- GitHub user uce opened a pull request:

[jira] [Commented] (FLINK-5166) TextInputFormatTest.testNestedFileRead

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708815#comment-15708815 ] ASF GitHub Bot commented on FLINK-5166: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2876: [FLINK-5166] TextInputFormatTest.testNestedFileRea...

2016-11-30 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2876#discussion_r90249472 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java --- @@ -90,23 +92,23 @@ public void testSimpleRead() {

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708810#comment-15708810 ] ASF GitHub Bot commented on FLINK-5114: --- GitHub user uce opened a pull request:

[jira] [Created] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space)

2016-11-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5212: -- Summary: Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space) Key: FLINK-5212 URL: https://issues.apache.org/jira/browse/FLINK-5212 Project: Flink

[jira] [Created] (FLINK-5211) Include an example configuration for all reporters

2016-11-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5211: --- Summary: Include an example configuration for all reporters Key: FLINK-5211 URL: https://issues.apache.org/jira/browse/FLINK-5211 Project: Flink Issue

[jira] [Commented] (FLINK-5166) TextInputFormatTest.testNestedFileRead

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708780#comment-15708780 ] ASF GitHub Bot commented on FLINK-5166: --- Github user shijinkui commented on a diff in the pull

[GitHub] flink pull request #2876: [FLINK-5166] TextInputFormatTest.testNestedFileRea...

2016-11-30 Thread shijinkui
Github user shijinkui commented on a diff in the pull request: https://github.com/apache/flink/pull/2876#discussion_r90246314 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java --- @@ -90,7 +91,9 @@ public void testSimpleRead() {

[jira] [Commented] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708766#comment-15708766 ] ASF GitHub Bot commented on FLINK-5178: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-4895) Drop support for Hadoop 1

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

[jira] [Resolved] (FLINK-4895) Drop support for Hadoop 1

2016-11-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4895. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved in

[GitHub] flink issue #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to point to...

2016-11-30 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2911 @uce can you have a look after processing #2891 (FLINK-5129)? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink pull request #2850: [FLINK-4895] Drop Hadoop1 support

2016-11-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2850 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708761#comment-15708761 ] ASF GitHub Bot commented on FLINK-5178: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to p...

2016-11-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/2911 [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system Previously, this was restricted to a local file system path but now we can allow it to be distributed, too,

[GitHub] flink issue #2899: Various logging improvements

2016-11-30 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2899 We should also set the received and handled message in `FlinkUntypedActor#onReceive` to trace. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2016-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15708696#comment-15708696 ] ASF GitHub Bot commented on FLINK-5129: --- Github user NicoK commented on the issue:

[GitHub] flink issue #2891: [FLINK-5129] make the BlobServer use a distributed file s...

2016-11-30 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2891 Sorry for the hassle, found a regression and added a fix plus an appropriate test for it. Should be fine now. --- If your project is set up for it, you can reply to this email and have your reply

  1   2   >