[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 o

[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-tabpanel&focusedCommentId=14296399#comment-14296399 ] Shuo Xiang commented on FLINK-1460: --- PR: https://github.com/apache/flink/pull/346 > Typ

[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

[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 featu

[GitHub] flink pull request: fix typos

2015-01-28 Thread coderxiang
GitHub user coderxiang opened a pull request: https://github.com/apache/flink/pull/346 fix typos Fix some typos. Notice that there are still inconsistent uses of **partition operator** and **partitioning operator** in the codebase. You can merge this pull request into a Git reposit

[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-tabpanel&focusedCommentId=14295625#comment-14295625 ] ASF GitHub Bot commented on FLINK-377: -- Github user StephanEwen commented on the pull

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71893972 We definitely have to double check the Licenses issues when merging this. I can do that next week. --- If your project is set up for it, you can reply to this email a

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

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-377: -- Assignee: Chesnay Schepler > Create a general purpose framework for language bindings >

[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] [Assigned] (FLINK-1422) Missing usage example for "withParameters"

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1422: --- Assignee: Chesnay Schepler > Missing usage example for "withParameters" > ---

[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-tabpanel&focusedCommentId=14295481#comment-14295481 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-01-28 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71880245 i don't have a clue about all this licensing stuff. what i have seen though is that spark uses a file that has a similar license as the dill library. (https://github.com/ap

[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-tabpanel&focusedCommentId=14295375#comment-14295375 ] ASF GitHub Bot commented on FLINK-377: -- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-01-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71869014 Nice to see the progress here :+1: I would like to take a closer look at your work in the next days. There is an issue with the `dill` library which is included in the

[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] [Resolved] (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 resolved FLINK-1344. -- Resolution: Fixed > 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-tabpanel&focusedCommentId=14295335#comment-14295335 ] ASF GitHub Bot commented on FLINK-1344: --- Github user senorcarbone commented on the p

[GitHub] flink pull request: [FLINK-1344] [streaming] Added implicits for s...

2015-01-28 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/341#issuecomment-71862752 Thanks for merging @gyfora ! @StephanEwen I agree, I don't like that either. We'll engineer that properly soon along with other environment configuration changes

[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-tabpanel&focusedCommentId=14295164#comment-14295164 ] ASF GitHub Bot commented on FLINK-1344: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1344] [streaming] Added implicits for s...

2015-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/341 --- 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 enabl

[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-tabpanel&focusedCommentId=14295098#comment-14295098 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on the p

[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-71828186 Looks good to me now. Thanks Chesney. --- 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

[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-tabpanel&focusedCommentId=14295092#comment-14295092 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on the p

[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 th

[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-tabpanel&focusedCommentId=14295087#comment-14295087 ] ASF GitHub Bot commented on FLINK-1419: --- Github user zentol commented on the pull re

[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-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 meth

[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-tabpanel&focusedCommentId=14295031#comment-14295031 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on the p

[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-tabpanel&focusedCommentId=14295026#comment-14295026 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on a dif

[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_r23680555 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -179,27 +179,40 @@ public Path call() {

[jira] [Commented] (FLINK-1436) Command-line interface verbose option & error reporting

2015-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14295023#comment-14295023 ] ASF GitHub Bot commented on FLINK-1436: --- Github user rmetzger 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-tabpanel&focusedCommentId=14295019#comment-14295019 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-1436] refactor CLiFrontend to provide m...

2015-01-28 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/331#issuecomment-71818646 Cool, thank you. I'll try it out as soon as I find time. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[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_r23680449 --- 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 a diff in the pull request: https://github.com/apache/flink/pull/339#discussion_r23680424 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -179,27 +179,40 @@ public Path call() {

[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-tabpanel&focusedCommentId=14295017#comment-14295017 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on a dif

[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-tabpanel&focusedCommentId=14295015#comment-14295015 ] ASF GitHub Bot commented on FLINK-1419: --- Github user tillrohrmann commented on a dif

[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() {

[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-tabpanel&focusedCommentId=14295010#comment-14295010 ] Aljoscha Krettek commented on FLINK-1458: - Yes, after the fix is merged it will in

[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-tabpanel&focusedCommentId=14294991#comment-14294991 ] ASF GitHub Bot commented on FLINK-1419: --- Github user zentol commented on the pull re

[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-71815201 updated to include discussed changes --- 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 no

[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-tabpanel&focusedCommentId=14294948#comment-14294948 ] Ufuk Celebi commented on FLINK-1459: Hey John, support for this kind of operations is

[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-tabpanel&focusedCommentId=14294945#comment-14294945 ] Chesnay Schepler commented on FLINK-1459: - there is currently a PR pending for thi

[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-tabpanel&focusedCommentId=14294939#comment-14294939 ] Gyula Fora edited comment on FLINK-1450 at 1/28/15 9:47 AM: Ye

[jira] [Commented] (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-tabpanel&focusedCommentId=14294939#comment-14294939 ] Gyula Fora commented on FLINK-1450: --- Yes, more specifically, the first element is the fi

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

2015-01-28 Thread John Sandiford (JIRA)
John Sandiford created FLINK-1459: - Summary: Collect DataSet to client Key: FLINK-1459 URL: https://issues.apache.org/jira/browse/FLINK-1459 Project: Flink Issue Type: Improvement

[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-tabpanel&focusedCommentId=14294920#comment-14294920 ] John Sandiford commented on FLINK-1458: --- Great thanks. Look forward to it. For my

[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-tabpanel&focusedCommentId=14294900#comment-14294900 ] ASF GitHub Bot commented on FLINK-1330: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t...

2015-01-28 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-71801652 I can confirm that the symlink gets deleted when `unlink` goal is executed in the `pre-clean` phase. --- If your project is set up for it, you can reply to this email and hav