[GitHub] flink pull request: Wrap very long line in FlatMapOperator class

2015-05-17 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/683#issuecomment-102935021 If no comment, will merge this simple fix end of day tomorrow. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [streaming] Fast calculation of medians of win...

2015-05-17 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/684 [streaming] Fast calculation of medians of windows [WIP] I started working on my Google Summer of Code Project. I decided to start with the fast calculation of medians of windows. The MedianPreReducer

[jira] [Resolved] (FLINK-1942) Add configuration options to Gelly-GSA

2015-05-17 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-1942. -- Resolution: Fixed Fix Version/s: 0.9 > Add configuration options to Gelly-GSA > -

[jira] [Commented] (FLINK-1942) Add configuration options to Gelly-GSA

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

[GitHub] flink pull request: [FLINK-1942][gelly] GSA Iteration Configuratio...

2015-05-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/635 --- 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-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547175#comment-14547175 ] Aljoscha Krettek commented on FLINK-1985: - [~rmetzger] yes, I have a fix for this

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

2015-05-17 Thread Hae Joon Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547149#comment-14547149 ] Hae Joon Lee edited comment on FLINK-1731 at 5/17/15 12:10 PM: -

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

2015-05-17 Thread Hae Joon Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547149#comment-14547149 ] Hae Joon Lee commented on FLINK-1731: - Hi, I am testing K-mean right now. I faced an e

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-102780139 Changed LocalStreamEnvironment to TestStreamEnvironment. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/682#discussion_r30469207 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -543,6 +542,144 @@ public void disableAutoTypeRegistration() {

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-102779406 Ok, I am not pushing until we get some more feedback then. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547111#comment-14547111 ] Matthias J. Sax commented on FLINK-1985: Well, the default value of the variable i

[jira] [Updated] (FLINK-2031) Missing images in blog posts

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2031: -- Labels: starter (was: ) > Missing images in blog posts > > >

[jira] [Commented] (FLINK-2031) Missing images in blog posts

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547110#comment-14547110 ] Robert Metzger commented on FLINK-2031: --- A user also reported numerous broken links

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/682#discussion_r30469078 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -543,6 +542,144 @@ public void disableAutoTypeRegistration() {

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-102776567 Thank you for the contribution. I would like to wait for some more feedback from other committers before we merge this. --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547107#comment-14547107 ] Robert Metzger commented on FLINK-1985: --- [~mjsax]: The issue is assigned to [~aljosc

[jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

2015-05-17 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547105#comment-14547105 ] Alexander Alexandrov commented on FLINK-2023: - I suggest to have a thin layer

[jira] [Resolved] (FLINK-1260) Add custom partitioning to documentation

2015-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1260. --- Resolution: Fixed Fix Version/s: 0.9 Assignee: Robert Metzger Resolved as part

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-102773476 Thanks, nice fix. I added one little amend: used `TestStreamEnvironment` instead of local. The former lets you force a given parallelism regardless of the machine. It is

[jira] [Commented] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547103#comment-14547103 ] Márton Balassi commented on FLINK-1985: --- Thanks Matthias, I have tested it, looks go

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

2015-05-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/676#issuecomment-102767943 As far as I see the problem is that the `AbstractProcessFailureRecoveryTest` that you use as a base class only makes sure that the anything that is in the `programTrigge