[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-132453057 @StephanEwen , I have fixed the styling issues as much as I could find out. Thanks for your patience. :) --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702524#comment-14702524 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702475#comment-14702475 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-132449408 Sure thing. I'll fix it. IntelliJ re-formats used to take care of such things, but I've stopped using it recently as it was messing up scala code. --- If your pr

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132449023 Hi @chiwanpark , I have modified the documentation to include the collect step. I have also made a few modification to how the histogram is created by using a

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132439907 Including the collect step in the documentation seems weird, IMO. Since the return type is a `DataSet[Histogram]`, anyone familiar with flink will know to collect

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

2015-08-18 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702379#comment-14702379 ] Suminda Dharmasena commented on FLINK-2366: --- OK. As long as it is *easily plugg

[jira] [Issue Comment Deleted] (FLINK-2366) HA Without ZooKeeper

2015-08-18 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suminda Dharmasena updated FLINK-2366: -- Comment: was deleted (was: OK. As long as it is *easily pluggable* it is OK. Also anoth

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

2015-08-18 Thread Suminda Dharmasena (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702380#comment-14702380 ] Suminda Dharmasena commented on FLINK-2366: --- OK. As long as it is *easily plugg

[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

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

[GitHub] flink pull request: [FLINK-2077] [core] Rework Path class and add ...

2015-08-18 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1035 [FLINK-2077] [core] Rework Path class and add extend support for Windows paths The class org.apache.flink.core.fs.Path handles paths for Flink's FileInputFormat and FileOutputFormat. Over time,

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132430686 The only problem to merge this is invalid example in documentation. We need calling `collect()` method and `apply(0)` to execute statistics methods such as `quantile`,

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1033#issuecomment-132429945 Looks good. There are some code style issues. Please modify them. BTW, Is it possible to run graph algorithm implemented with Scala in Java? If yes, it would

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1033#discussion_r37376484 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/GraphAlgorithm.scala --- @@ -0,0 +1,30 @@ +/* + * Licensed t

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1033#discussion_r37376469 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -649,10 +650,13 @@ TypeInformation : ClassTag](jg

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1033#discussion_r37376477 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -649,10 +650,13 @@ TypeInformation : ClassTag](jg

[GitHub] flink pull request: Path refactor

2015-08-18 Thread gallenvara
Github user gallenvara closed the pull request at: https://github.com/apache/flink/pull/1034 --- 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

[GitHub] flink pull request: Path refactor

2015-08-18 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1034 Path refactor You can merge this pull request into a Git repository by running: $ git pull https://github.com/gallenvara/flink path_refactor Alternatively you can review and apply these ch

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

2015-08-18 Thread ChengXiangLi
Github user ChengXiangLi commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r37373497 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/PoissonSampler.java --- @@ -0,0 +1,109 @@ +/* + * Licensed to the A

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

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

[jira] [Commented] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling

2015-08-18 Thread Min Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702049#comment-14702049 ] Min Jiang commented on FLINK-2089: -- The issue seems not resolved. I downloaded the versio

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-132322001 Sorry to be picky again, but it would be good to harmonize the code style a bit - make it more consistent with the remaining code. What struck me in particul

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

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

[jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701802#comment-14701802 ] Stephan Ewen commented on FLINK-2545: - Thanks for reporting this! As a quick fix, you

[jira] [Created] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

2015-08-18 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2545: - Summary: NegativeArraySizeException while creating hash table bloom filters Key: FLINK-2545 URL: https://issues.apache.org/jira/browse/FLINK-2545 Project: Flink I

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132264800 Haha. It's no problem. I've updated the documentation for this. :) --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132261492 Sorry to be a nitpick, but if we are going to split the PR then the documentation should be split accordingly, we can merge the column-wise statistics once this one is m

[jira] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API

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

[GitHub] flink pull request: [FLINK-2398][api-breaking] Introduce StreamGra...

2015-08-18 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/988#issuecomment-132260208 I think this is good now. I adapted the Streaming Tests to always use `StreamingMultipleProgramTestBase` when appropriate. The earlier problems where caused by some test

[jira] [Commented] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API

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

[GitHub] flink pull request: [FLINK-2386] Rework Kafka consumer for Flink

2015-08-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1028#issuecomment-132256558 I've opened a pull request with the code removed against your branch: https://github.com/StephanEwen/incubator-flink/pull/14 --- If your project is set up for it, you

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

2015-08-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r37313995 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/PoissonSampler.java --- @@ -0,0 +1,109 @@ +/* + * Licensed to the A

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

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

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

2015-08-18 Thread PieterJanVanAeken
Github user PieterJanVanAeken commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-132252484 As mentioned, they are not in sync yet. We need to create an issue to update the Scala API so that it is in sync with the Java API. A completeness test should

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

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701434#comment-14701434 ] ASF GitHub Bot commented on FLINK-1962: --- Github user PieterJanVanAeken commented on

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread PieterJanVanAeken
Github user PieterJanVanAeken commented on the pull request: https://github.com/apache/flink/pull/1033#issuecomment-132249704 By the way, let me know if I need to create a JIRA for this first but it seemed overkill for such a trivial change. --- If your project is set up for it, you

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

2015-08-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-132241841 If the APIs are in sync there should be one documentation for both, right? Similar as with the other APIs... --- If your project is set up for it, you can reply

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread PieterJanVanAeken
Github user PieterJanVanAeken commented on the pull request: https://github.com/apache/flink/pull/1033#issuecomment-132241973 Please wait a sec with this one. Something is off with my local changes vs my repo changes. --- If your project is set up for it, you can reply to this email

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

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

[GitHub] flink pull request: Add Scala version of GraphAlgorithm

2015-08-18 Thread PieterJanVanAeken
GitHub user PieterJanVanAeken opened a pull request: https://github.com/apache/flink/pull/1033 Add Scala version of GraphAlgorithm The Scala Gelly API already has a wrapper for running java-based GraphAlgorithms. It is needed for running pre-built algorithms such as the PageRankAlg

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

2015-08-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1004#issuecomment-132235443 What are the plans for documenting the Gelly Scala API ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Closed] (FLINK-2477) Add test for SocketClientSink

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2477. --- > Add test for SocketClientSink > - > > Key: FLINK-2477 >

[jira] [Resolved] (FLINK-2477) Add test for SocketClientSink

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2477. - Resolution: Implemented Implemented in d2e88ffdabb9d817f3897acd3ca3e566cf86450a Thank you for the

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

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

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

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1962. - Resolution: Implemented Fix Version/s: 0.10 Implemented in 240e8895c6e1d5ea6f67370d276cb58f

[jira] [Resolved] (FLINK-2529) fix on some unused code for flink-runtime

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2529. - Resolution: Fixed Fixed in 8a59f87bd4b3ec15d9bafae8e7de6d8a55e070b1 > fix on some unused code for

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

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1962. --- > Add Gelly Scala API > --- > > Key: FLINK-1962 > URL: htt

[jira] [Commented] (FLINK-2529) fix on some unused code for flink-runtime

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

[GitHub] flink pull request: [FLINK-2477][Add]Add tests for SocketClientSin...

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/977 --- 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] [Closed] (FLINK-2529) fix on some unused code for flink-runtime

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2529. --- > fix on some unused code for flink-runtime > - > >

[GitHub] flink pull request: [FLINK-2529][runtime]remove some unused code

2015-08-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1022#issuecomment-132234428 That is fine, no worries! --- 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 ha

[GitHub] flink pull request: [FLINK-2529][runtime]remove some unused code

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1022 --- 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 enab

[jira] [Commented] (FLINK-2529) fix on some unused code for flink-runtime

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

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

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1004 --- 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 enab

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

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

[jira] [Commented] (FLINK-2477) Add test for SocketClientSink

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

[jira] [Updated] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

2015-08-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2544: - Description: I observed that some of the test cases using {{PowerMockRunner}} fail with Java 8u20

[jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701331#comment-14701331 ] Stephan Ewen commented on FLINK-2544: - +1 for documenting this > Some test cases usin

[jira] [Created] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

2015-08-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2544: Summary: Some test cases using PowerMock fail with Java 8u20 Key: FLINK-2544 URL: https://issues.apache.org/jira/browse/FLINK-2544 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

2015-08-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701270#comment-14701270 ] Aljoscha Krettek commented on FLINK-2508: - I think the batch API would have the sa

[jira] [Closed] (FLINK-2532) The function name and the variable name are same, it is confusing

2015-08-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2532. - Resolution: Fixed Fix Version/s: 0.10 Via a9d55d3 > The function name and the variable nam

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132209035 I have kept the documentation for statistics in this however. We can merge #1032 first and then this to maintain the illusion of cause-effect. :') --- If your pro

[GitHub] flink pull request: [FLINK-2286] [streaming] Wrapped ParallelMerge...

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/994 --- 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-2286] [0.9.1] ParallelMerge fix

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1014 --- 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 enab

[jira] [Commented] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window

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

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132208131 @thvasilo , @chiwanpark , I've split this into two parts. The statistics part is now in #1032 --- If your project is set up for it, you can reply to this email a

[GitHub] flink pull request: [flink-2532]fix the function name and the vari...

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1025 --- 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 enab

[GitHub] flink pull request: [FLINK-2379][ml]Add column wise statistics for...

2015-08-18 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1032 [FLINK-2379][ml]Add column wise statistics for vector Data Sets This is because of splitting the work in #861 in two parts. You can merge this pull request into a Git repository by running:

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

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701253#comment-14701253 ] ASF GitHub Bot commented on FLINK-2379: --- GitHub user sachingoel0101 opened a pull re

[jira] [Commented] (FLINK-2529) fix on some unused code for flink-runtime

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

[GitHub] flink pull request: [FLINK-2529][runtime]remove some unused code

2015-08-18 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1022#issuecomment-132205784 Ha... Sorry for my English, just misunderstood the "execution". I will learn more about the Thread class. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701227#comment-14701227 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

2015-08-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701225#comment-14701225 ] Till Rohrmann commented on FLINK-1994: -- Sounds great [~rawkintrevo]. When it's ready,

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-132199820 Fixed. --- 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-2488) Expose attemptNumber in RuntimeContext

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

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1026#discussion_r37294536 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskRuntimeInfo.java --- @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701217#comment-14701217 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-132198739 Rebased to the latest master. Can be merged now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

2015-08-18 Thread Trevor Grant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701200#comment-14701200 ] Trevor Grant commented on FLINK-1994: - I more or less have this working with a few new

[jira] [Commented] (FLINK-2529) fix on some unused code for flink-runtime

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

[GitHub] flink pull request: [FLINK-2529][runtime]remove some unused code

2015-08-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1022#issuecomment-132196596 I'll merge half of this 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 proje

[jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

2015-08-18 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701196#comment-14701196 ] Márton Balassi commented on FLINK-2508: --- Thanks for both resports, Aljoscha. I am lo

[jira] [Commented] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

2015-08-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701186#comment-14701186 ] Ufuk Celebi commented on FLINK-2540: Yes, sure. I will fix it asap. Thanks for reporti

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132193111 They're not coupled at all. But both are related to statistics over data sets. This is why I combined them both in one. If you're wondering, there is a JIRA for th

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

2015-08-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701183#comment-14701183 ] ASF GitHub Bot commented on FLINK-2379: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701179#comment-14701179 ] Stephan Ewen commented on FLINK-2540: - I put Ufuk as responsible for that (hop that's

[jira] [Updated] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2540: Assignee: Ufuk Celebi > LocalBufferPool.requestBuffer gets into infinite loop >

[jira] [Updated] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

2015-08-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2540: Priority: Blocker (was: Major) > LocalBufferPool.requestBuffer gets into infinite loop > --

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132192126 Hello, I was wondering when the column-wise statistics were added to this PR and whether it makes sense to add them here, or create a new issue and PR for them.

[jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

2015-08-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14701175#comment-14701175 ] Aljoscha Krettek commented on FLINK-2508: - Another problem I discovered is that Te

[jira] [Assigned] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader

2015-08-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2543: - Assignee: Robert Metzger > State handling does not support deserializing classes through

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132188989 @chiwanpark , modified the names. --- 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 d

[jira] [Created] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader

2015-08-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2543: - Summary: State handling does not support deserializing classes through the UserCodeClassloader Key: FLINK-2543 URL: https://issues.apache.org/jira/browse/FLINK-2543

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132187018 Olrite. I'll be back in a few. :) --- 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 d

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132186504 I'm also inclined to use Discrete. --- 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

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132186102 Ah yes. You're right. I will change the names. Which do you think is the better name? I'm in favor of Discrete. --- If your project is set up for it, you can repl

[GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog...

2015-08-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-132183402 Is there the valid reason to have multiple names ('discrete histogram', 'categorical histogram')? I think that to avoid confusion, we need to unify the names. --- If

[jira] [Closed] (FLINK-2521) Add automatic test name logging for tests

2015-08-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2521. Resolution: Fixed Added via 2f0412f163f4d37605188c8cc763111e0b51f0dc > Add automatic test name logg

[jira] [Commented] (FLINK-2521) Add automatic test name logging for tests

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

[GitHub] flink pull request: [FLINK-2521] [tests] Adds automatic test name ...

2015-08-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1015 --- 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 enab

  1   2   >