[GitHub] flink issue #2366: [FLINK-4322] Unify CheckpointCoordinator and SavepointCoo...

2016-08-17 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2366 The unification looks great and now things are simple in terms of restoration. Thanks. --- 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-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425928#comment-15425928 ] ASF GitHub Bot commented on FLINK-4322: --- Github user ramkrish86 commented on the issue:

[jira] [Commented] (FLINK-4420) Introduce star(*) to select all of the columns in the table

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425912#comment-15425912 ] ASF GitHub Bot commented on FLINK-4420: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #2384: [FLINK-4420] [table] Introduce star(*) to select a...

2016-08-17 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2384 [FLINK-4420] [table] Introduce star(*) to select all of the columns in the table Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[jira] [Created] (FLINK-4420) Introduce star(*) to select all of the columns in the table

2016-08-17 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4420: -- Summary: Introduce star(*) to select all of the columns in the table Key: FLINK-4420 URL: https://issues.apache.org/jira/browse/FLINK-4420 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425903#comment-15425903 ] ASF GitHub Bot commented on FLINK-4271: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ...

2016-08-17 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2305 I'm ok with the `with(...)` approach. In addition, we should create a JIRA under [FLINK-3957] "Breaking API changes for Flink 2.0", to keep track of deprecating and changing the `apply` method

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-17 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 @uce I saw that there were conflicts after yesterday's updates to the master. Hence I have rebased my PR and force pushed the changes. Thanks. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425900#comment-15425900 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-17 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 @uce The test case failures seems to be unrelated. Want to have a look at the updated PR? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425876#comment-15425876 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the issue:

[jira] [Created] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType

2016-08-17 Thread shuai.xu (JIRA)
shuai.xu created FLINK-4419: --- Summary: Batch improvement for supporting dfs as a ResultPartitionType Key: FLINK-4419 URL: https://issues.apache.org/jira/browse/FLINK-4419 Project: Flink Issue

[jira] [Assigned] (FLINK-4406) Implement job master registration at resource manager

2016-08-17 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu reassigned FLINK-4406: -- Assignee: Wenlong Lyu > Implement job master registration at resource manager >

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-08-17 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425768#comment-15425768 ] Renkai Ge commented on FLINK-4282: -- Hi, [~aljoscha]. I changed the code as your last proposal, do you

[jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425664#comment-15425664 ] ASF GitHub Bot commented on FLINK-4418: --- GitHub user rehevkor5 opened a pull request:

[GitHub] flink pull request #2383: [FLINK-4418] [client] Improve resilience when Inet...

2016-08-17 Thread rehevkor5
GitHub user rehevkor5 opened a pull request: https://github.com/apache/flink/pull/2383 [FLINK-4418] [client] Improve resilience when InetAddress.getLocalHos… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Updated] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-17 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-4418: - Description: When attempting to connect to a cluster with a ClusterClient, if the machine's

[jira] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

2016-08-17 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-4418: Summary: ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception Key: FLINK-4418 URL:

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

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

[GitHub] flink pull request #2374: [FLINK-3950] Add Meter Metric Type

2016-08-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2374#discussion_r75219490 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/util/TestMeter.java --- @@ -0,0 +1,55 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform

2016-08-17 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder updated FLINK-4341: Affects Version/s: 1.1.1 > Checkpoint state size grows unbounded when task parallelism not uniform

[jira] [Commented] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform

2016-08-17 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425408#comment-15425408 ] Scott Kidder commented on FLINK-4341: - I repeated my tests using Flink 1.1.1 and continue to have

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

2016-08-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:13 PM: - Hi [~vkalavri],

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

2016-08-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM: - Hi [~vkalavri],

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

2016-08-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM: - Hi [~vkalavri],

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

2016-08-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 8/17/16 9:12 PM: - Hi [~vkalavri],

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

2016-08-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I changed the implementation now having these

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425346#comment-15425346 ] ASF GitHub Bot commented on FLINK-3950: --- Github user mushketyk commented on the issue:

[GitHub] flink issue #2374: [FLINK-3950] Add Meter Metric Type

2016-08-17 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2374 Hi @zentol I've updated the PR according to your suggestions. About the Meter interface I think we can make it more flexible in two ways: * Update Meter to support variable number of

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-08-17 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425292#comment-15425292 ] Jamie Grier commented on FLINK-4391: [~maguowei] Do you have any sense of when you might be able to

[GitHub] flink pull request #2382: FLINK-4402: Wrong metrics parameter names in docum...

2016-08-17 Thread nssalian
GitHub user nssalian opened a pull request: https://github.com/apache/flink/pull/2382 FLINK-4402: Wrong metrics parameter names in documentation Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-4402) Wrong metrics parameter names in documentation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425222#comment-15425222 ] ASF GitHub Bot commented on FLINK-4402: --- GitHub user nssalian opened a pull request:

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[GitHub] flink pull request #2300: [FLINK-4245] [metrics] Expose all defined variable...

2016-08-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2300#discussion_r75190837 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java --- @@ -83,9 +88,25 @@ //

[GitHub] flink issue #2288: Feature/s3 a fix

2016-08-17 Thread cresny
Github user cresny commented on the issue: https://github.com/apache/flink/pull/2288 refactored commit here: https://github.com/apache/flink/pull/2288/commits/8505e9c77f5ed79542af259f007be2c3a29edbc5 self-tested working in upstream master --- If your project is set up for

[jira] [Assigned] (FLINK-4402) Wrong metrics parameter names in documentation

2016-08-17 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned FLINK-4402: -- Assignee: Neelesh Srinivas Salian > Wrong metrics parameter names in

[jira] [Commented] (FLINK-4402) Wrong metrics parameter names in documentation

2016-08-17 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425084#comment-15425084 ] Neelesh Srinivas Salian commented on FLINK-4402: Thank you. Posting a PR soon. > Wrong

[jira] [Commented] (FLINK-4402) Wrong metrics parameter names in documentation

2016-08-17 Thread RWenden (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425039#comment-15425039 ] RWenden commented on FLINK-4402: Ok with me. > Wrong metrics parameter names in documentation >

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425006#comment-15425006 ] ASF GitHub Bot commented on FLINK-4271: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2305 I would like to come to an agreement with everyone how to proceed. From the discussion on the mailing list, I see that quite some people are opposed to breaking the compatibility unless

[jira] [Closed] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4322. --- > Unify CheckpointCoordinator and SavepointCoordinator >

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424997#comment-15424997 ] ASF GitHub Bot commented on FLINK-4322: --- Github user StephanEwen commented on the issue:

[jira] [Resolved] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4322. - Resolution: Fixed Assignee: Stephan Ewen Fixed via 76ca1a7955fedd8583a0af12289a14d0f1bcf868

[GitHub] flink issue #2366: [FLINK-4322] Unify CheckpointCoordinator and SavepointCoo...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2366 Looked very good. Fixed a minor issue (test log level) and merged 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

[GitHub] flink pull request #2366: [FLINK-4322] Unify CheckpointCoordinator and Savep...

2016-08-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2366 --- 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-4322) Unify CheckpointCoordinator and SavepointCoordinator

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

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424942#comment-15424942 ] ASF GitHub Bot commented on FLINK-1984: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1)

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2315 Great work @EronWright. Code quality, testing and extent of this PR is really impressive :-) I think you've nicely modularized the Mesos resource manager with the additional actors. This makes

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424913#comment-15424913 ] ASF GitHub Bot commented on FLINK-4414: --- Github user wenlong88 commented on the issue:

[GitHub] flink issue #2381: [FLINK-4414][cluster management] Remove restriction on Rp...

2016-08-17 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2381 If there is a `RpcGateway.getAddress`, it will be more friendly in api. But I also think mixing the user defined RPC methods and framework interfaces will be a bit of odd and needs specific

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

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

[GitHub] flink issue #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop dependen...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2378 Manually merged in c894896a45f895997567d5c4e86f9ca25e542e52 --- 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

[GitHub] flink pull request #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop d...

2016-08-17 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2378 --- 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

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424901#comment-15424901 ] ASF GitHub Bot commented on FLINK-4409: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp

2016-08-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4417: --- Summary: Checkpoints should be subsumed by CheckpointID not, by timestamp Key: FLINK-4417 URL: https://issues.apache.org/jira/browse/FLINK-4417 Project: Flink

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424865#comment-15424865 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-17 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 @mxm - Could you please take a look and let me know if you need any further changes. --- 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-4414) Remove restriction on RpcService.getAddress

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

[GitHub] flink pull request #2381: [FLINK-4414][cluster management] Remove restrictio...

2016-08-17 Thread wenlong88
Github user wenlong88 commented on a diff in the pull request: https://github.com/apache/flink/pull/2381#discussion_r75157339 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java --- @@ -197,11 +201,11 @@ public void stopService() {

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75156694 --- Diff: flink-mesos/src/test/resources/log4j-test.properties --- @@ -0,0 +1,32 @@

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75154390 --- Diff: flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala --- @@ -0,0 +1,174 @@ +/* + * Licensed

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2016-08-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424813#comment-15424813 ] Ufuk Celebi commented on FLINK-4387: Fixed in f791680 (master). In the newly introduced

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75153237 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala --- @@ -0,0 +1,349 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[GitHub] flink pull request #2300: [FLINK-4245] [metrics] Expose all defined variable...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2300#discussion_r75152566 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java --- @@ -83,9 +88,25 @@ //

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75151735 --- Diff: flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala --- @@ -0,0 +1,174 @@ +/* + *

[jira] [Created] (FLINK-4416) Provide a programmatic way to load a Yarn config

2016-08-17 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4416: - Summary: Provide a programmatic way to load a Yarn config Key: FLINK-4416 URL: https://issues.apache.org/jira/browse/FLINK-4416 Project: Flink

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424770#comment-15424770 ] Stephan Ewen commented on FLINK-4409: - [~RenkaiGe] I have pushed the fix into the 1.2-SNAPSHOT and

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75150474 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/Tasks.scala --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75149938 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/Tasks.scala --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75149129 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java --- @@ -0,0 +1,290 @@ +/*

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75147221 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala --- @@ -0,0 +1,349 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup()

2016-08-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4415: Assignee: Kostas Kloudas > Enhance Trigger Interface with onFire() and onCleanup() >

[jira] [Created] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup()

2016-08-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4415: --- Summary: Enhance Trigger Interface with onFire() and onCleanup() Key: FLINK-4415 URL: https://issues.apache.org/jira/browse/FLINK-4415 Project: Flink

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75140675 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala --- @@ -0,0 +1,349 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424678#comment-15424678 ] ASF GitHub Bot commented on FLINK-4414: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2381: [FLINK-4414][cluster management] Remove restriction on Rp...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2381 Maybe it makes more sense to extends `RpcGateway` interface and offer a getAddress method which returns the remote address of the gateway. We should also add tests. --- If your project is set

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[GitHub] flink pull request #2381: [FLINK-4414][cluster management] Remove restrictio...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2381#discussion_r75140948 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java --- @@ -197,11 +201,11 @@ public void stopService() {

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75139941 --- Diff: flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/ConnectionMonitor.scala --- @@ -0,0 +1,126 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75139688 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/util/ZooKeeperUtils.java --- @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75139611 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/util/ZooKeeperUtils.java --- @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15424660#comment-15424660 ] ASF GitHub Bot commented on FLINK-4414: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2381: [FLINK-4414][cluster management] Remove restriction on Rp...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2381 Thanks for your contribution @wenlong88. The PR mixes multiple things together. It would be better if you could separate these changes. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75138892 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/ZooKeeperMesosWorkerStore.java --- @@ -0,0 +1,290 @@ +/*

[jira] [Resolved] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

2016-08-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4281. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 7ce42c2e7e332b0fafd19a3f9ed49e4554958fdd.

[jira] [Commented] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions

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

  1   2   3   4   >