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

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

[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-tabpanel&focusedCommentId=14293217#comment-14293217 ] 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-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: https://t

[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-tabpanel&focusedCommentId=14293219#comment-14293219 ] Fabian Hueske commented on FLINK-1452: -- I am +1 for a place to add contributions, but

[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-tabpanel&focusedCommentId=14293222#comment-14293222 ] Stephan Ewen commented on FLINK-1105: - I think it would actually be nice to expose exp

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

[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-tabpanel&focusedCommentId=14293225#comment-14293225 ] Stephan Ewen commented on FLINK-1105: - Adding to my comment above: That would mean tha

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

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

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

[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-tabpanel&focusedCommentId=14293240#comment-14293240 ] Robert Metzger commented on FLINK-1452: --- In my opinion: {{flink-addons}}: - are usua

[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. It

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

[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 elements.

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

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

[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-tabpanel&focusedCommentId=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 enabl

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

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

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

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

[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-tabpanel&focusedCommentId=14293390#comment-14293390 ] 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-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 email

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

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

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

[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-tabpanel&focusedCommentId=14293458#comment-14293458 ] Aljoscha Krettek commented on FLINK-1396: - For this to work I have to move the Had

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

[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-tabpanel&focusedCommentId=14293481#comment-14293481 ] ASF GitHub Bot commented on FLINK-938: -- Github user qmlmoon commented on the pull requ

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

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

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

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

[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-tabpanel&focusedCommentId=14293520#comment-14293520 ] ASF GitHub Bot commented on FLINK-938: -- Github user tillrohrmann commented on a diff i

[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 { c

[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-tabpanel&focusedCommentId=14293521#comment-14293521 ] ASF GitHub Bot commented on FLINK-377: -- Github user dan-blanchard commented on the pul

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

[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-tabpanel&focusedCommentId=14293523#comment-14293523 ] ASF GitHub Bot commented on FLINK-938: -- Github user tillrohrmann commented on a diff i

[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 { op

[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-tabpanel&focusedCommentId=14293525#comment-14293525 ] ASF GitHub Bot commented on FLINK-938: -- Github user tillrohrmann commented on a diff i

[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 { config

[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-tabpanel&focusedCommentId=14293527#comment-14293527 ] ASF GitHub Bot commented on FLINK-938: -- Github user qmlmoon commented on a diff in the

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

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

2015-01-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/328 --- 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-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-tabpanel&focusedCommentId=14293536#comment-14293536 ] ASF GitHub Bot commented on FLINK-1352: --- Github user asfgit closed the pull request

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

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

[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 { c

[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-tabpanel&focusedCommentId=14293561#comment-14293561 ] ASF GitHub Bot commented on FLINK-938: -- Github user tillrohrmann commented on a diff i

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

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

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

[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 { config

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=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 ca

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

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

[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 { c

[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-tabpanel&focusedCommentId=14293612#comment-14293612 ] ASF GitHub Bot commented on FLINK-938: -- Github user tillrohrmann commented on a diff i

[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-tabpanel&focusedCommentId=14293723#comment-14293723 ] 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-27 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/339#issuecomment-71672497 Whenever I look more closely at the DC I'm always left wondering how it can work at all. About your first point, i don't think thats enough. there is a more fundam

[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-71688094 @dan-blanchard generally, how easy it is will depend on what you're going for. you can implement the functionality to create a plan in the given language; or just

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

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

2015-01-27 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/210#issuecomment-71689597 Looks like this is now ready to merge. @zentol I understand your concern. However, I think that it is much easier to execute in this way. Most of the times, the user

[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-tabpanel&focusedCommentId=14293869#comment-14293869 ] John Sandiford commented on FLINK-1378: --- Yes, the fix works. Thank you. > could no

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

2015-01-27 Thread John Sandiford (JIRA)
John Sandiford created FLINK-1458: - Summary: Interfaces and abstract classes are not valid types Key: FLINK-1458 URL: https://issues.apache.org/jira/browse/FLINK-1458 Project: Flink Issue Typ

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

2015-01-27 Thread John Sandiford (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Sandiford updated FLINK-1458: -- Description: I don't know whether this is by design or is a bug, but I am having trouble workin

[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-tabpanel&focusedCommentId=14293973#comment-14293973 ] ASF GitHub Bot commented on FLINK-377: -- Github user dan-blanchard commented on the pul

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

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

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

[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

[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-tabpanel&focusedCommentId=14294182#comment-14294182 ] Fabian Hueske commented on FLINK-1458: -- Yes, this is a limitation at the moment but t

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

[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 935e316a38367cab513df

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

[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-tabpanel&focusedCommentId=14294191#comment-14294191 ] Stephan Ewen commented on FLINK-1458: - John, this is a limitation that has been fixed

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

[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-tabpanel&focusedCommentId=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 > -

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

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

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

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

[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-tabpanel&focusedCommentId=14294501#comment-14294501 ] ASF GitHub Bot commented on FLINK-1318: --- Github user fhueske commented on the pull r

[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-tabpanel&focusedCommentId=14294506#comment-14294506 ] Fabian Hueske commented on FLINK-1450: -- So Reduce is kind of a special case of Fold w

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

[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-tabpanel&focusedCommentId=14294517#comment-14294517 ] Fabian Hueske commented on FLINK-1396: -- +1 for having direct API methods for HadoopIn

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

[GitHub] flink pull request: integrated forwarded fields

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

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

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

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

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

  1   2   >