[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-19 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551889#comment-14551889 ] Laurent Tardif commented on FLINK-1848: --- going a bit deepper in the investigation sh

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

2015-05-19 Thread Raghav Chalapathy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551753#comment-14551753 ] Raghav Chalapathy commented on FLINK-1733: -- Hi Till Let me go through the paper

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java. the feature branch can be found

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java. [the feature branch can be foun

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java. [the feature branch can be foun

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java. (was: Implementation of Hits A

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Description: Implementation of Hits Algorithm in Gelly API using Java. The [feature branch can be foun

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Attachment: (was: HitsMain.java) > Implementation of Gelly HITS Algorithm > --

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Attachment: (was: Hits_Class.java) > Implementation of Gelly HITS Algorithm >

[jira] [Resolved] (FLINK-1523) Vertex-centric iteration extensions

2015-05-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-1523. -- Resolution: Implemented Fix Version/s: 0.9 > Vertex-centric iteration extensions > --

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551220#comment-14551220 ] ASF GitHub Bot commented on FLINK-1523: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [gelly][Refactoring] Removed example string

2015-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/625 --- 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 enabl

[GitHub] flink pull request: [FLINK-1523] vertex-centric iteration extensio...

2015-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/680 --- 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 enabl

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551203#comment-14551203 ] Vasia Kalavri commented on FLINK-2044: -- Hello [~JavidMayar]! Thank you for your effor

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

2015-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/676 --- 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 enabl

[jira] [Assigned] (FLINK-2052) Clear up Serializable warnings in streaming operators

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2052: --- Assignee: Aljoscha Krettek > Clear up Serializable warnings in streaming operators >

[jira] [Commented] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551139#comment-14551139 ] Aljoscha Krettek commented on FLINK-2051: - Thanks for spotting this, I forgot to a

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

2015-05-19 Thread senorcarbone
Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/676#discussion_r30637229 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ByteStreamStateHandle.java --- @@ -0,0 +1,77 @@ +/* + * Licensed to the Apac

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

2015-05-19 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/676#discussion_r30637002 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ByteStreamStateHandle.java --- @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Sof

[GitHub] flink pull request: [gelly][Refactoring] Removed example string

2015-05-19 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/625#issuecomment-103641540 I take it your update means you agreed with my suggestion :) I'll merge this one as well! --- If your project is set up for it, you can reply to this email and have you

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

2015-05-19 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/676#issuecomment-103640808 Apart from my comment on the transient field I think this is ok to merge. Perhaps we can look into standardising the task manager backend configuration afterwards. S

[GitHub] flink pull request: Pluggable state backend support for checkpoint...

2015-05-19 Thread senorcarbone
Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/676#discussion_r30636159 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ByteStreamStateHandle.java --- @@ -0,0 +1,77 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14551050#comment-14551050 ] ASF GitHub Bot commented on FLINK-1907: --- Github user nikste commented on the pull re

[GitHub] flink pull request: [FLINK-1907] Scala shell

2015-05-19 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/672#issuecomment-103638341 Fixed according to comments and linux terminal issue, should now pass all tests. --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550892#comment-14550892 ] Stephan Ewen commented on FLINK-1952: - Next step in the diagnosis: There is apparently

[jira] [Created] (FLINK-2052) Clear up Serializable warnings in streaming operators

2015-05-19 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2052: - Summary: Clear up Serializable warnings in streaming operators Key: FLINK-2052 URL: https://issues.apache.org/jira/browse/FLINK-2052 Project: Flink Issue Type: Tas

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30622734 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30622577 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103597087 Unfortunately, it is not possible ti implement this as Junit Tests. The stream connection needs access keys of a twitter account and the maximum number of parallel

[jira] [Created] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

2015-05-19 Thread JIRA
Márton Balassi created FLINK-2051: - Summary: Fix disabled test in ComplexIntegrationTest Key: FLINK-2051 URL: https://issues.apache.org/jira/browse/FLINK-2051 Project: Flink Issue Type: Bug

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30621383 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSource.java ---

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30620688 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceTest.java ---

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/695#discussion_r30620574 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSource.java --- @

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103579307 That would be really great, thank you! --- 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 do

[GitHub] flink pull request: [FLINK-2012][gelly] Added methods to remove/ad...

2015-05-19 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/678#issuecomment-103574952 Thanks for this PR @andralungu! There are a few things we need to consider here I think: - when to have a `DataSet` argument and when to have a `List`. For examp

[jira] [Commented] (FLINK-2012) addVertices, addEdges, removeVertices, removeEdges methods

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550693#comment-14550693 ] ASF GitHub Bot commented on FLINK-2012: --- Github user vasia commented on the pull req

[jira] [Resolved] (FLINK-2035) Update 0.9 roadmap with ML issues

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2035. -- Resolution: Fixed Marked corresponding jira issues and added them to the google doc. > Update 0

[jira] [Created] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators

2015-05-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2050: Summary: Add pipelining mechanism for chainable transformers and estimators Key: FLINK-2050 URL: https://issues.apache.org/jira/browse/FLINK-2050 Project: Flink

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread Sebastian Schelter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550585#comment-14550585 ] Sebastian Schelter commented on FLINK-2026: --- In that case, it should be fine to

[jira] [Updated] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1992: - Fix Version/s: 0.9 > Add convergence criterion to SGD optimizer >

[jira] [Updated] (FLINK-1993) Replace MultipleLinearRegression's custom SGD with optimization framework's SGD

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1993: - Fix Version/s: 0.9 > Replace MultipleLinearRegression's custom SGD with optimization framework's

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Assignee: Sachin Goel > Implement an online histogram with Merging and equalization features > ---

[jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm

2015-05-19 Thread Ahamd Javid (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahamd Javid updated FLINK-2044: --- Summary: Implementation of Gelly HITS Algorithm (was: Implementation of Gelly Algorithm HITS) > Impl

[jira] [Commented] (FLINK-2044) Implementation of Gelly Algorithm HITS

2015-05-19 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550568#comment-14550568 ] Alexander Alexandrov commented on FLINK-2044: - The [feature branch can be foun

[jira] [Closed] (FLINK-1971) Add user function type to StreamOperator

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1971. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in https://github.com/apache/flink/commi

[jira] [Closed] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1977. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in https://github.com/apache/flink/commit/5

[jira] [Closed] (FLINK-2009) Time-Based Windows fail with Chaining Disabled

2015-05-19 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2009. --- Resolution: Fixed Fixed in https://github.com/apache/flink/commit/a04f091217cedccb00bb21a4686

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550549#comment-14550549 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha closed the pull reques

[jira] [Commented] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550548#comment-14550548 ] ASF GitHub Bot commented on FLINK-1977: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-19 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/659 --- 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 ena

[GitHub] flink pull request: [FLINK-1977] Rework Stream Operators to always...

2015-05-19 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/659#issuecomment-103530579 Manually merged --- 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 featur

[jira] [Updated] (FLINK-2034) Add vision and roadmap for ML library to docs

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2034: - Fix Version/s: 0.9 > Add vision and roadmap for ML library to docs > -

[jira] [Updated] (FLINK-2035) Update 0.9 roadmap with ML issues

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2035: - Fix Version/s: 0.9 > Update 0.9 roadmap with ML issues > - > >

[jira] [Created] (FLINK-2049) KafkaSink sporadically fails to send message

2015-05-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2049: - Summary: KafkaSink sporadically fails to send message Key: FLINK-2049 URL: https://issues.apache.org/jira/browse/FLINK-2049 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1992: --- Priority: Minor (was: Major) > Add convergence criterion to SGD optimizer > -

[jira] [Commented] (FLINK-2007) Initial data point in Delta function needs to be serializable

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550482#comment-14550482 ] ASF GitHub Bot commented on FLINK-2007: --- GitHub user mbalassi opened a pull request:

[GitHub] flink pull request: [FLINK-2007] [streaming] Proper Delta policy s...

2015-05-19 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/697 [FLINK-2007] [streaming] Proper Delta policy serialization The initial value passed to the Delta policy has to be serialized to be transferred to the cluster. This change adds the standard Flink ser

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Description: Dimension reduction is a crucial prerequisite for many data analysis tasks. Therefor

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Description: Dimension reduction is a crucial prerequisite for many data analysis tasks. Therefor

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103499923 It is possible to implement an integration test. For example, I can track a term and then I has to check if all tweets contain the term. If you want I can i

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550463#comment-14550463 ] Till Rohrmann commented on FLINK-1733: -- I found a new publication on scalable PCA com

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Priority: Minor (was: Major) > Add PCA to machine learning library >

[jira] [Commented] (FLINK-1979) Implement Loss Functions

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550452#comment-14550452 ] Till Rohrmann commented on FLINK-1979: -- The easiest way would probably be to simply c

[jira] [Updated] (FLINK-2046) Quickstarts are missing on the new Website

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2046: -- Component/s: Quickstarts > Quickstarts are missing on the new Website >

[jira] [Commented] (FLINK-1999) TF-IDF transformer

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550448#comment-14550448 ] Till Rohrmann commented on FLINK-1999: -- You probably have to apply a similar trick as

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-103498471 Thank you for working on the issue. I'll soon review your changes in detail. From what I saw by scrolling over it, it looks very good (with log messages and documenta

[jira] [Commented] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550446#comment-14550446 ] Robert Metzger commented on FLINK-2048: --- Hi [~HilmiYildirim], I gave you "Contributo

[jira] [Updated] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2048: -- Assignee: Hilmi Yildirim > Enhance Twitter Stream support > -- > >

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

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550425#comment-14550425 ] ASF GitHub Bot commented on FLINK-1745: --- GitHub user chiwanpark opened a pull reques

[GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne...

2015-05-19 Thread chiwanpark
GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/696 [FLINK-1745] [ml] [WIP] Add exact k-nearest-neighbours algorithm to machine learning library This PR is not final but work in progress. You can see detail description in [JIRA](https://issues.apa

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550385#comment-14550385 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-19 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30595561 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/optimization/GradientDescentITSuite.scala --- @@ -205,6 +190,61 @@ class GradientDescentI

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-19 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550382#comment-14550382 ] Laurent Tardif commented on FLINK-1848: --- There also a little issue in the test that

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Priority: Minor (was: Major) > Implement an online histogram with Merging and equalization featur

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

2015-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2030: - Labels: ML (was: ) > Implement an online histogram with Merging and equalization features > -

[jira] [Created] (FLINK-2048) Enhance Twitter Stream support

2015-05-19 Thread Hilmi Yildirim (JIRA)
Hilmi Yildirim created FLINK-2048: - Summary: Enhance Twitter Stream support Key: FLINK-2048 URL: https://issues.apache.org/jira/browse/FLINK-2048 Project: Flink Issue Type: Task Com

[jira] [Commented] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-05-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550364#comment-14550364 ] Stephan Ewen commented on FLINK-1952: - Okay, I am able to reproduce it locally with a

[jira] [Commented] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550361#comment-14550361 ] ASF GitHub Bot commented on FLINK-2037: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-19 Thread HilmiYildirim
GitHub user HilmiYildirim opened a pull request: https://github.com/apache/flink/pull/695 Implemented TwitterSourceFilter and adapted TwitterSource I implemented the class TwitterFilterSource which inherits from TwitterSource. It enables to filter twitter streams, for example, by te

[GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/

2015-05-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/691#issuecomment-103471022 I think this is a hacky fix. Sounds like the right approach is to have a python cli frontend that does not expect a jar file. --- If your project is set up

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550359#comment-14550359 ] ASF GitHub Bot commented on FLINK-2026: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/686#issuecomment-103470201 Looks good, modulo the commas. +1 to merge after fixing this. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550340#comment-14550340 ] ASF GitHub Bot commented on FLINK-2026: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/686#discussion_r30592879 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java --- @@ -914,7 +917,15 @@ public JavaPlan createProgramPlan(String jobName) {

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550337#comment-14550337 ] ASF GitHub Bot commented on FLINK-2026: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550335#comment-14550335 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: [FLINK-2026] add a flag to indicate previous e...

2015-05-19 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/686#issuecomment-103463683 Pull request updated. --- 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 featu

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-19 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30592697 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/optimization/GradientDescentITSuite.scala --- @@ -205,6 +190,61 @@ class GradientDescentI

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550328#comment-14550328 ] ASF GitHub Bot commented on FLINK-2025: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/685#issuecomment-103461860 - Rebased to current master. - Now comparing on byte array instead of creating a String object. - All checks are performed case-insensitive. --- If your project is se

[jira] [Created] (FLINK-2047) Rename CoCoA to SVM

2015-05-19 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2047: -- Summary: Rename CoCoA to SVM Key: FLINK-2047 URL: https://issues.apache.org/jira/browse/FLINK-2047 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550322#comment-14550322 ] ASF GitHub Bot commented on FLINK-2025: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/685#discussion_r30592160 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/BooleanValueParser.java --- @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Commented] (FLINK-2025) Support booleans in CSV reader

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550321#comment-14550321 ] ASF GitHub Bot commented on FLINK-2025: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2025] add support for booleans in csv p...

2015-05-19 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/685#discussion_r30592154 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java --- @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] flink pull request: Implemented the class TwitterFilterSource

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/687#issuecomment-103460862 I do another Pull Request --- 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 h

[GitHub] flink pull request: Implemented the class TwitterFilterSource

2015-05-19 Thread HilmiYildirim
Github user HilmiYildirim closed the pull request at: https://github.com/apache/flink/pull/687 --- 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 i

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550311#comment-14550311 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on a diff in

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-19 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30591734 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -76,86 +77,163 @@ class GradientDescent(runPara

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550294#comment-14550294 ] ASF GitHub Bot commented on FLINK-1992: --- Github user thvasilo commented on the pull

  1   2   >