[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-01-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293458#comment-14293458 ] Aljoscha Krettek commented on FLINK-1396: - For this to work I have to move the

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread qmlmoon
Github user qmlmoon commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-71645508 ok. I rebased the PR and modified it with scala implementation. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-71647940 Great, thanks. --- 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

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

2015-01-27 Thread dan-blanchard
Github user dan-blanchard commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71648291 @rmetzger I'm really more curious than anything at this point. I recently worked on a fairly large Storm topology that has parts written Java, Python, and Perl. As

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23607471 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -519,6 +519,12 @@ object JobManager {

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

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

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23607635 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -611,6 +615,13 @@ object TaskManager {

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread qmlmoon
Github user qmlmoon commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23607815 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -519,6 +519,12 @@ object JobManager {

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

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71652771 I'm wondering whether the count hash map update should rather happen in the copy process. Because otherwise there could be the following interleaving: 1. You

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

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

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23607703 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -596,6 +596,10 @@ object TaskManager {

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

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

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

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/331#issuecomment-71649409 Thanks for your feedback, @rmetzger . The error message is at the bottom because that way it is most easily identifiable by the user (no scrolling necessary). Before, we

[jira] [Closed] (FLINK-1352) Buggy registration from TaskManager to JobManager

2015-01-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1352. Resolution: Fixed Fixed in 730e056a2a2ea028495637b633396392c31337e3 Buggy registration from

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

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

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23609808 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -519,6 +519,12 @@ object JobManager {

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

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

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

2015-01-27 Thread dan-blanchard
Github user dan-blanchard commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71705775 @zentol Thanks for the info. I'm sorry to derail the PR conversation here for a bit! --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/337#issuecomment-71618846 Looks good to merge. Like Robert said, the `HADOOP_CLASSPATH` is used to add third party libraries. From `hadoop-env.sh`: # Extra Java CLASSPATH

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

2015-01-27 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71611872 Tests run on travis (they don't right now because fabian merged something that changes the CSVInputFormat constructor, which breaks stuff on my end) but see:

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293219#comment-14293219 ] Fabian Hueske commented on FLINK-1452: -- I am +1 for a place to add contributions, but

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

2015-01-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293240#comment-14293240 ] Robert Metzger commented on FLINK-1452: --- In my opinion: {{flink-addons}}: - are

[jira] [Commented] (FLINK-1105) Add support for locally sorted output

2015-01-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293222#comment-14293222 ] Stephan Ewen commented on FLINK-1105: - I think it would actually be nice to expose

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

2015-01-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71612618 @dan-blanchard What non-JVM language are you looking for? Maybe we can do a little prototype with that language to see how well it works. Maybe you or somebody else

[GitHub] flink pull request: [FLINK-1328] Reworked semantic annotations

2015-01-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/311#issuecomment-71613018 +1 for merging it Whats the plan with the documentation? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

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

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

[jira] [Commented] (FLINK-1328) Rework Constant Field Annotations

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

[jira] [Commented] (FLINK-1442) Archived Execution Graph consumes too much memory

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

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

2015-01-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-71610034 In addition to that, we should probably investigate why the clean phase is not removing the directory. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-1442] Reduce memory consumption of arch...

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/344#issuecomment-71616952 @StephanEwen Yes, that was on purpose. The previous two data structures (`HashMap` and `Queue`) are now replaced by the `LinkedHashMap` which serves the same functionality.

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

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

[jira] [Commented] (FLINK-1105) Add support for locally sorted output

2015-01-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293225#comment-14293225 ] Stephan Ewen commented on FLINK-1105: - Adding to my comment above: That would mean

[GitHub] flink pull request: Implement the convenience methods count and co...

2015-01-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/210#issuecomment-71726730 @zentol You are right, for the time being, that this results in parts in repeated execution. While not totally unavoidable in all cases, the code going in soon about

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

2015-01-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-71727262 @dan-blanchard That is fine. Thank you for the pointer to Storm's multilang protocol. We'll have a look at it and see whether we can make something similar work with

[jira] [Resolved] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

2015-01-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1378. - Resolution: Fixed Fix Version/s: 0.8 0.9 Fixed via

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

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1458. -- Resolution: Duplicate Duplicate of FLINK-1369 Interfaces and abstract classes are not valid

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

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

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

2015-01-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-71722351 We can bind the `unlink`to the `pre-clean` phase, see if that helps. All in all, if it does not work, it does not work. This is a nice utility, by no way

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

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294182#comment-14294182 ] Fabian Hueske commented on FLINK-1458: -- Yes, this is a limitation at the moment but

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

2015-01-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294191#comment-14294191 ] Stephan Ewen commented on FLINK-1458: - John, this is a limitation that has been fixed

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

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

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294506#comment-14294506 ] Fabian Hueske commented on FLINK-1450: -- So Reduce is kind of a special case of Fold

[jira] [Commented] (FLINK-1328) Rework Constant Field Annotations

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

[jira] [Resolved] (FLINK-846) Semantic Annotations - Inconsistencies

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-846. - Resolution: Implemented Implemented in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Semantic

[jira] [Closed] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties)

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1156. Resolution: Fixed Fixed in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Bug in Constant Fields

[GitHub] flink pull request: [Typo] Delete DiscardingOuputFormat

2015-01-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/343 --- 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] [Resolved] (FLINK-1457) RAT check fails on Windows

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1457. -- Resolution: Fixed Fixed in 06c2c35a2c165b6a612b0be6d00d99f287330dc7 Thanks for the patch!

[GitHub] flink pull request: [FLINK-1318] CsvInputFormat: Made quoted strin...

2015-01-27 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/265#issuecomment-71760224 Yes, that's still left to do... ;-) --- 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-1318) Make quoted String parsing optional and configurable for CSVInputFormats

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

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294517#comment-14294517 ] Fabian Hueske commented on FLINK-1396: -- +1 for having direct API methods for

[GitHub] flink pull request: [FLINK-1328] Reworked semantic annotations

2015-01-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/311 --- 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: [Typo] Delete DiscardingOuputFormat

2015-01-27 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/343#issuecomment-71760881 +1 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] [Resolved] (FLINK-1329) Enable constant field definitions for Pojo DataTypes

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1329. -- Resolution: Implemented Implemented in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Enable

[GitHub] flink pull request: [Typo] Delete DiscardingOuputFormat

2015-01-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/343#issuecomment-71765382 +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 enabled

[jira] [Resolved] (FLINK-1328) Rework Constant Field Annotations

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1328. -- Resolution: Fixed Fixed in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Rework Constant Field

[jira] [Commented] (FLINK-1457) RAT check fails on Windows

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

[jira] [Created] (FLINK-1457) RAT check fails on Windows

2015-01-27 Thread Sebastian Kruse (JIRA)
Sebastian Kruse created FLINK-1457: -- Summary: RAT check fails on Windows Key: FLINK-1457 URL: https://issues.apache.org/jira/browse/FLINK-1457 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread qmlmoon
Github user qmlmoon commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23610509 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -519,6 +519,12 @@ object JobManager {

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

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

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

2015-01-27 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71654749 both good points. I'll address them after lunch! --- 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

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

2015-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293588#comment-14293588 ] ASF GitHub Bot commented on FLINK-938: -- Github user qmlmoon commented on a diff in the

[jira] [Commented] (FLINK-1457) RAT check fails on Windows

2015-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293590#comment-14293590 ] ASF GitHub Bot commented on FLINK-1457: --- GitHub user sekruse opened a pull request:

[GitHub] flink pull request: [FLINK-1457] exclude avro test file from RAT c...

2015-01-27 Thread sekruse
GitHub user sekruse opened a pull request: https://github.com/apache/flink/pull/345 [FLINK-1457] exclude avro test file from RAT check You can merge this pull request into a Git repository by running: $ git pull https://github.com/sekruse/flink FLINK-1475 Alternatively you

[GitHub] flink pull request: [FLINK-1457] exclude avro test file from RAT c...

2015-01-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/345#issuecomment-71656804 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 feature

[jira] [Commented] (FLINK-1457) RAT check fails on Windows

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

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/248#discussion_r23611202 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -519,6 +519,12 @@ object JobManager {

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

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

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

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71754470 You're right Chesney. I assume that the faulty DC wasn't noticed because it was probably never really used ;-) Your solution should make the DC to work

[GitHub] flink pull request: [FLINK-1434] [FLINK-1401] Streaming support ad...

2015-01-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/334 --- 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] [Resolved] (FLINK-1401) Add plan visualiser support for Streaming programs

2015-01-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1401. --- Resolution: Fixed Add plan visualiser support for Streaming programs

[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

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

[jira] [Resolved] (FLINK-1434) Web interface cannot be used to run streaming programs

2015-01-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1434. --- Resolution: Fixed Web interface cannot be used to run streaming programs

[GitHub] flink pull request: [FLINK-1318] CsvInputFormat: Made quoted strin...

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/265#issuecomment-71631281 Looks good to me. How about adding some documentation for this feature? Maybe under http://flink.apache.org/docs/0.8/programming_guide.html#data-sources --- If your project

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

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

[jira] [Resolved] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

2015-01-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1433. --- Resolution: Fixed Fix Version/s: 0.9 Assignee: Robert Metzger Fixed for 0.9

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

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/333#issuecomment-71633168 So either we can somehow change the execution order of the clean goal or we fix this in the junction plugin. --- If your project is set up for it, you can reply to this

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

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

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/337#issuecomment-71631049 Merging it. --- 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

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

2015-01-27 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71638812 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

[jira] [Commented] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

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

[GitHub] flink pull request: [FLINK-1433] Add HADOOP_CLASSPATH to start scr...

2015-01-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/337 --- 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] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

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

[jira] [Updated] (FLINK-1303) HadoopInputFormat does not work with Scala API

2015-01-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-1303: Issue Type: Sub-task (was: Bug) Parent: FLINK-1396 HadoopInputFormat does not

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/328#issuecomment-71647585 I'll merge it. --- 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-1352) Buggy registration from TaskManager to JobManager

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

[jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

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

[jira] [Commented] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

2015-01-27 Thread John Sandiford (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293869#comment-14293869 ] John Sandiford commented on FLINK-1378: --- Yes, the fix works. Thank you. could not