[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707972#comment-14707972 ] ASF GitHub Bot commented on FLINK-1901: --- Github user thvasilo commented on the pull

[jira] [Commented] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707946#comment-14707946 ] Vasia Kalavri commented on FLINK-2548: -- [~ggevay], an approach similar to what you

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14707979#comment-14707979 ] Martin Liesenberg commented on FLINK-2445: -- Hi, I have a question concerning the

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708000#comment-14708000 ] Martin Liesenberg commented on FLINK-2017: -- Hi, I'd like to work on this

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/949#issuecomment-133675023 It's great to have this in, I'll try to update the cross-validation and SGD to use this. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2030][FLINK-2274][ml]Online Histograms ...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-133707118 @tillrohrmann, thanks for the brilliant suggestions. Using a `TreeMap` and `PriorityQueue` with invalidation, I've managed to bring down the complexity of the

[jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features

[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708043#comment-14708043 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2448]Clear cache file list in Execution...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1031#issuecomment-133788218 Travis passes. :) I asked on the dev list about the two small changes in flink-gelly. @vasia --- If your project is set up for it, you can reply to this

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1000 --- 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-2451) Cleanup Gelly examples

[ https://issues.apache.org/jira/browse/FLINK-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708142#comment-14708142 ] ASF GitHub Bot commented on FLINK-2451: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-2562) [py] Implement KeySelectors

Chesnay Schepler created FLINK-2562: --- Summary: [py] Implement KeySelectors Key: FLINK-2562 URL: https://issues.apache.org/jira/browse/FLINK-2562 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-2451) Cleanup Gelly examples

[ https://issues.apache.org/jira/browse/FLINK-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri closed FLINK-2451. Resolution: Fixed Fix Version/s: 0.10 Cleanup Gelly examples --

[jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708305#comment-14708305 ] ASF GitHub Bot commented on FLINK-2448: --- Github user sachingoel0101 commented on the

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

[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708092#comment-14708092 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on the pull

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

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-133727559 Thanks for the comments @andralungu! @shghatge, can you please close this PR? I will make the docs update and open a new one, which will include your work and my

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

[ https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708097#comment-14708097 ] ASF GitHub Bot commented on FLINK-2310: --- Github user vasia commented on the pull

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

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/892#issuecomment-133728081 Any progress on this and #923 @shghatge? --- 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-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708099#comment-14708099 ] Vasia Kalavri commented on FLINK-2033: -- I can close this one now, right [~vanaepi]?

[jira] [Created] (FLINK-2561) Sync Gelly Java and Scala APIs

Vasia Kalavri created FLINK-2561: Summary: Sync Gelly Java and Scala APIs Key: FLINK-2561 URL: https://issues.apache.org/jira/browse/FLINK-2561 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708102#comment-14708102 ] ASF GitHub Bot commented on FLINK-1962: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API v2

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-133730158 I have created [FLINK-2561](https://issues.apache.org/jira/browse/FLINK-2561) for the sync. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1040#discussion_r37697987 --- Diff: docs/apis/streaming_guide.md --- @@ -1517,11 +1517,24 @@ Stream connectors !-- TODO: reintroduce flume --

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708115#comment-14708115 ] ASF GitHub Bot commented on FLINK-2558: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1040#discussion_r37698000 --- Diff: docs/apis/streaming_guide.md --- @@ -1661,6 +1674,165 @@ More about Kafka can be found [here](https://kafka.apache.org/documentation.html

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708114#comment-14708114 ] ASF GitHub Bot commented on FLINK-2558: --- Github user aljoscha commented on a diff in

[jira] [Updated] (FLINK-2439) [py] Expand DataSet feature coverage

[ https://issues.apache.org/jira/browse/FLINK-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2439: Description: An upcoming commit of mine will add the following methods to the Python API's

[jira] [Updated] (FLINK-2432) [py] Provide support for custom serialization

[ https://issues.apache.org/jira/browse/FLINK-2432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2432: Issue Type: Sub-task (was: New Feature) Parent: FLINK-1926 [py] Provide support

[jira] [Updated] (FLINK-2439) [py] Expand DataSet feature coverage

[ https://issues.apache.org/jira/browse/FLINK-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2439: Issue Type: Sub-task (was: Improvement) Parent: FLINK-1926 [py] Expand DataSet

[jira] [Updated] (FLINK-2440) [py] Expand Environment feature coverage

[ https://issues.apache.org/jira/browse/FLINK-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2440: Issue Type: Sub-task (was: Improvement) Parent: FLINK-1926 [py] Expand

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708075#comment-14708075 ] ASF GitHub Bot commented on FLINK-2558: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1040#discussion_r37697064 --- Diff: docs/apis/streaming_guide.md --- @@ -1661,6 +1674,165 @@ More about Kafka can be found [here](https://kafka.apache.org/documentation.html

[jira] [Commented] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse

[ https://issues.apache.org/jira/browse/FLINK-2560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708078#comment-14708078 ] ASF GitHub Bot commented on FLINK-2560: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2560] Flink-Avro Plugin cannot be handl...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1041#issuecomment-133718527 Looks good, +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

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708074#comment-14708074 ] ASF GitHub Bot commented on FLINK-2558: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1040#issuecomment-133718325 Added two minor comments on the docs/interface, but treat those as optional, they are and matter of taste anyways. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708076#comment-14708076 ] ASF GitHub Bot commented on FLINK-2558: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708077#comment-14708077 ] ASF GitHub Bot commented on FLINK-2558: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1040#discussion_r37697052 --- Diff: docs/apis/streaming_guide.md --- @@ -1517,11 +1517,24 @@ Stream connectors !-- TODO: reintroduce flume --

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1040#issuecomment-133718276 This looks pretty nice :-) Docs, tests, good comments, cluster tests! +1 to merge this! --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1000#issuecomment-133725849 Thank you for the review @andralungu. I will rebase and merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-2451) Cleanup Gelly examples

[ https://issues.apache.org/jira/browse/FLINK-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708089#comment-14708089 ] ASF GitHub Bot commented on FLINK-2451: --- Github user vasia commented on the pull