[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

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

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/922#issuecomment-122805962 Thanks for improving the documentation. Looks good to merge for me. --- 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-2362) distinct is missing in DataSet API documentation

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

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-20 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/922#discussion_r34974826 --- Diff: docs/apis/dataset_transformations.md --- @@ -924,6 +924,183 @@ Not supported. **Note:** Extending the set of supported aggregation functions

[jira] [Commented] (FLINK-1723) Add cross validation for model evaluation

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

[jira] [Commented] (FLINK-1723) Add cross validation for model evaluation

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

[jira] [Updated] (FLINK-2379) Add methods to evaluate field wise statistics over DataSet of vectors.

2015-07-20 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Goel updated FLINK-2379: --- Description: Design methods to evaluate statistics over dataset of vectors. For continuous fields,

[GitHub] flink pull request: [FLINK-2075] Add Approximate Adamic Adar Simil...

2015-07-20 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/923#issuecomment-122784993 I think you've referenced the wrong jira ticket. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-2075) Shade akka and protobuf dependencies away

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

[jira] [Commented] (FLINK-2312) Random Splits

2015-07-20 Thread Maximilian Alber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633118#comment-14633118 ] Maximilian Alber commented on FLINK-2312: - I agree too. Something else: How do

[GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f...

2015-07-20 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/891#discussion_r34973783 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/CrossValidation.scala --- @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2312][ml][WIP] Randomly Splitting a Dat...

2015-07-20 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/921#issuecomment-122785194 I agree, a generalized implementation would be favorable. --- 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-2312) Random Splits

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

[GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f...

2015-07-20 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/891#discussion_r34973140 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/CrossValidation.scala --- @@ -0,0 +1,97 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

2015-07-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633162#comment-14633162 ] Stephan Ewen commented on FLINK-2377: - Can you verify that this is a problem of the

[jira] [Resolved] (FLINK-2027) Flink website does not provide link to source repo

2015-07-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2027. Resolution: Fixed I think this was reopened by accident. Flink website does not provide link to

[jira] [Commented] (FLINK-1723) Add cross validation for model evaluation

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

[GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f...

2015-07-20 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/891#discussion_r34976620 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/CrossValidation.scala --- @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f...

2015-07-20 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/891#discussion_r34975724 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/evaluation/CrossValidation.scala --- @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-20 Thread pp86
Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/922#issuecomment-122815918 Thanks for the suggestion @mxm , I updated the documentation. --- 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-2367) “flink-xx-jobmanager-linux-3lsu.log file can't auto be recovered/detected after mistaking delete

2015-07-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633163#comment-14633163 ] Maximilian Michels commented on FLINK-2367: --- I'm afraid the logger is unaware of

[jira] [Commented] (FLINK-1723) Add cross validation for model evaluation

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

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-07-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633166#comment-14633166 ] Ufuk Celebi commented on FLINK-2299: The FAQ is on the website repository flink-web

[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

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

[jira] [Created] (FLINK-2380) Allow to configure default FS for file inputs

2015-07-20 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2380: -- Summary: Allow to configure default FS for file inputs Key: FLINK-2380 URL: https://issues.apache.org/jira/browse/FLINK-2380 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-07-20 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu resolved FLINK-2299. Resolution: Fixed Fix Version/s: (was: 0.9.1) 0.10 The slot on which

[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

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

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-20 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/922#discussion_r34984880 --- Diff: docs/apis/programming_guide.md --- @@ -606,7 +606,17 @@ DataSetTuple3Integer, String, Double output = input.sum(0).andMin(2); /td

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-07-20 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633422#comment-14633422 ] Andra Lungu commented on FLINK-2299: Thanks, Ufuk! :) The slot on which the task

[jira] [Commented] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters

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

[GitHub] flink pull request: [FLINK-2375] Add Approximate Adamic Adar Simil...

2015-07-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/923#issuecomment-122868758 Could you also do a git ammend to reference the correct jira issue in the commit? --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

2015-07-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633525#comment-14633525 ] Gabor Gevay commented on FLINK-2377: Yes, I have found the problem:

[GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu...

2015-07-20 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/924 [FLINK-2377] Add reader.close() to readAllResultLines You can merge this pull request into a Git repository by running: $ git pull https://github.com/ggevay/flink readAllResultLinesFix

[jira] [Assigned] (FLINK-2381) Possible class not found Exception on failed partition producer

2015-07-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-2381: -- Assignee: Ufuk Celebi Possible class not found Exception on failed partition producer

[jira] [Created] (FLINK-2381) Possible class not found Exception on failed partition producer

2015-07-20 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2381: -- Summary: Possible class not found Exception on failed partition producer Key: FLINK-2381 URL: https://issues.apache.org/jira/browse/FLINK-2381 Project: Flink

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

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

[GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu...

2015-07-20 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/924#issuecomment-122893574 Great catch! Looks good 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

[jira] [Created] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks

2015-07-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2382: --- Summary: Live Metric Reporting Does Not Work for Two-Input StreamTasks Key: FLINK-2382 URL: https://issues.apache.org/jira/browse/FLINK-2382 Project: Flink

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

2015-07-20 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-122949512 Does anyone have any objections still? The impact of the timestamps is now completely disabled by default. If there are no objections I would like to merge this

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

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

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

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

[jira] [Assigned] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks

2015-07-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2382: - Assignee: Maximilian Michels Live Metric Reporting Does Not Work for Two-Input

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

2015-07-20 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/925 [FLINK-2371] improve AccumulatorLiveITCase Instead of using Thread.sleep() to synchronize the checks of the accumulator values, we rely on message passing here to synchronize the task process.

[jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example

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

[GitHub] flink pull request: [FLINK-2375] Add Approximate Adamic Adar Simil...

2015-07-20 Thread shghatge
Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/923#issuecomment-123051521 Updated PR @vasia I removed the Vertex Centric Iteration :) Hope this method is okay. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa...

2015-07-20 Thread shghatge
Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/892#issuecomment-123051793 @andralungu @vasia PR has been updated to make the code more efficient. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters

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

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-20 Thread shghatge
Github user shghatge commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-123057981 The only problem with assuming NullValue if a value is missing is that we can't return NullValue in place of VV. I mean to say GraphK, VV, EV in this VV or EV can't

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

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

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

2015-07-20 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634358#comment-14634358 ] pietro pinoli commented on FLINK-685: - Hi [~fhueske], then if I implement the dummy

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

2015-07-20 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pietro pinoli reassigned FLINK-685: --- Assignee: pietro pinoli Add support for semi-joins --

[GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa...

2015-07-20 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/892#issuecomment-123153943 Hi @shghatge , Did you also run the two examples on the cluster to make sure that the approximate version is faster? Then you could also add some numbers

[jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example

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