[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/729#discussion_r31531758 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/UdfOperatorUtils.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569232#comment-14569232 ] ASF GitHub Bot commented on FLINK-1319: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [streaming] Consolidate streaming API method n...

GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/761 [streaming] Consolidate streaming API method names * This PR build on #743 and adds partitionBy for connected streams, scala and docs * Does the renames discussed on the mailing list in

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-107996871 Hey Timo, I've tested this locally so far and it's working smoothly! Let's write a blog post about this very soon. :-) As soon as I have access to more machines, I

[GitHub] flink pull request: [FLINK-2069] Fix Scala CSV Output Format

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/759#issuecomment-108002285 Thanks for the fix, LGTM. --- 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

[jira] [Created] (FLINK-2135) Java plan translation fails with ClassCastException (probably in first())

Robert Metzger created FLINK-2135: - Summary: Java plan translation fails with ClassCastException (probably in first()) Key: FLINK-2135 URL: https://issues.apache.org/jira/browse/FLINK-2135 Project:

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

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

[jira] [Commented] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569338#comment-14569338 ] Aljoscha Krettek commented on FLINK-2069: - thanks for testing :) writeAsCSV

[jira] [Commented] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569339#comment-14569339 ] Aljoscha Krettek commented on FLINK-2069: - thanks for testing :) writeAsCSV

[jira] [Commented] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

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

[jira] [Issue Comment Deleted] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Faye Beligianni updated FLINK-2069: --- Comment: was deleted (was: I just tested it and it creates the csv file :) ) writeAsCSV

[jira] [Commented] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569325#comment-14569325 ] Faye Beligianni commented on FLINK-2069: I just tested it and it creates the csv

[jira] [Issue Comment Deleted] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2069: Comment: was deleted (was: thanks for testing :)) writeAsCSV function in DataStream Scala

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

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

[GitHub] flink pull request: [FLINK-1981] add support for GZIP files

GitHub user sekruse opened a pull request: https://github.com/apache/flink/pull/762 [FLINK-1981] add support for GZIP files * register decompression algorithms with file extensions for extensibility * fit deflate decompression into this scheme * add support for GZIP files

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

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

[jira] [Issue Comment Deleted] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Goel updated FLINK-2131: --- Comment: was deleted (was: The first two initialization methods have been added:

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568654#comment-14568654 ] Sachin Goel commented on FLINK-2131: The first two initialization methods have been

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

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

[GitHub] flink pull request: [FLINK-2131]: Initialization schemes for k-mea...

Github user sachingoel0101 closed the pull request at: https://github.com/apache/flink/pull/756 --- 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

[GitHub] flink pull request: [FLINK-2131]: Initialization schemes for k-mea...

GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/757 [FLINK-2131]: Initialization schemes for k-means clustering This adds two most common initialization strategies for the k-means clustering algorithm, namely, Random initialization and

[GitHub] flink pull request: [FLINK-2131]: Initialization schemes for k-mea...

GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/756 [FLINK-2131]: Initialization schemes for k-means clustering This adds two most common initialization strategies for the k-means clustering algorithm, namely, Random initialization and

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

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

<    1   2