[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504119#comment-14504119 ] ASF GitHub Bot commented on FLINK-1514: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-04-20 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-94606828 Hi @balidani! I pulled your changes and made some improvements, mainly to the examples, so that they are consistent with the rest of Gelly's examples. You can see

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503927#comment-14503927 ] ASF GitHub Bot commented on FLINK-703: -- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28739333 --- Diff: flink-core/src/main/java/org/apache/flink/statistics/heavyhitters/IHeavyHitter.java --- @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503961#comment-14503961 ] ASF GitHub Bot commented on FLINK-1297: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503801#comment-14503801 ] ASF GitHub Bot commented on FLINK-1908: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503979#comment-14503979 ] ASF GitHub Bot commented on FLINK-1297: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

2015-04-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-94590741 LGTM --- 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

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28739811 --- Diff: flink-core/src/main/java/org/apache/flink/statistics/OperatorStatistics.java --- @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503665#comment-14503665 ] ASF GitHub Bot commented on FLINK-1758: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/576#issuecomment-94572014 Apart from the fact that I don't agree with those two methods having the same name, everything else was updated. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

2015-04-20 Thread Jonathan Hasenburg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503788#comment-14503788 ] Jonathan Hasenburg commented on FLINK-1719: --- I will write my Bachelor Thesis

[GitHub] flink pull request: [FLINK-1883][gelly] Added Min Vertex Id Propag...

2015-04-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/596#issuecomment-94438358 @vasia , The library method matches Spargel now. I also refactored the randomised edges test a bit. Tell me what you think! --- If your project is set

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502729#comment-14502729 ] ASF GitHub Bot commented on FLINK-377: -- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1871][gelly] Added Spargel to Gelly mig...

2015-04-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/600#issuecomment-94432522 Hi @vasia , The general guidelines were added. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-1871) Add a Spargel to Gelly migration guide

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502694#comment-14502694 ] ASF GitHub Bot commented on FLINK-1871: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/609#issuecomment-94442619 The TaskManager uses an exponential backoff strategy to resolve connection problems with the JobManager. On Mon, Apr 20, 2015 at 11:07 AM, Max

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94443054 I just ran it on the cluster. Works like a charm. :smile: For word count, python takes 12 minutes, java about 2:40. But this should be expected, I guess.

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502728#comment-14502728 ] ASF GitHub Bot commented on FLINK-1908: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/609#issuecomment-9121 The TaskManager's maximum registration duration is configured by the config value ```taskmanager.maxRegistrationDuration```. The default value is set to infinity for

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502737#comment-14502737 ] ASF GitHub Bot commented on FLINK-1908: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-04-20 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502686#comment-14502686 ] Chiwan Park commented on FLINK-1745: I suggest a scenario of KNN like following:

[jira] [Commented] (FLINK-1883) Add Min Vertex ID Propagation Library Method and Example

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502712#comment-14502712 ] ASF GitHub Bot commented on FLINK-1883: --- Github user andralungu commented on the

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502733#comment-14502733 ] ASF GitHub Bot commented on FLINK-377: -- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94443599 Can you give me a +1 in the discussion on the ML as well? On Mon, Apr 20, 2015 at 2:46 PM, Aljoscha Krettek notificati...@github.com wrote: I just

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread DarkKnightCZ
Github user DarkKnightCZ commented on the pull request: https://github.com/apache/flink/pull/609#issuecomment-94451193 @tillrohrmann The problem that occurred was that JM bound the IP:PORT with some delay, so TMs failed to start, since they couldn't connect. When i tried

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502783#comment-14502783 ] ASF GitHub Bot commented on FLINK-1908: --- Github user DarkKnightCZ commented on the

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502792#comment-14502792 ] ASF GitHub Bot commented on FLINK-1908: --- Github user DarkKnightCZ commented on a

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502734#comment-14502734 ] ASF GitHub Bot commented on FLINK-1908: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/609#discussion_r28685121 --- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.sh --- @@ -37,6 +37,26 @@ fi # cluster mode, bring up job manager locally and a task manager on

[jira] [Assigned] (FLINK-1733) Add PCA to machine learning library

2015-04-20 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghav Chalapathy reassigned FLINK-1733: Assignee: Raghav Chalapathy Add PCA to machine learning library

[jira] [Created] (FLINK-1913) Document how to access data in HCatalog

2015-04-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1913: - Summary: Document how to access data in HCatalog Key: FLINK-1913 URL: https://issues.apache.org/jira/browse/FLINK-1913 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502736#comment-14502736 ] ASF GitHub Bot commented on FLINK-1908: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread DarkKnightCZ
Github user DarkKnightCZ commented on a diff in the pull request: https://github.com/apache/flink/pull/609#discussion_r28688289 --- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.sh --- @@ -37,6 +37,26 @@ fi # cluster mode, bring up job manager locally and a task

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502545#comment-14502545 ] ASF GitHub Bot commented on FLINK-377: -- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502547#comment-14502547 ] ASF GitHub Bot commented on FLINK-1297: --- Github user tammymendt commented on the

[jira] [Commented] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502546#comment-14502546 ] ASF GitHub Bot commented on FLINK-1908: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94403584 yes that is correct. --- 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

[jira] [Commented] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-04-20 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502620#comment-14502620 ] Chiwan Park commented on FLINK-1745: [~raghav.chalapa...@gmail.com] Hi. We can

[jira] [Assigned] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-04-20 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park reassigned FLINK-1745: -- Assignee: Chiwan Park Add k-nearest-neighbours algorithm to machine learning library

[jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-04-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502763#comment-14502763 ] Till Rohrmann commented on FLINK-1746: -- Hi Raghav, cool that you picked the topic up

[GitHub] flink pull request: [docs] Change doc layout

2015-04-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/606#discussion_r28671427 --- Diff: docs/setup/local_setup.md --- @@ -20,11 +20,11 @@ specific language governing permissions and limitations under the License. --

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94402978 I was referring to the way that communication is handled between the java host and the generic language client: Communication between them is not based on a fixed set of

[jira] [Assigned] (FLINK-1843) Job History gets cleared too fast

2015-04-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-1843: - Assignee: Maximilian Michels Job History gets cleared too fast

[jira] [Commented] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-04-20 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502562#comment-14502562 ] Raghav Chalapathy commented on FLINK-1745: -- Hi Chiwan Would like to colloborate

[jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502580#comment-14502580 ] Robert Metzger commented on FLINK-1746: --- Hi, I gave you Contributor permissions in

[GitHub] flink pull request: Flink 964

2015-04-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/112#issuecomment-94392457 I think we can close this pull request. This PR is not adding new methods for getting metrics from the system. It is using the (legacy?) JobManager profiling

[GitHub] flink pull request: [docs] Change doc layout

2015-04-20 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/606#discussion_r28671249 --- Diff: docs/setup/local_setup.md --- @@ -20,11 +20,11 @@ specific language governing permissions and limitations under the License. --

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94397131 All issues that I'm aware of are resolved. --- 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-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502558#comment-14502558 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[jira] [Assigned] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-04-20 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghav Chalapathy reassigned FLINK-1746: Assignee: Raghav Chalapathy Add linear discriminant analysis to machine learning

[GitHub] flink pull request: [docs] Change doc layout

2015-04-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-94393362 Why did you remove the Disqus comments from the pages? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94402062 @aljoscha Timeout is removed. Data transfer is still done with mapped file, access to these files is synchronized using TCP. Im not sure what you mean with your last

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502551#comment-14502551 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-04-20 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502576#comment-14502576 ] Raghav Chalapathy commented on FLINK-1746: -- Hi Till I would like to start

[GitHub] flink pull request: [FLINK-1908] JobManager startup delay isn't co...

2015-04-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/609#issuecomment-94401080 Thanks for the pull request. Seems to work fine. I was wondering, shouldn't the task managers repeatably try to build up a connection to the job manager? For me, that seems

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502544#comment-14502544 ] ASF GitHub Bot commented on FLINK-377: -- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94400959 I'll test it again on a cluster. Could you please elaborate a bit. Is the timeout still in? Communication is through TCP instead of the mapped files. but still with the

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-04-20 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-94401023 I wrote to the mailinglist to discuss the state of this PR --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Assigned] (FLINK-1911) DataStream and DataSet projection is out of sync

2015-04-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Péter Szabó reassigned FLINK-1911: -- Assignee: Péter Szabó DataStream and DataSet projection is out of sync

[GitHub] flink pull request: [FLINK-1799][scala] Fix handling of generic ar...

2015-04-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/582#issuecomment-94392757 Any more thoughts? Otherwise I would like to merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-1799) Scala API does not support generic arrays

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502520#comment-14502520 ] ASF GitHub Bot commented on FLINK-1799: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502534#comment-14502534 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[jira] [Commented] (FLINK-1867) TaskManagerFailureRecoveryITCase causes stalled travis builds

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502967#comment-14502967 ] ASF GitHub Bot commented on FLINK-1867: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-1906) Add tip to work around plain Tuple return type of project operator

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502870#comment-14502870 ] ASF GitHub Bot commented on FLINK-1906: --- Github user StephanEwen commented on the

[jira] [Created] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread JIRA
Zoltán Zvara created FLINK-1914: --- Summary: Wrong FS while starting YARN session without correct HADOOP_HOME Key: FLINK-1914 URL: https://issues.apache.org/jira/browse/FLINK-1914 Project: Flink

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502885#comment-14502885 ] ASF GitHub Bot commented on FLINK-1758: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1799][scala] Fix handling of generic ar...

2015-04-20 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/582#discussion_r28691764 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java --- @@ -143,6 +143,18 @@ else if (type instanceof Class?

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502901#comment-14502901 ] Robert Metzger commented on FLINK-1914: --- Hi, thank you for the feedback. The Yarn

[jira] [Commented] (FLINK-1799) Scala API does not support generic arrays

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502906#comment-14502906 ] ASF GitHub Bot commented on FLINK-1799: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r28696843 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java --- @@ -1063,6 +1065,33 @@ public void

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/576#issuecomment-94461019 Hi @vasia , The inline comments have been addressed, I still have the big comment to look at :) One thing(or two ^^) that could be discussed: -

[GitHub] flink pull request: [FLINK-1906] [docs] Add tip to work around pla...

2015-04-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/611#issuecomment-94457892 Good addition, +1 to merge --- 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: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r28696976 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java --- @@ -663,6 +663,39 @@ public void

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r28696965 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java --- @@ -663,6 +663,39 @@ public void

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502996#comment-14502996 ] ASF GitHub Bot commented on FLINK-703: -- Github user fhueske commented on a diff in the

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r28696934 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java --- @@ -1063,6 +1065,33 @@ public void

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-94464757 Keeping the accumulators from each task separately is something that we want to change anyways in the main system. Then, this would not need special casing.

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502900#comment-14502900 ] ASF GitHub Bot commented on FLINK-1297: --- Github user StephanEwen commented on the

[jira] [Updated] (FLINK-1260) Add custom partitioning to documentation

2015-04-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1260: Assignee: (was: Chesnay Schepler) Add custom partitioning to documentation

[jira] [Commented] (FLINK-1799) Scala API does not support generic arrays

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502897#comment-14502897 ] ASF GitHub Bot commented on FLINK-1799: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502997#comment-14502997 ] ASF GitHub Bot commented on FLINK-703: -- Github user fhueske commented on a diff in the

[GitHub] flink pull request: [FLINK-1799][scala] Fix handling of generic ar...

2015-04-20 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/582#discussion_r28692599 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java --- @@ -143,6 +143,18 @@ else if (type instanceof Class?

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502932#comment-14502932 ] Zoltán Zvara commented on FLINK-1914: - There is a warn! Thanks! Wrong FS while

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502939#comment-14502939 ] Robert Metzger commented on FLINK-1914: --- I have to admit its not very prominent, but

[GitHub] flink pull request: [FLINK-1867/1880] Raise test timeouts in hope ...

2015-04-20 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/612 [FLINK-1867/1880] Raise test timeouts in hope of fixing Travis fails You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink

[jira] [Updated] (FLINK-1422) Missing usage example for withParameters

2015-04-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1422: Assignee: (was: Chesnay Schepler) Missing usage example for withParameters

[jira] [Commented] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-04-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502909#comment-14502909 ] Till Rohrmann commented on FLINK-1745: -- Hi Chiwan and Raghav, cool that you two want

[jira] [Created] (FLINK-1915) Faulty plan selection by optimizer

2015-04-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1915: Summary: Faulty plan selection by optimizer Key: FLINK-1915 URL: https://issues.apache.org/jira/browse/FLINK-1915 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/572#issuecomment-94482477 Thanks for the update. Looks really good! I have just a few inline comments. Once these are resolved, I would try the code and merge it if everything works. --- If

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

2015-04-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-94502825 I've updated the pull request. I decided to implement the concise method: ``` sinkId:taskId output - sink id provided, parallelism 1 sinkId output - sink

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503224#comment-14503224 ] ASF GitHub Bot commented on FLINK-703: -- Github user chiwanpark commented on the pull

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/572#issuecomment-94512484 I updated this PR. Thanks for advice. :) * Remove `setParallelism(1)` in test code. * Simplify `testGroupReduceWithAtomicValue` in `GroupReduceITCase`.

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

2015-04-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r28697764 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/Keys.java --- @@ -274,24 +274,31 @@ private static int

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503147#comment-14503147 ] ASF GitHub Bot commented on FLINK-1486: --- Github user mxm commented on the pull

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503045#comment-14503045 ] ASF GitHub Bot commented on FLINK-703: -- Github user chiwanpark commented on a diff in

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503011#comment-14503011 ] ASF GitHub Bot commented on FLINK-703: -- Github user fhueske commented on a diff in the

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503018#comment-14503018 ] ASF GitHub Bot commented on FLINK-703: -- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1799][scala] Fix handling of generic ar...

2015-04-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/582#issuecomment-94483743 I fixed @StephanEwen's complaint. It was incorrect but the type class of TypeInformation does not seem to be used in any places where it matters. --- If your project is

[jira] [Commented] (FLINK-1799) Scala API does not support generic arrays

2015-04-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503030#comment-14503030 ] ASF GitHub Bot commented on FLINK-1799: --- Github user aljoscha commented on the pull

  1   2   >