[jira] [Created] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1978: - Summary: POJO serialization NPE Key: FLINK-1978 URL: https://issues.apache.org/jira/browse/FLINK-1978 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530226#comment-14530226 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a

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

2015-05-06 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530225#comment-14530225 ] PJ Van Aeken commented on FLINK-1962: - I did a new commit to my personal Github,

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

2015-05-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29744552 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,49 @@ object TaskManager {

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530250#comment-14530250 ] ASF GitHub Bot commented on FLINK-1792: --- Github user tillrohrmann commented on a

[jira] [Updated] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-1978: -- Description: NullPointer on serialization of a Date field: Caused by:

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

2015-05-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29745454 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager {

[jira] [Comment Edited] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530197#comment-14530197 ] Flavio Pompermaier edited comment on FLINK-1978 at 5/6/15 9:10 AM:

[jira] [Commented] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530197#comment-14530197 ] Flavio Pompermaier commented on FLINK-1978: --- The error can be reproduced with

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

2015-05-06 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530317#comment-14530317 ] PJ Van Aeken commented on FLINK-1962: - Update : Using implicit conversions, I managed

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

2015-05-06 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530353#comment-14530353 ] PJ Van Aeken commented on FLINK-1962: - [~StephanEwen] I think that removing the

[GitHub] flink pull request: [streaming] Added naming for streaming operato...

2015-05-06 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/654#issuecomment-99427464 I would change the setName() method to name() to match the batch api, but other than this it looks good to merge --- If your project is set up for it, you can reply to

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

2015-05-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530425#comment-14530425 ] Johannes Günther commented on FLINK-1979: - We are two Students part of the DIMA

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

2015-05-06 Thread Peter Schrott (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530424#comment-14530424 ] Peter Schrott edited comment on FLINK-1731 at 5/6/15 12:10 PM:

[GitHub] flink pull request: [streaming] Added naming for streaming operato...

2015-05-06 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/654#issuecomment-99427925 Ok, will rename while merging - let us wait for travis. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request: [streaming] Added naming for streaming operato...

2015-05-06 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/654 [streaming] Added naming for streaming operators This improves tracking of jobs. Added for standard and windowing operators, both Java and Scala APIs. You can merge this pull request into

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

2015-05-06 Thread Peter Schrott (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530424#comment-14530424 ] Peter Schrott commented on FLINK-1731: -- FGoessler, philjjoon, peedeeX21 voelkj are

[jira] [Comment Edited] (FLINK-1979) Implement Loss Functions

2015-05-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530471#comment-14530471 ] Till Rohrmann edited comment on FLINK-1979 at 5/6/15 12:52 PM:

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

2015-05-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530471#comment-14530471 ] Till Rohrmann commented on FLINK-1979: -- Hi [~jguenther], great to hear that you wanna

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

2015-05-06 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530484#comment-14530484 ] Johannes Günther commented on FLINK-1979: - Yes that would be great ! Implement

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

2015-05-06 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/625#issuecomment-99499311 @vasia Don't forget to also have a look at this PR. It's rebased :) --- If your project is set up for it, you can reply to this email and have your reply appear

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

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530642#comment-14530642 ] ASF GitHub Bot commented on FLINK-1942: --- Github user andralungu commented on the

[GitHub] flink pull request: [streaming] Added naming for streaming operato...

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

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

2015-05-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1979: - Assignee: Johannes Günther Implement Loss Functions

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

2015-05-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530313#comment-14530313 ] Stephan Ewen commented on FLINK-1962: - How about remove the generic type constraints

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

2015-05-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531586#comment-14531586 ] Vasia Kalavri commented on FLINK-1962: -- Hey, we actually added the type constraints

[jira] [Commented] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531287#comment-14531287 ] ASF GitHub Bot commented on FLINK-1974: --- Github user jkirsch commented on a diff in

[GitHub] flink pull request: [FLINK-1974] JobExecutionResult NetRuntime - d...

2015-05-06 Thread jkirsch
Github user jkirsch commented on a diff in the pull request: https://github.com/apache/flink/pull/652#discussion_r29795245 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java --- @@ -47,12 +48,23 @@ public JobExecutionResult(JobID jobID, long

[GitHub] flink pull request: [FLINK-1974] JobExecutionResult NetRuntime - d...

2015-05-06 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/652#discussion_r29796343 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java --- @@ -47,12 +48,23 @@ public JobExecutionResult(JobID jobID, long

[jira] [Commented] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531277#comment-14531277 ] ASF GitHub Bot commented on FLINK-1974: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1974] JobExecutionResult NetRuntime - d...

2015-05-06 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/652#discussion_r29794147 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java --- @@ -47,12 +48,23 @@ public JobExecutionResult(JobID jobID, long

[jira] [Commented] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531269#comment-14531269 ] ASF GitHub Bot commented on FLINK-1974: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1974] JobExecutionResult NetRuntime - d...

2015-05-06 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/652#issuecomment-99585022 Looks good. What do you think about changing the name of the new method to `getNetRuntime`? --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531304#comment-14531304 ] ASF GitHub Bot commented on FLINK-1974: --- Github user fhueske commented on a diff in

[jira] [Updated] (FLINK-1732) Add Gaussian mixture model to machine learning library

2015-05-06 Thread Felix Neutatz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix Neutatz updated FLINK-1732: - Assignee: Alexander Alexandrov Add Gaussian mixture model to machine learning library

[jira] [Commented] (FLINK-1978) POJO serialization NPE

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530832#comment-14530832 ] ASF GitHub Bot commented on FLINK-1978: --- GitHub user fhueske opened a pull request:

[jira] [Commented] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530840#comment-14530840 ] ASF GitHub Bot commented on FLINK-1933: --- Github user chiwanpark commented on the

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

2015-05-06 Thread bhatsachin
Github user bhatsachin commented on a diff in the pull request: https://github.com/apache/flink/pull/553#discussion_r29786547 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1894,6 +1895,52 @@ object TaskManager {

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

2015-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14531107#comment-14531107 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on a diff

[jira] [Updated] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

2015-05-06 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-1982: - Summary: Remove dependencies on Record for Flink runtime and core (was: Remove dependencies of

[jira] [Created] (FLINK-1983) Remove dependencies on Record APIs for Spargel

2015-05-06 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-1983: Summary: Remove dependencies on Record APIs for Spargel Key: FLINK-1983 URL: https://issues.apache.org/jira/browse/FLINK-1983 Project: Flink Issue Type:

[jira] [Created] (FLINK-1982) Remove dependencies of Record for Flink runtime and core

2015-05-06 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-1982: Summary: Remove dependencies of Record for Flink runtime and core Key: FLINK-1982 URL: https://issues.apache.org/jira/browse/FLINK-1982 Project: Flink Issue

[GitHub] flink pull request: [FLINK-1933] Add distance measure interface an...

2015-05-06 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/629#issuecomment-99531887 I added a overview documentation. Please review and comment if there are some errors. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-1978] Fix POJO deserialization copy f...

2015-05-06 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/655 [FLINK-1978] Fix POJO deserialization copy for reuse objects with NULL fields Pojo `deserialize()` and `copy()` fails if a field of the reuse object is `null`. This PR fixes the bug and

[jira] [Commented] (FLINK-964) Integrate profiling code with web interface

2015-05-06 Thread Sebastian Kruse (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530735#comment-14530735 ] Sebastian Kruse commented on FLINK-964: --- Is this issue still relevant? With the new

[jira] [Created] (FLINK-1980) Allowing users to decorate input streams

2015-05-06 Thread Sebastian Kruse (JIRA)
Sebastian Kruse created FLINK-1980: -- Summary: Allowing users to decorate input streams Key: FLINK-1980 URL: https://issues.apache.org/jira/browse/FLINK-1980 Project: Flink Issue Type: New

[jira] [Created] (FLINK-1981) Add GZip support

2015-05-06 Thread Sebastian Kruse (JIRA)
Sebastian Kruse created FLINK-1981: -- Summary: Add GZip support Key: FLINK-1981 URL: https://issues.apache.org/jira/browse/FLINK-1981 Project: Flink Issue Type: New Feature