[jira] [Commented] (FLINK-2123) Fix CLI client logging

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573941#comment-14573941 ] ASF GitHub Bot commented on FLINK-2123: --- Github user flinkqa commented on the pull

[GitHub] flink pull request: [FLINK-2123] Fix log4j warnings on CliFrontend...

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/783#issuecomment-109125004 Tested pull request.Result: fatal: No such remote 'totest' fatal: 'totest' does not appear to be a git repository fatal: The remote end hung up unexpectedly

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

2015-06-04 Thread lokeshrajaram
GitHub user lokeshrajaram opened a pull request: https://github.com/apache/flink/pull/790 [FLINK-2155] Enforce import restriction on usage of Flink shaded package and Commons Validate [FLINK-2155] Enforce import restriction on usage of Flink shaded package and Commons Validate

[GitHub] flink pull request: [FLINK-2000] [table] Add sql style aggregation...

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/782#issuecomment-109156576 Tested pull request.Result: fatal: No such remote 'totest' fatal: 'totest' does not appear to be a git repository fatal: The remote end hung up unexpectedly

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

2015-06-04 Thread lokeshrajaram
Github user lokeshrajaram closed the pull request at: https://github.com/apache/flink/pull/776 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

2015-06-04 Thread lokeshrajaram
Github user lokeshrajaram commented on the pull request: https://github.com/apache/flink/pull/776#issuecomment-109155561 @uce Thanks a lot for the for your help. Followed your instructions and got it right but worked on a new branch. created a new pull request and hence closing this.

[GitHub] flink pull request: Add CONTRIBUTING.md file with pointers to our ...

2015-06-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/778#issuecomment-109169311 +1 great find --- 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-2160] Change Streaming Source Interface...

2015-06-04 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/785#issuecomment-109042503 I would prefer if the `emit` in the `SourceContext` was called `collect`. I gt that this way we distinguish it from the `Collector`, but I would personally not embrace

[jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573530#comment-14573530 ] ASF GitHub Bot commented on FLINK-2160: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1061] Document how to run an example

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/784#issuecomment-109099384 Tested pull request.Result: fatal: No such remote 'totest' fatal: 'totest' does not appear to be a git repository fatal: The remote end hung up unexpectedly

[jira] [Commented] (FLINK-1061) Describe how to run the examples from the command line

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573850#comment-14573850 ] ASF GitHub Bot commented on FLINK-1061: --- Github user flinkqa commented on the pull

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

2015-06-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/754#discussion_r31743017 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/BatchSchedulingTest.java --- @@ -0,0 +1,521 @@ +/* + *

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108983331 The reason for the limited number of jobs is that they can consume a lot of memory on the JM. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1061) Describe how to run the examples from the command line

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573218#comment-14573218 ] ASF GitHub Bot commented on FLINK-1061: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1061] Document how to run an example

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/784#discussion_r31744536 --- Diff: docs/apis/examples.md --- @@ -25,11 +25,34 @@ from simple word counting to graph algorithms. The code samples illustrate the use of

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573222#comment-14573222 ] ASF GitHub Bot commented on FLINK-2068: --- Github user mjsax commented on the pull

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108990592 Done. I added it to this PR (corrected an error in docs/README.md, too). --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573266#comment-14573266 ] ASF GitHub Bot commented on FLINK-2160: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108982112 Done. Sorry for the huge diff in JobSubmissionServlet: the line endings have not been correct (in UNIX now). The actual changes are in lines 74(+), 120(+), 126(+), 132(-)

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[GitHub] flink pull request: [FLINK-1565][FLINK-2078] Document ExecutionCon...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/781#issuecomment-108985254 Very nice. +1 for the docs structure and examples. (Disclaimer: I did not check thoroughly for typos) --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108985448 One more issue: the documentation you pointed to says, that if no entry class is provided in Manifest file, it can be specified via assembler assemblerClass

[jira] [Resolved] (FLINK-1422) Missing usage example for withParameters

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1422. --- Resolution: Fixed Assignee: Chesnay Schepler Resolved in

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573216#comment-14573216 ] ASF GitHub Bot commented on FLINK-2068: --- Github user mjsax commented on the pull

[jira] [Commented] (FLINK-1565) Document object reuse behavior

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

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-06-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573153#comment-14573153 ] Till Rohrmann commented on FLINK-2156: -- This should only occur on Travis. Locally,

[jira] [Commented] (FLINK-1126) Add suggestion for using large TupleX types

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

[jira] [Commented] (FLINK-2123) Fix CLI client logging

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

[jira] [Assigned] (FLINK-1565) Document object reuse behavior

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1565: - Assignee: Robert Metzger Document object reuse behavior --

[GitHub] flink pull request: [FLINK-1126][docs] Best practice: named TupleX...

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/786 [FLINK-1126][docs] Best practice: named TupleX types You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink1126 Alternatively

[GitHub] flink pull request: [FLINK-2123] Fix log4j warnings on CliFrontend...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/783#issuecomment-108984346 Looks good. +1 to merge this --- 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

[GitHub] flink pull request: [FLINK-1126][docs] Best practice: named TupleX...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/786#issuecomment-108984468 +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

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108986558 Damn. Would you like to open a PR for fixing it or should I do it? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573188#comment-14573188 ] ASF GitHub Bot commented on FLINK-2068: --- Github user mjsax commented on the pull

[jira] [Commented] (FLINK-1126) Add suggestion for using large TupleX types

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573203#comment-14573203 ] ASF GitHub Bot commented on FLINK-1126: --- GitHub user rmetzger opened a pull request:

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573245#comment-14573245 ] ASF GitHub Bot commented on FLINK-2068: --- Github user mjsax commented on the pull

[GitHub] flink pull request: [FLINK-2160] Change Streaming Source Interface...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/785#discussion_r31746941 --- Diff:

[jira] [Commented] (FLINK-2080) Execute Flink with sbt

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573275#comment-14573275 ] Robert Metzger commented on FLINK-2080: --- Thank you. Can you give me your email

[jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

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

[GitHub] flink pull request: [FLINK-2160] Change Streaming Source Interface...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/785#issuecomment-108993818 Good, mod some very minor comments. +1 from my side. I like it. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-2080] Document how to use Flink with sb...

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/787 [FLINK-2080] Document how to use Flink with sbt I've turned the patch from FLINK-2080 into a pull request ;) You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-2080) Execute Flink with sbt

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573280#comment-14573280 ] ASF GitHub Bot commented on FLINK-2080: --- GitHub user rmetzger opened a pull request:

[jira] [Updated] (FLINK-2080) Execute Flink with sbt

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2080: -- Assignee: Christian Wuertz Execute Flink with sbt --

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573297#comment-14573297 ] Robert Metzger commented on FLINK-1229: --- Updated documentation for this in

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108996266 Perfect, thank you. I've already commited the second commit of this pull request in http://git-wip-us.apache.org/repos/asf/flink/commit/da8aa108 --- If your project is

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108987569 Yes, you have. It is in the `docs/` directory of the Flink source. If you have jekyll installed, you can also run the ./build_docs.sh -p script in that directory for

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108987358 Do I have access to the documentation? If yes, where can I find it? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-1126) Add suggestion for using large TupleX types

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573472#comment-14573472 ] ASF GitHub Bot commented on FLINK-1126: --- Github user flinkqa commented on the pull

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[GitHub] flink pull request: [FLINK-2080] Document how to use Flink with sb...

2015-06-04 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/787#issuecomment-109040646 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 feature enabled

[jira] [Commented] (FLINK-2080) Execute Flink with sbt

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573521#comment-14573521 ] ASF GitHub Bot commented on FLINK-2080: --- Github user mbalassi commented on the pull

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-06-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573057#comment-14573057 ] Stephan Ewen commented on FLINK-2156: - I have elevated this to critical, because these

[jira] [Resolved] (FLINK-864) Add description of mutable object iterators (GroupReduce, CoGroup) to documentation

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-864. -- Resolution: Invalid The mutable object mode is going to be documented in FLINK-1565 Add

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

2015-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/742 --- 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-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

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

[jira] [Commented] (FLINK-1061) Describe how to run the examples from the command line

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573115#comment-14573115 ] ASF GitHub Bot commented on FLINK-1061: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1061] Document how to run an example

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/784 [FLINK-1061] Document how to run an example You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink1061 Alternatively you can

[jira] [Assigned] (FLINK-1061) Describe how to run the examples from the command line

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1061: - Assignee: Robert Metzger Describe how to run the examples from the command line

[jira] [Closed] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

2015-06-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2098. --- Resolution: Fixed Fixed in:

[jira] [Assigned] (FLINK-1126) Add suggestion for using large TupleX types

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1126: - Assignee: Robert Metzger Add suggestion for using large TupleX types

[GitHub] flink pull request: [FLINK-2160] Change Streaming Source Interface...

2015-06-04 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/785 [FLINK-2160] Change Streaming Source Interface to run(Context)/cancel() The context can be used to emit elemens and retrieve the checkpointing lock object. In the future, the context

[jira] [Commented] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573128#comment-14573128 ] ASF GitHub Bot commented on FLINK-2160: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-2000] [table] Add sql style aggregation...

2015-06-04 Thread chhao01
GitHub user chhao01 opened a pull request: https://github.com/apache/flink/pull/782 [FLINK-2000] [table] Add sql style aggregation support https://issues.apache.org/jira/browse/FLINK-2000 You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-2116) Make pipeline extension require less coding

2015-06-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572977#comment-14572977 ] Till Rohrmann commented on FLINK-2116: -- We could still offer a way to create matrices

[GitHub] flink pull request: [FLINK-2123] Fix log4j warnings on CliFrontend...

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/783 [FLINK-2123] Fix log4j warnings on CliFrontend startup * The hadoop1 build still contained a log4j.properties file from hadoop (I guess hadoop is shipping a jar file that contains a

[jira] [Commented] (FLINK-2123) Fix CLI client logging

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14573076#comment-14573076 ] ASF GitHub Bot commented on FLINK-2123: --- GitHub user rmetzger opened a pull request:

[jira] [Commented] (FLINK-2123) Fix CLI client logging

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

[GitHub] flink pull request: [FLINK-2123] Fix log4j warnings on CliFrontend...

2015-06-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/783#issuecomment-108963562 I've successfully tested the change on Windows/cygwin with flink installed in a path containing spaces. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis

2015-06-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572903#comment-14572903 ] Ufuk Celebi commented on FLINK-2163: I think I/O on Travis is unreliable. We could fix

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[GitHub] flink pull request: [FLINK-2136] Adding DataStream tests for Scala...

2015-06-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/771#issuecomment-108927352 General questions: Are type hints implemented already in the streaming API? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[GitHub] flink pull request: [streaming] ITCases for streaming scala exampl...

2015-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/777 --- 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-2123) Fix CLI client logging

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572833#comment-14572833 ] Robert Metzger commented on FLINK-2123: --- How can I reproduce the too much

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

2015-06-04 Thread lokeshrajaram
Github user lokeshrajaram commented on the pull request: https://github.com/apache/flink/pull/776#issuecomment-108929985 @uce Thanks for the instructions. will follow this and create a new pull request. sorry for the trouble. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2000) Add SQL-style aggregations for Table API

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572971#comment-14572971 ] ASF GitHub Bot commented on FLINK-2000: --- GitHub user chhao01 opened a pull request:

[jira] [Commented] (FLINK-2158) NullPointerException in DateSerializer.

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572783#comment-14572783 ] ASF GitHub Bot commented on FLINK-2158: --- GitHub user rmetzger opened a pull request:

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572798#comment-14572798 ] ASF GitHub Bot commented on FLINK-2068: --- Github user mjsax commented on the pull

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-06-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-108908174 Thanks for the feedback. I will fix 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

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

2015-06-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/754#discussion_r31728131 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -588,23 +590,74 @@ void markFinished() {

[jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling

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

[jira] [Commented] (FLINK-1844) Add Normaliser to ML library

2015-06-04 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572941#comment-14572941 ] Theodore Vasiloudis commented on FLINK-1844: Hello Faye, have you managed to

[GitHub] flink pull request: [FLINK-2155] Enforce import restriction on usa...

2015-06-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/776#issuecomment-108930518 You don't have to update the pull request when you force push to the branch of this pull request. :-) --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2123) Fix CLI client logging

2015-06-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572841#comment-14572841 ] Robert Metzger commented on FLINK-2123: --- Okay .. sorry.. It seems that the too much

[jira] [Created] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis

2015-06-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2163: --- Summary: VertexCentricConfigurationITCase sometimes fails on Travis Key: FLINK-2163 URL: https://issues.apache.org/jira/browse/FLINK-2163 Project: Flink

[jira] [Commented] (FLINK-1565) Document object reuse behavior

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572825#comment-14572825 ] ASF GitHub Bot commented on FLINK-1565: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1565][FLINK-2078] Document ExecutionCon...

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/781 [FLINK-1565][FLINK-2078] Document ExecutionConfig and object reuse You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink1565

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

2015-06-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/754#discussion_r31728385 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/BatchSchedulingTest.java --- @@ -0,0 +1,521 @@ +/* + *

[jira] [Commented] (FLINK-2136) Test the streaming scala API

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

[jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572954#comment-14572954 ] ASF GitHub Bot commented on FLINK-2155: --- Github user lokeshrajaram commented on the

[jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572957#comment-14572957 ] ASF GitHub Bot commented on FLINK-2155: --- Github user uce commented on the pull

[GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba...

2015-06-04 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/754#discussion_r31729748 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/BatchSchedulingTest.java --- @@ -0,0 +1,521 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2136) Test the streaming scala API

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572963#comment-14572963 ] ASF GitHub Bot commented on FLINK-2136: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-2136] Adding DataStream tests for Scala...

2015-06-04 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/771#issuecomment-108932396 @StephanEwen: The `SingleOutpustStreamOperator` has the returns method, similar to the batch API. --- If your project is set up for it, you can reply to this email and

[jira] [Resolved] (FLINK-2048) Enhance Twitter Stream support

2015-06-04 Thread Hilmi Yildirim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hilmi Yildirim resolved FLINK-2048. --- Resolution: Fixed TwitterFilterSource was adapted and TwitterFilterSource was implemented.

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

2015-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572312#comment-14572312 ] ASF GitHub Bot commented on FLINK-2098: --- Github user mbalassi commented on the pull

  1   2   3   >