[jira] [Resolved] (FLINK-2285) Active policy emits elements of the last window twice

2015-07-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-2285. --- Resolution: Fixed Fixed via 6c21862. > Active policy emits elements of the last window twice

[GitHub] flink pull request: [FLINK-2285] [streaming] Removed duplicate cal...

2015-07-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/873 --- 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-2285) Active policy emits elements of the last window twice

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

[jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612788#comment-14612788 ] ASF GitHub Bot commented on FLINK-1085: --- Github user dabaitu commented on the pull r

[GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc...

2015-07-02 Thread dabaitu
Github user dabaitu commented on the pull request: https://github.com/apache/flink/pull/854#issuecomment-118219396 @StephanEwen please review again. Thanks! --- 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

[GitHub] flink pull request: My branch

2015-07-02 Thread samk3211
Github user samk3211 closed the pull request at: https://github.com/apache/flink/pull/881 --- 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-Gelly] [example] added missing assumpti...

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/883#issuecomment-118181248 Hi @samk3211! Thank you for spotting this :) Can you please (1) close #881, (2) add this comment also to GSAPageRank as @andralungu (3) squash your commits to a single o

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

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

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/877#issuecomment-118180990 In my view it's a straight-forward configuration option. If the user wants to propagate changes in this direction, they set the parameter. Also, I'm seeing that Gelly i

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-02 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/877#issuecomment-118179979 Hihi! Shivani is updating the PR on the fly :) Reminds me of myself back in the day ;) If I may tease: If these GSA parameters did not have an example, I would

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612601#comment-14612601 ] ASF GitHub Bot commented on FLINK-2141: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/877#issuecomment-118179278 Hi @shghatge! This looks good in general. Apart from my small inline comment, I have an objection regarding the added example. If I understand correctly, this exampl

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

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

[GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi...

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/877#discussion_r33826389 --- Diff: docs/libs/gelly_guide.md --- @@ -734,6 +737,24 @@ public static final class Apply { {% endhighlight %} +The following example illus

[jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612583#comment-14612583 ] ASF GitHub Bot commented on FLINK-2141: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: My branch

2015-07-02 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/881#issuecomment-118177927 I am a bit out of context here, but I believe this PR should be deleted :) --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Resolved] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu resolved FLINK-2150. Resolution: Fixed > Add a library method that assigns unique Long values to vertices > -

[jira] [Updated] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-2150: --- Affects Version/s: 0.9 Fix Version/s: 0.10 > Add a library method that assigns unique Long val

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

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

[GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds

2015-07-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/801 --- 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-1520]Read edges and vertices from CSV f...

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-118173012 Hi @shghatge! Thank you for the update :) I left some comments inline. There are still some formatting issues in the code. Please, carefully go through your changes

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

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

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

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

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

2015-07-02 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33824099 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java --- @@ -54,16 +75,13 @@ public void testCre

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612541#comment-14612541 ] ASF GitHub Bot commented on FLINK-2150: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds

2015-07-02 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-118171270 Merging... --- 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

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

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612537#comment-14612537 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in th

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

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

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

2015-07-02 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33823858 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the Apache Sof

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

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33823849 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationWithMapperITCase.java --- @@ -52,16 +72,13 @@ public void

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

2015-07-02 Thread shghatge
Github user shghatge commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33823720 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the Apache Sof

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

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612532#comment-14612532 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in th

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

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

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

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33823666 --- Diff: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphCreationITCase.java --- @@ -54,16 +75,13 @@ public void testCreate

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

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33822653 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the Apache Softwa

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

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612516#comment-14612516 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in th

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

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612513#comment-14612513 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on a diff in th

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

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/847#discussion_r33822502 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/GraphCsvReader.java --- @@ -0,0 +1,471 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

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

[GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-118164049 Great work @andralungu, +1 from me! Make sure you squash your commits and appropriately update the commit message before merging ;) --- If your project is set up for i

[GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds

2015-07-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/801#discussion_r33820633 --- Diff: docs/apis/zip_elements_guide.md --- @@ -63,4 +63,44 @@ env.execute() will yield the tuples: (0,A), (1,B), (2,C), (3,D), (4,E), (5,F)

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612491#comment-14612491 ] ASF GitHub Bot commented on FLINK-2150: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: Hits

2015-07-02 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-118161158 Hi there! What is the status of this PR? It seems that travis is failing with checkstyle violations related to using spaces instead of tabs. Let us know if you n

[jira] [Commented] (FLINK-2309) Use static code analysis to replace selector functions with field accesses.

2015-07-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612399#comment-14612399 ] Timo Walther commented on FLINK-2309: - Yes, indeed. Another reason to actually use the

[jira] [Created] (FLINK-2316) Optimize the SCA for bytecode generated by Scala

2015-07-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-2316: --- Summary: Optimize the SCA for bytecode generated by Scala Key: FLINK-2316 URL: https://issues.apache.org/jira/browse/FLINK-2316 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612357#comment-14612357 ] ASF GitHub Bot commented on FLINK-1085: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc...

2015-07-02 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/854#discussion_r33809780 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/CombineTaskTest.java --- @@ -92,7 +92,35 @@ public void testCombineTask() {

[jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612355#comment-14612355 ] ASF GitHub Bot commented on FLINK-1085: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc...

2015-07-02 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/854#discussion_r33809590 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java --- @@ -170,7 +171,14 @@ public void run() throws E

[jira] [Created] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

2015-07-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2315: --- Summary: Hadoop Writables cannot exploit implementing NormalizableKey Key: FLINK-2315 URL: https://issues.apache.org/jira/browse/FLINK-2315 Project: Flink Iss

[jira] [Commented] (FLINK-2305) Add documenation about Storm compatibility layer

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

[GitHub] flink pull request: [FLINK-2305] Add documenation about Storm comp...

2015-07-02 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/884 [FLINK-2305] Add documenation about Storm compatibility layer additional improvements - added RawOutputFormatter - bug fix in SimpleOutputFormatter - enable default output formatter for Stor

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118083599 OK then we can close the issue as wontfix. --- 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 pro

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118074547 I think that setting the dependency to "provided" is something the user should do, because it actually depends on the user environment. --- If your project is set up fo

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118074166 The PR from @tammymendt is outdated. The `flink-contrib` is packaging to jar (not pom) in this old version. --- If your project is set up for it, you can reply to this ema

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118072783 I think the statistics collection pull request has been created before we splitted the `flink-contrib` project into individual submodules. Now contrib is much more fi

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118066010 OK thanks for the remark. Although somewhat verbose, this solves my concrete issue. I wonder if the list can be exclusive, e.g. ```xml

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118063336 The PR is still open and can be adapted. --- 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 proje

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

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

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

2015-07-02 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/879#issuecomment-118058537 I ran some more numbers on the cluster. With watermark interval 1 Second there is no noticeable difference in performance. I will now investigate sending the watermarks

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

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

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33782762 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the Apac

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118047809 I see. But changing the scope to "provided" is the wrong way to go. You need to exclude unnecessary sub-module dependencies: ``` org.apache.flink flink-

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[jira] [Updated] (FLINK-2314) Make Streaming File Sources Persistent

2015-07-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2314: Labels: easyfix starter (was: ) > Make Streaming File Sources Persistent >

[jira] [Created] (FLINK-2314) Make Streaming File Sources Persistent

2015-07-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2314: --- Summary: Make Streaming File Sources Persistent Key: FLINK-2314 URL: https://issues.apache.org/jira/browse/FLINK-2314 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33778892 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611975#comment-14611975 ] ASF GitHub Bot commented on FLINK-2157: --- Github user tillrohrmann commented on a dif

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

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

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

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

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

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

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

2015-07-02 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/879#issuecomment-118037541 Also, when using TaskManagers with 512mb the performance degrades heavily when running successive tests, seems to be related to garbage collection. (On both master and e

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33778292 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the Apac

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

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

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33778337 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the Apac

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

2015-07-02 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/879#issuecomment-118037363 Ok, the test results I posted earlier seem correct. I also ran the tests on my machine with two TaskManagers, There the result is the same for master/event-time/event-ti

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118036089 @StephanEwen can you tell me what package doesn't work so I can test it out? --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided"

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

[GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ...

2015-07-02 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/880#issuecomment-118035911 @mjsax exactly. Let's at the moment I land in the following situtaion. 1. I want to create a job which includes the [statistics collection facility proposed

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

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611950#comment-14611950 ] Andra Lungu commented on FLINK-2299: I see... This means that the problem can still be

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

2015-07-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611946#comment-14611946 ] Stephan Ewen commented on FLINK-2299: - The JobManager is not dying. It temporarily los

[jira] [Commented] (FLINK-2293) Division by Zero Exception

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611943#comment-14611943 ] Andra Lungu commented on FLINK-2293: Hi [~StephanEwen], I am trying to prepare my set

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

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611939#comment-14611939 ] Andra Lungu edited comment on FLINK-2299 at 7/2/15 1:14 PM: Th

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

2015-07-02 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611939#comment-14611939 ] Andra Lungu commented on FLINK-2299: The JM seems to have died at this time: 00:46:06

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33775317 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611930#comment-14611930 ] ASF GitHub Bot commented on FLINK-2157: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2015-07-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14611929#comment-14611929 ] ASF GitHub Bot commented on FLINK-2157: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/871#discussion_r33775244 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Classifier.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

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

[GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram...

2015-07-02 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/871#issuecomment-118026838 I'll also rebase on the latest master, so that we can get the SVM code in, without the commits here. --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

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

[jira] [Resolved] (FLINK-2297) Add threshold setting for SVM binary predictions

2015-07-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2297. -- Resolution: Fixed Fixed via eb23f80742e743a75888f5d4fbed879383b6741e > Add threshold setting fo

[jira] [Commented] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki

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

  1   2   3   >