[jira] [Commented] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295164#comment-14295164 ] ASF GitHub Bot commented on FLINK-1344: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types

2015-01-28 Thread John Sandiford (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294920#comment-14294920 ] John Sandiford commented on FLINK-1458: --- Great thanks. Look forward to it. For my

[jira] [Commented] (FLINK-1459) Collect DataSet to client

2015-01-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294948#comment-14294948 ] Ufuk Celebi commented on FLINK-1459: Hey John, support for this kind of operations is

[jira] [Commented] (FLINK-1330) Restructure directory layout

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294900#comment-14294900 ] ASF GitHub Bot commented on FLINK-1330: --- Github user mxm commented on the pull

[jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

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

[GitHub] flink pull request: [FLINK-1419] [runtime] DC properly synchronize...

2015-01-28 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71825712 well you sure know how to keep me busy :) you are right about moving it back. Updated. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-1419] [runtime] DC properly synchronize...

2015-01-28 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71827151 Haste makes waste ;-) --- 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] [Comment Edited] (FLINK-1450) Add Fold operator to the Streaming api

2015-01-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294939#comment-14294939 ] Gyula Fora edited comment on FLINK-1450 at 1/28/15 9:47 AM:

[jira] [Commented] (FLINK-1459) Collect DataSet to client

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294945#comment-14294945 ] Chesnay Schepler commented on FLINK-1459: - there is currently a PR pending for

[jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

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

[GitHub] flink pull request: [FLINK-1419] [runtime] DC properly synchronize...

2015-01-28 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/339#discussion_r23680315 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -179,27 +179,40 @@ public Path call() {

[GitHub] flink pull request: [FLINK-1419] [runtime] DC properly synchronize...

2015-01-28 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71819301 With your latest changes Chesney, namely the incrementing/decrementing logic, I think that it now makes sense again to increase the counters in the createTmpFile

[jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294991#comment-14294991 ] ASF GitHub Bot commented on FLINK-1419: --- Github user zentol commented on the pull

[jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types

2015-01-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295010#comment-14295010 ] Aljoscha Krettek commented on FLINK-1458: - Yes, after the fix is merged it will

[jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295092#comment-14295092 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295481#comment-14295481 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull

[GitHub] flink pull request: fix typos

2015-01-28 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/346#issuecomment-71948299 +1 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 this

[jira] [Created] (FLINK-1460) Typo fixes

2015-01-28 Thread Shuo Xiang (JIRA)
Shuo Xiang created FLINK-1460: - Summary: Typo fixes Key: FLINK-1460 URL: https://issues.apache.org/jira/browse/FLINK-1460 Project: Flink Issue Type: Improvement Reporter: Shuo Xiang

[jira] [Commented] (FLINK-1460) Typo fixes

2015-01-28 Thread Shuo Xiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14296399#comment-14296399 ] Shuo Xiang commented on FLINK-1460: --- PR: https://github.com/apache/flink/pull/346 Typo

[jira] [Updated] (FLINK-1460) Typo fixes

2015-01-28 Thread Shuo Xiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Xiang updated FLINK-1460: -- Description: Fix some typos. Also fix some inconsistent uses of *partition operator* and *partitioning

[jira] [Closed] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

2015-01-28 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paris Carbone closed FLINK-1344. Add implicit conversion from scala streams to DataStreams

[jira] [Commented] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295335#comment-14295335 ] ASF GitHub Bot commented on FLINK-1344: --- Github user senorcarbone commented on the

[jira] [Assigned] (FLINK-1260) Add custom partitioning to documentation

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1260: --- Assignee: Chesnay Schepler Add custom partitioning to documentation

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14295625#comment-14295625 ] ASF GitHub Bot commented on FLINK-377: -- Github user StephanEwen commented on the pull