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

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/781#issuecomment-109172997 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-2160] Change Streaming Source Interface...

2015-06-04 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/785#issuecomment-109173098 @mbalassi What's the reason for not wanting emit and keeping collect? I am aware that other parts of the system have a Collector with a collect method but the sources ar

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

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

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

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

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

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

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/785#issuecomment-109067246 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-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-tabpanel&focusedCommentId=14573658#comment-14573658 ] ASF GitHub Bot commented on FLINK-2160: --- Github user flinkqa commented on the pull r

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

2015-06-04 Thread Faye Beligianni (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14573629#comment-14573629 ] Faye Beligianni commented on FLINK-1844: Hello [~tvas], I have implemented the ma

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

2015-06-04 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14573616#comment-14573616 ] Vasia Kalavri commented on FLINK-2163: -- Thanks [~aljoscha] for reporting this and [~u

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

2015-06-04 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/771#discussion_r31766212 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala --- @@ -0,0 +1,475 @@

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

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

2015-06-04 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/771#discussion_r31766241 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala --- @@ -0,0 +1,475 @@

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

[jira] [Commented] (FLINK-2139) Test Streaming Outputformats

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

[GitHub] flink pull request: [FLINK-2139] [streaming] Streaming outputforma...

2015-06-04 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/789 [FLINK-2139] [streaming] Streaming outputformat tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/mbalassi/flink flink-2139 Alternatively y

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

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

[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-tabpanel&focusedCommentId=14573521#comment-14573521 ] ASF GitHub Bot commented on FLINK-2080: --- Github user mbalassi 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 a

[jira] [Commented] (FLINK-2087) Add streaming mode to YARN as well

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

[GitHub] flink pull request: [FLINK-2087] Add streaming mode switch to YARN

2015-06-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/788 [FLINK-2087] Add streaming mode switch to YARN You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink2087 Alternatively you can r

[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-tabpanel&focusedCommentId=14573505#comment-14573505 ] 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 rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-109036738 asf_flink is just how I name the flink git repository. if its called "flink" on your git, then that's what you have to do ;) --- If your project is set up for it, yo

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

[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-109036073 This makes sense. There is no read confusion. I just need to learn more about git and the correct process. What is asf_flink ? Why not "git fetch flink && git rebase flink/

[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-tabpanel&focusedCommentId=14573497#comment-14573497 ] 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 rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/707#issuecomment-109034661 Ah yeah .. Sorry regarding the git confusion. I would do the following: git checkout multipleJobsWebUI git rebase -i HEAD~2 # delete the commit I've a

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

[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-109033136 One of the five builds failed (Kafka test). I guess, it one of the randomly failing once. The build is green in my own Travis: https://travis-ci.org/mjsax/flink/builds/6544

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

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

2015-06-04 Thread flinkqa
Github user flinkqa commented on the pull request: https://github.com/apache/flink/pull/786#issuecomment-109030827 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-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-tabpanel&focusedCommentId=14573297#comment-14573297 ] Robert Metzger commented on FLINK-1229: --- Updated documentation for this in http://g

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

[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-tabpanel&focusedCommentId=14573281#comment-14573281 ] Robert Metzger commented on FLINK-2080: --- I've turned your patch into a pull request

[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 https:/

[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-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-tabpanel&focusedCommentId=14573280#comment-14573280 ] ASF GitHub Bot commented on FLINK-2080: --- GitHub user rmetzger opened a pull request:

[jira] [Comment Edited] (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-tabpanel&focusedCommentId=14573275#comment-14573275 ] Robert Metzger edited comment on FLINK-2080 at 6/4/15 6:05 PM: -

[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

[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-tabpanel&focusedCommentId=14573275#comment-14573275 ] Robert Metzger commented on FLINK-2080: --- Thank you. Can you give me your email addr

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

[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-tabpanel&focusedCommentId=14573270#comment-14573270 ] ASF GitHub Bot commented on FLINK-2160: --- Github user StephanEwen commented on a diff

[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_r31747189 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSou

[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-tabpanel&focusedCommentId=14573266#comment-14573266 ] ASF GitHub Bot commented on FLINK-2160: --- Github user StephanEwen commented on a diff

[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: flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.

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

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

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

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

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

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

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

[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 ". This is not true any more

[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 http://git-wip-us.apache.org/re

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

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

[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

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

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

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

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

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

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

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

[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 @@ +/* + * Licens

[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-tabpanel&focusedCommentId=14573153#comment-14573153 ] Till Rohrmann commented on FLINK-2156: -- This should only occur on Travis. Locally, th

[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-tabpanel&focusedCommentId=14573128#comment-14573128 ] ASF GitHub Bot commented on FLINK-2160: --- GitHub user aljoscha opened a pull request:

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

[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: https://github.com/apache/flink/commit/6685b0bac54b95705426fd78bb

[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-tabpanel&focusedCommentId=14573115#comment-14573115 ] ASF GitHub Bot commented on FLINK-1061: --- GitHub user rmetzger opened a pull request:

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

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

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

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

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

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

[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-tabpanel&focusedCommentId=14573076#comment-14573076 ] ASF GitHub Bot commented on FLINK-2123: --- GitHub user rmetzger opened a pull request:

[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 log4j.properties

[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-tabpanel&focusedCommentId=14573057#comment-14573057 ] Stephan Ewen commented on FLINK-2156: - I have elevated this to critical, because these

[jira] [Updated] (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:all-tabpanel ] Stephan Ewen updated FLINK-2156: Priority: Critical (was: Blocker) > Scala modules cannot create logging file >

[jira] [Updated] (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:all-tabpanel ] Stephan Ewen updated FLINK-2156: Priority: Blocker (was: Minor) > Scala modules cannot create logging file > ---

[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-tabpanel&focusedCommentId=14572977#comment-14572977 ] Till Rohrmann commented on FLINK-2116: -- We could still offer a way to create matrices

[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 https://githu

  1   2   3   >