[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-122117624 Hi @pp86, are you still working on this PR? I would suggest to open a new PR for the documentation (FLINK-2362). --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630487#comment-14630487 ] ASF GitHub Bot commented on FLINK-1963: --- Github user hsaputra commented on a diff in

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630488#comment-14630488 ] ASF GitHub Bot commented on FLINK-1963: --- Github user hsaputra commented on a diff in

[jira] [Closed] (FLINK-1963) Improve distinct() transformation

2015-07-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1963. Resolution: Fixed Fix Version/s: (was: 0.9) 0.10 fixed with

[jira] [Updated] (FLINK-1748) Integrate PageRank implementation into machine learning library

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1748: - Priority: Minor (was: Major) Integrate PageRank implementation into machine learning library

[jira] [Commented] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629436#comment-14629436 ] ASF GitHub Bot commented on FLINK-2332: --- GitHub user tillrohrmann opened a pull

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629503#comment-14629503 ] Suminda Dharmasena commented on FLINK-2366: --- You are using it as a library. HA

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629505#comment-14629505 ] Till Rohrmann commented on FLINK-2366: -- But why can you not do the same with ZK? If

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629515#comment-14629515 ] Fabian Hueske commented on FLINK-2366: -- Besides being a distributed data processing

[jira] [Commented] (FLINK-2365) Review of How to contribute page

2015-07-16 Thread Enrique Bautista Barahona (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629540#comment-14629540 ] Enrique Bautista Barahona commented on FLINK-2365: -- Here's the PR:

[jira] [Resolved] (FLINK-2364) Link to Guide is Broken

2015-07-16 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2364. --- Resolution: Not A Problem Thanks for reporting. Due to the new website's structure,

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629494#comment-14629494 ] Suminda Dharmasena commented on FLINK-2366: --- You can have an embedded DB to

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629500#comment-14629500 ] Fabian Hueske commented on FLINK-2366: -- What exactly do you mean by using Flink

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629507#comment-14629507 ] Till Rohrmann commented on FLINK-2366: -- But in the end, you will execute your jobs on

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629514#comment-14629514 ] Suminda Dharmasena commented on FLINK-2366: --- Do not want to start another

[jira] [Commented] (FLINK-2267) Support multi-class scoring for binary classification scores

2015-07-16 Thread Rohit Shinde (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629549#comment-14629549 ] Rohit Shinde commented on FLINK-2267: - Can this issue be assigned to me? What all

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629565#comment-14629565 ] Till Rohrmann commented on FLINK-2366: -- What do you mean exactly with embedded and

[jira] [Commented] (FLINK-2364) Link to Guide is Broken

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629508#comment-14629508 ] Suminda Dharmasena commented on FLINK-2364: --- I cannot rememeber the refereing

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629532#comment-14629532 ] Suminda Dharmasena commented on FLINK-2366: --- What I am pushing for is embedded,

[jira] [Comment Edited] (FLINK-2300) Links on FAQ page not rendered correctly

2015-07-16 Thread Enrique Bautista Barahona (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628555#comment-14628555 ] Enrique Bautista Barahona edited comment on FLINK-2300 at 7/16/15 10:38 AM:

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

2015-07-16 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-121924666 Okay. @tillrohrmann, can you review 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

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629545#comment-14629545 ] ASF GitHub Bot commented on FLINK-2131: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

2015-07-16 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-121928501 Will do, once I have some free time. Currently I've to finish the high availability support. Try to hurry up. On Thu, Jul 16, 2015 at 12:50 PM, Sachin

[jira] [Closed] (FLINK-1748) Integrate PageRank implementation into machine learning library

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1748. Resolution: Done As part of Gelly. Integrate PageRank implementation into machine learning

[GitHub] flink pull request: [FLINK-2332] [runtime] Adds leader session IDs...

2015-07-16 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/917 [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs ## Registration Session IDs Introduces registration session IDs for all registration messages. Upon

[jira] [Updated] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2366: - Priority: Minor (was: Blocker) HA Without ZooKeeper

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629373#comment-14629373 ] Paris Carbone commented on FLINK-2366: -- That's a tough one! ^^ If you mean using

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

2015-07-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629596#comment-14629596 ] Ufuk Celebi commented on FLINK-2366: I agree with Till. The use case with embedded

[jira] [Created] (FLINK-2368) Add a convergence criteria

2015-07-16 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2368: -- Summary: Add a convergence criteria Key: FLINK-2368 URL: https://issues.apache.org/jira/browse/FLINK-2368 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log file can't auto be recovered/detected after mistaking delete

2015-07-16 Thread chenliang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang updated FLINK-2367: - Issue Type: Improvement (was: Bug) “flink-xx-jobmanager-linux-3lsu.log file can't auto be

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

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

[jira] [Commented] (FLINK-2368) Add a convergence criteria

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629757#comment-14629757 ] ASF GitHub Bot commented on FLINK-2368: --- GitHub user sachingoel0101 opened a pull

[GitHub] flink pull request: [FLINK-2368][ml]Adds convergence criteria [WIP...

2015-07-16 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/918#discussion_r34788837 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/SVM.scala --- @@ -382,7 +402,11 @@ object SVM{

[jira] [Commented] (FLINK-2368) Add a convergence criteria

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629761#comment-14629761 ] ASF GitHub Bot commented on FLINK-2368: --- Github user sachingoel0101 commented on a

[GitHub] flink pull request: [FLINK-2368][ml]Adds convergence criteria [WIP...

2015-07-16 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/918 [FLINK-2368][ml]Adds convergence criteria [WIP] Adds a convergence criteria class which allows the user to decide whether they want to terminate training at any point, based on the solutions

[jira] [Created] (FLINK-2369) On Windows, in testFailingSortingDataSinkTask the temp file is not removed

2015-07-16 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2369: -- Summary: On Windows, in testFailingSortingDataSinkTask the temp file is not removed Key: FLINK-2369 URL: https://issues.apache.org/jira/browse/FLINK-2369 Project: Flink

[jira] [Created] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log file can't auto be recovered/detected after mistaking delete

2015-07-16 Thread chenliang (JIRA)
chenliang created FLINK-2367: Summary: “flink-xx-jobmanager-linux-3lsu.log file can't auto be recovered/detected after mistaking delete Key: FLINK-2367 URL: https://issues.apache.org/jira/browse/FLINK-2367

[jira] [Created] (FLINK-2370) Unify Client Code

2015-07-16 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2370: -- Summary: Unify Client Code Key: FLINK-2370 URL: https://issues.apache.org/jira/browse/FLINK-2370 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

2015-07-16 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-122071560 Added fix for https://issues.apache.org/jira/browse/FLINK-2338 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Updated] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi

2015-07-16 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-2352: --- Assignee: Shivani Ghatge [Graph Visualization] Integrate Gelly with Gephi

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

2015-07-16 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630360#comment-14630360 ] Andra Lungu commented on FLINK-2361: Hi, I tweaked the code to look like this:

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630233#comment-14630233 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull

[GitHub] flink pull request: Update README.md

2015-07-16 Thread chenliag613
Github user chenliag613 closed the pull request at: https://github.com/apache/flink/pull/912 --- 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-2366) HA Without ZooKeeper

2015-07-16 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630814#comment-14630814 ] Suminda Dharmasena commented on FLINK-2366: --- In which case can you add the

[GitHub] flink pull request: Update README.md

2015-07-16 Thread chenliag613
Github user chenliag613 commented on the pull request: https://github.com/apache/flink/pull/912#issuecomment-122147385 Thanks @chiwanpark @mxm . --- 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-1963] Improve distinct() transformation

2015-07-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-122121617 No worries :-) You better use a dedicated branch for your next PR instead of the master branch. I'll go ahead and merge this PR now. Thanks for the

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

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

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-122132484 Merged, thanks for the contribution @pp86 ! --- 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

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

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

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/905 --- 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-1963) Improve distinct() transformation

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630551#comment-14630551 ] ASF GitHub Bot commented on FLINK-1963: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

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

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/905#discussion_r34847588 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/DistinctITCase.java --- @@ -274,4 +277,45 @@ public Integer map(POJO value)

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-122131578 Good catch @hsaputra :-) I'll fix it before merging --- 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-1963) Improve distinct() transformation

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

[jira] [Commented] (FLINK-685) Add support for semi-joins

2015-07-16 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630528#comment-14630528 ] pietro pinoli commented on FLINK-685: - Dear [~fhueske], are you (community) still

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-16 Thread pp86
Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-122118573 Hi @fhueske , I'm very sorry, this is the first time I work with github, I am doing some mess :| But, I think I finally succeeded in removing the unwanted

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630431#comment-14630431 ] ASF GitHub Bot commented on FLINK-1963: --- Github user pp86 commented on the pull