[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412920 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1655) Rename StreamInvokable to StreamOperator

2015-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496157#comment-14496157 ] ASF GitHub Bot commented on FLINK-1655: --- Github user akshaydixi closed the pull

[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412522 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-1655] Renamed StreamInvokable to Stream...

2015-04-15 Thread akshaydixi
Github user akshaydixi closed the pull request at: https://github.com/apache/flink/pull/508 --- 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: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412479 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412374 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412288 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412749 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to

[GitHub] flink pull request: fixed a few typos in internal_general_arch.md

2015-04-15 Thread akshaydixi
GitHub user akshaydixi opened a pull request: https://github.com/apache/flink/pull/602 fixed a few typos in internal_general_arch.md You can merge this pull request into a Git repository by running: $ git pull https://github.com/akshaydixi/flink typo Alternatively you can

[GitHub] flink pull request: fixed a few typos in internal_general_arch.md

2015-04-15 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/602#issuecomment-93406145 Looks good 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

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

2015-04-15 Thread niraj rai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496378#comment-14496378 ] niraj rai commented on FLINK-992: - Hi, if no one is working, I can work on this. Create

[jira] [Commented] (FLINK-1869) Make StreamDiscretizers chainable

2015-04-15 Thread Akshay Dixit (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496299#comment-14496299 ] Akshay Dixit commented on FLINK-1869: - Hi, I'd like to take a crack at this issue if

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

2015-04-15 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496492#comment-14496492 ] Henry Saputra commented on FLINK-992: - HI [~nrai], yes you could start working on this

[jira] [Assigned] (FLINK-1818) Provide API to cancel running job

2015-04-15 Thread niraj rai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] niraj rai reassigned FLINK-1818: Assignee: niraj rai Provide API to cancel running job -

[jira] [Assigned] (FLINK-992) Create CollectionDataSets by reading (client) local files.

2015-04-15 Thread niraj rai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] niraj rai reassigned FLINK-992: --- Assignee: niraj rai (was: Henry Saputra) Create CollectionDataSets by reading (client) local files.

[GitHub] flink pull request: [FLINK-1753] Extend KafkaITCase, reworked Pers...

2015-04-15 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/603 [FLINK-1753] Extend KafkaITCase, reworked PersistentKafkaSource (initially) Added large messages test and reworked PersistentKafkaSource. A Flink user I'm talking with offline is affected

[jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496862#comment-14496862 ] ASF GitHub Bot commented on FLINK-1753: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: Stream graph + internal refactor

2015-04-15 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/594#issuecomment-93635634 This is great patch, but as @mxm mentioned before, it almost impossible to review patches with this size. If the PR could not be chopped into separate PRs, lets

[GitHub] flink pull request: [FLINK-1753] Extend KafkaITCase, reworked Pers...

2015-04-15 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/603#issuecomment-93568853 The failed test has been resolved. --- 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

[jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496993#comment-14496993 ] ASF GitHub Bot commented on FLINK-1753: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: Stream graph + internal refactor

2015-04-15 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/594#issuecomment-93264219 I will merge this later today if no objections . --- 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

[GitHub] flink pull request: Stream graph + internal refactor

2015-04-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/594 --- 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] [Created] (FLINK-1891) Add isEmpty check when the input dir

2015-04-15 Thread Sibao Hong (JIRA)
Sibao Hong created FLINK-1891: - Summary: Add isEmpty check when the input dir Key: FLINK-1891 URL: https://issues.apache.org/jira/browse/FLINK-1891 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1876) Refactor StreamGraph to be node centric

2015-04-15 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1876. --- Resolution: Done Refactor StreamGraph to be node centric ---

[GitHub] flink pull request: [FLINK-1891]Add the input storageDirectory emp...

2015-04-15 Thread matadorhong
GitHub user matadorhong opened a pull request: https://github.com/apache/flink/pull/601 [FLINK-1891]Add the input storageDirectory empty check Add the input storageDirectory empty check, if input of storageDirectory is empty, we should use tmp as the base dir And also fix the

[jira] [Commented] (FLINK-1891) Add isEmpty check when the input dir

2015-04-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14495989#comment-14495989 ] ASF GitHub Bot commented on FLINK-1891: --- GitHub user matadorhong opened a pull

[GitHub] flink pull request: Ml branch

2015-04-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28412028 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,178 @@ +/* + * Licensed to