[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973639 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27973958 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27974019 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala --- @@ -0,0 +1,189 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r27975352 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala --- @@ -0,0 +1,101 @@ +/* + * Licensed to the

[jira] [Assigned] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1793: - Assignee: Márton Balassi Streaming File Source cannot be canceled

[GitHub] flink pull request: [FLINK-1823] Remove linq from Table API docume...

Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/580#issuecomment-90951956 SHIP IT :+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

[jira] [Commented] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue

[ https://issues.apache.org/jira/browse/FLINK-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485394#comment-14485394 ] ASF GitHub Bot commented on FLINK-1823: --- Github user hsaputra commented on the pull

[jira] [Commented] (FLINK-1670) Collect method for streaming

[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485531#comment-14485531 ] ASF GitHub Bot commented on FLINK-1670: --- GitHub user ggevay opened a pull request:

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/581 [FLINK-1670] Made DataStream iterable I created a DataStreamIterator class, and added an iterator() method to DataStream, which returns an instance of it. The iterator creates a TCP server on which

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-90987769 It is an interesting idea to collect back a data stream. This solution here has, however, quite a few limitations and implications (I assume it was only locally

[jira] [Commented] (FLINK-1670) Collect method for streaming

[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485648#comment-14485648 ] ASF GitHub Bot commented on FLINK-1670: --- Github user StephanEwen commented on the

<    1   2