[jira] [Commented] (FLINK-1738) Add mean centering transformation to machine learning library

2015-05-22 Thread Ajay Bhat (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14557091#comment-14557091 ] Ajay Bhat commented on FLINK-1738: -- Hi, I'd like to work on this. In which package do you

[jira] [Closed] (FLINK-2086) how main difference betwwen Hadoop and Apache Flink

2015-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2086. - Resolution: Not A Problem > how main difference betwwen Hadoop and Apache Flink >

[jira] [Created] (FLINK-2086) how main difference betwwen Hadoop and Apache Flink

2015-05-22 Thread hagersaleh (JIRA)
hagersaleh created FLINK-2086: - Summary: how main difference betwwen Hadoop and Apache Flink Key: FLINK-2086 URL: https://issues.apache.org/jira/browse/FLINK-2086 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2084) Create a dedicated streaming mode

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

[GitHub] flink pull request: [FLINK-2084] [core] Add an option to start Fli...

2015-05-22 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/718 [FLINK-2084] [core] Add an option to start Flink in streaming mode The streaming mode subsumes the batch mode, as it allows to run both kinds of programs. Batch programs will most likely run slig

[GitHub] flink pull request: Change FlinkMiniCluster#HOSTNAME to FlinkMiniC...

2015-05-22 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/711#issuecomment-104712456 CC @StephanEwen I think that could be expressed via right name or additional comments rather than using all caps. --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

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

[GitHub] flink pull request: [FLINK-2074] Fix erroneous emission of Sliding...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/716#issuecomment-104708161 Thats actually a compelling case for adding a test. Also it seems that you are planning to rework a lot of the windowing stuff .. The more tests you have there, the

[GitHub] flink pull request: implement a simple session management

2015-05-22 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/681#issuecomment-104707707 I've updated the pull request. - The `JobID` is now propagated from the `ExecutionEnvironment` to the `JobGraph`. That's why a setter for setting the `JobID` at the `

[jira] [Updated] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

2015-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2085: Issue Type: Sub-task (was: New Feature) Parent: FLINK-2084 > Add an option to the MemoryMan

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

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

[GitHub] flink pull request: [FLINK-2074] Fix erroneous emission of Sliding...

2015-05-22 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/716#issuecomment-104706869 I don't know, all this time we had the wrong behaviour and no tests were catching it. --- If your project is set up for it, you can reply to this email and have your re

[jira] [Resolved] (FLINK-1476) Flink VS Spark on loop test

2015-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1476. - Resolution: Invalid This is a discussion that should happen on the mailing list > Flink VS Spark

[jira] [Closed] (FLINK-1323) Implement memory management profiles

2015-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1323. --- > Implement memory management profiles > > > Key: FLI

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

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-104705751 It looks like many unrelated commits are part of the pull request. I suspect something went wrong while merging/rebasing. Can you take a look? --- If your project i

[jira] [Resolved] (FLINK-1323) Implement memory management profiles

2015-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1323. - Resolution: Won't Fix Subsumed by FLINK-2085 > Implement memory management profiles > ---

[jira] [Created] (FLINK-2085) Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it

2015-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2085: --- Summary: Add an option to the MemoryManager to allocate memory as needed, rather than preallocating it Key: FLINK-2085 URL: https://issues.apache.org/jira/browse/FLINK-2085

[GitHub] flink pull request: [FLINK-1920] Properly pass command line argume...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/689#issuecomment-104705358 I'll merge this soon (next 24 hrs), if there are no objections. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-1920) Passing -D akka.ask.timeout=5 min to yarn client does not work

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

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

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

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

2015-05-22 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/697#discussion_r30910025 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java --- @@ -131,4 +14

[GitHub] flink pull request: From stream to Hbase

2015-05-22 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/706#discussion_r30909599 --- Diff: flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java --- @@ -0,0 +1,114 @@ +/* + * Li

[GitHub] flink pull request: From stream to Hbase

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/706#issuecomment-104704212 +1 to merge the change --- 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

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-104703807 Thank you for the contribution. I'm trying to test it over the weekend. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-05-22 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/707#discussion_r30909390 --- Diff: flink-clients/src/main/java/org/apache/flink/client/web/JobsServlet.java --- @@ -1,212 +1,226 @@ -/* - * Licensed to the Apache Software Fou

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[GitHub] flink pull request: Change FlinkMiniCluster#HOSTNAME to FlinkMiniC...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/711#issuecomment-104703453 Change looks good, I'm not sure if there was any deeper meaning in the all caps name. Would be good if the authors of the code could let us know. --- If your projec

[GitHub] flink pull request: [FLINK-1848] Fix for file paths with Windows d...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/712#issuecomment-104703293 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature en

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

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

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1957] [runtime] Improve er...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/713#issuecomment-104702861 I haven't looked at the code yet, but I've used the code from this branch for some cluster experiments I did today and everything seems to work. So at least for my te

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

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

[GitHub] flink pull request: [FLINK-2074] Fix erroneous emission of Sliding...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/716#issuecomment-104702211 Is there an easy way to add a test for this? --- 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 proj

[GitHub] flink pull request: Improve Flink on YARN stability

2015-05-22 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/717 Improve Flink on YARN stability This issue is addressing three issues: - NPE in the history view of the JobManager - Change the Akka configuration for YARN TaskManagers so that they kill the

[GitHub] flink pull request: Eager print

2015-05-22 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/699#issuecomment-104699134 +1! --- 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

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

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

[GitHub] flink pull request: [FLINK-2074] Fix erroneous emission of Sliding...

2015-05-22 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/716 [FLINK-2074] Fix erroneous emission of Sliding Time PreReducer Before this, a sliding time window would keep emitting the last result because the number of elements per pre-aggregation result was

[jira] [Created] (FLINK-2084) Create a dedicated streaming mode

2015-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2084: --- Summary: Create a dedicated streaming mode Key: FLINK-2084 URL: https://issues.apache.org/jira/browse/FLINK-2084 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556231#comment-14556231 ] Aljoscha Krettek commented on FLINK-2074: - I think I found the bug and fixed it. I

[jira] [Assigned] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2074: --- Assignee: Aljoscha Krettek > Sliding Window Keeps Emitting Elements After Source Stop

[GitHub] flink pull request: [FLINK-2083] [docs] [ml] Ensure high quality d...

2015-05-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/715#issuecomment-104669338 We could turn this into a WIP PR, and keep it open until 0.9 is released, in case we want to make more changes to the docs. --- If your project is set up for it, you ca

[jira] [Commented] (FLINK-2083) Ensure high quality docs for FlinkML in 0.9

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

[jira] [Assigned] (FLINK-1723) Add cross validation for parameter selection and validation

2015-05-22 Thread Mikio Braun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikio Braun reassigned FLINK-1723: -- Assignee: Mikio Braun > Add cross validation for parameter selection and validation > -

[jira] [Assigned] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2015-05-22 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis reassigned FLINK-1807: -- Assignee: Theodore Vasiloudis (was: Till Rohrmann) > Stochastic gradient desce

[GitHub] flink pull request: [FLINK-2083] [docs] [ml] Ensure high quality d...

2015-05-22 Thread thvasilo
GitHub user thvasilo opened a pull request: https://github.com/apache/flink/pull/715 [FLINK-2083] [docs] [ml] Ensure high quality docs for FlinkML in 0.9 Various fixes and additions to the docs for FlinkML You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (FLINK-2083) Ensure high quality docs for FlinkML in 0.9

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

[jira] [Created] (FLINK-2083) Ensure high quality docs for FlinkML in 0.9

2015-05-22 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2083: -- Summary: Ensure high quality docs for FlinkML in 0.9 Key: FLINK-2083 URL: https://issues.apache.org/jira/browse/FLINK-2083 Project: Flink Issue T

[jira] [Commented] (FLINK-2056) Add guide to create a chainable predictor in docs

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

[GitHub] flink pull request: [FLINK-2056] [ml] [docs] Add guide to create a...

2015-05-22 Thread thvasilo
GitHub user thvasilo opened a pull request: https://github.com/apache/flink/pull/714 [FLINK-2056] [ml] [docs] Add guide to create a chainable predictor in docs Adds documentation explaining chaining in FlinkML, mostly aimed at developers. You can merge this pull request into a Git

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556115#comment-14556115 ] Aljoscha Krettek commented on FLINK-2074: - Thanks for looking into this. Although

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556108#comment-14556108 ] Gyula Fora commented on FLINK-2081: --- So what if I am maintaining a connection with some

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-22 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556102#comment-14556102 ] Gabor Gevay commented on FLINK-2074: I did some debugging on this, and although I don'

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556099#comment-14556099 ] Aljoscha Krettek commented on FLINK-2081: - The way I see it is that open always in

[jira] [Created] (FLINK-2082) Chained stream tasks share the same RuntimeEnvironment

2015-05-22 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2082: - Summary: Chained stream tasks share the same RuntimeEnvironment Key: FLINK-2082 URL: https://issues.apache.org/jira/browse/FLINK-2082 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-2082) Chained stream tasks share the same RuntimeContext

2015-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-2082: -- Summary: Chained stream tasks share the same RuntimeContext (was: Chained stream tasks share the same R

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556040#comment-14556040 ] Gyula Fora commented on FLINK-2081: --- I think state restore should come before open and i

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556034#comment-14556034 ] Robert Metzger commented on FLINK-2081: --- You can always work around that by leaving

[jira] [Commented] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14556027#comment-14556027 ] Gyula Fora commented on FLINK-2081: --- On the other hand if the initialization logic depen

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/705 --- 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-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-22 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/705#issuecomment-104643115 I've removed the configuration constants and Travis passed after the rebase (modulo KafkaITCase). I'm merging this... --- If your project is set up for it, you can reply to

[jira] [Assigned] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2081: --- Assignee: Aljoscha Krettek > Change order of restore state and open for Streaming Ope

[jira] [Created] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2081: --- Summary: Change order of restore state and open for Streaming Operators Key: FLINK-2081 URL: https://issues.apache.org/jira/browse/FLINK-2081 Project: Flink

[jira] [Created] (FLINK-2080) Execute Flink with sbt

2015-05-22 Thread Christian Wuertz (JIRA)
Christian Wuertz created FLINK-2080: --- Summary: Execute Flink with sbt Key: FLINK-2080 URL: https://issues.apache.org/jira/browse/FLINK-2080 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2079) Add watcher to YARN TM containers to detect stopped actor system

2015-05-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2079: - Summary: Add watcher to YARN TM containers to detect stopped actor system Key: FLINK-2079 URL: https://issues.apache.org/jira/browse/FLINK-2079 Project: Flink

[GitHub] flink pull request: [YARN] Cut off 25% of the heap as a safety mar...

2015-05-22 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/709#issuecomment-104595183 I'm closing the PR again because I've found that there are more cases to consider ;) --- If your project is set up for it, you can reply to this email and have your rep

[GitHub] flink pull request: [YARN] Cut off 25% of the heap as a safety mar...

2015-05-22 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/709 --- 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

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1957] [runtime] Improve er...

2015-05-22 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/713 [FLINK-1954] [FLINK-1957] [runtime] Improve error handling of transport failures *Problem*: Failures in the network stack were not properly handled and correctly attributed. *Solution*: Failur

[jira] [Created] (FLINK-2078) Document type registration at the ExecutionEnvironment

2015-05-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2078: Summary: Document type registration at the ExecutionEnvironment Key: FLINK-2078 URL: https://issues.apache.org/jira/browse/FLINK-2078 Project: Flink Issue Ty

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

2015-05-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1992. Resolution: Fixed Added via b3b6a9da0532d884f7d633530c11cda15aa6bc1b > Add convergence criterion to

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

2015-05-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2034. -- Resolution: Fixed Added via b602b2ee1c9d130e97e844572f9827b29fbd9cf8 > Add vision and roadmap f

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

2015-05-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2050. Resolution: Fixed Added via fde0341fe16c7258e42f77e289a557157995830c > Add pipelining mechanism for

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

2015-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/692 --- 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-2050) Add pipelining mechanism for chainable transformers and estimators

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

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/704 --- 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-1992) Add convergence criterion to SGD optimizer

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

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

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

[GitHub] flink pull request: [FLINK-2034] [docs] Add vision and roadmap for...

2015-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/688 --- 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: Eager print

2015-05-22 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/699#issuecomment-104561157 Congratulations on your first contribution @nikste! --- 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 p

[jira] [Commented] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

2015-05-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14555816#comment-14555816 ] Maximilian Michels commented on FLINK-2070: --- +1 for {{printOnTaskManager()}} I

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

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

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-22 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/704#issuecomment-104552796 Oh that's true,yes. LGTM then! --- 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

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

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

[GitHub] flink pull request: [FLINK-2034] [docs] Add vision and roadmap for...

2015-05-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/688#issuecomment-104550265 LGTM. Will merge it. --- 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 th

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

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

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

2015-05-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/692#issuecomment-104548034 LGTM. Will merge it. --- 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 th

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

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

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

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

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/704#issuecomment-104546529 If there are no further objections, then I'll merge this PR today. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-22 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/704#issuecomment-104546413 That's happening because the `Estimator`, `Transformer` and `Predictor` have a default value for the ParameterMap parameter. --- If your project is set up for it, y