[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627695#comment-14627695 ] William Saar commented on FLINK-2355: - No Co* tasks. Here is the plan

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-121533840 +1 good to merge and this is a prerequisite for getting a first version of the new web UI in. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627734#comment-14627734 ] ASF GitHub Bot commented on FLINK-297: -- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121535037 Ok, of looks better indeed. I will modify 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

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627778#comment-14627778 ] ASF GitHub Bot commented on FLINK-1967: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121547033 As far as I understand, the current mechanism (operator time) is still possible. Then it would be okay. Concerning always adding timestamps to stream

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/913#discussion_r34661467 --- Diff: docs/internals/through_stack.md --- @@ -0,0 +1,181 @@ +--- +title: From Program to Result: A Dive through Stack and Execution +---

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627792#comment-14627792 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627799#comment-14627799 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/913#discussion_r34661865 --- Diff: docs/internals/through_stack.md --- @@ -0,0 +1,181 @@ +--- +title: From Program to Result: A Dive through Stack and Execution +---

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/913#discussion_r34661812 --- Diff: docs/internals/through_stack.md --- @@ -0,0 +1,181 @@ +--- +title: From Program to Result: A Dive through Stack and Execution +---

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627713#comment-14627713 ] Ufuk Celebi commented on FLINK-2355: Thanks for the plan. I had a look at it with

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121533017 Would anyone like to look into the implementation? I think if we want to have this feature we should merge this rather sooner than later because it touches a lot of

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627729#comment-14627729 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627743#comment-14627743 ] ASF GitHub Bot commented on FLINK-2359: --- Github user ggevay commented on the pull

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627775#comment-14627775 ] ASF GitHub Bot commented on FLINK-1967: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121546219 I think the implementation looks good however I am concerned about the performance hit. We need to make sure that we dont get this serious overhead when the job

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627787#comment-14627787 ] ASF GitHub Bot commented on FLINK-1967: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121548970 If we can still have the records without timestamps that would be good. But this should be automatic. Regarding monitoring, this seems to be an overkill for that

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/913#discussion_r34661712 --- Diff: docs/internals/through_stack.md --- @@ -0,0 +1,181 @@ +--- +title: From Program to Result: A Dive through Stack and Execution +---

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627737#comment-14627737 ] William Saar commented on FLINK-2355: - Thanks, just wanted to check if this was

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627807#comment-14627807 ] ASF GitHub Bot commented on FLINK-2292: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-121559138 The text for the task manager execution looks good except for some minor things. I did not check the SVG. If you want to put it out like that (incomplete

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121558994 I was just trying to make the point that for monitoring we don't need to attach timestamps for all the records. If monitoring means 15% less throughput I would probably

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627813#comment-14627813 ] ASF GitHub Bot commented on FLINK-1967: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34662511 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -306,99 +308,100 @@ extends Actor with

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627811#comment-14627811 ] ASF GitHub Bot commented on FLINK-2292: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627816#comment-14627816 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on the pull

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627820#comment-14627820 ] William Saar commented on FLINK-2355: - At the very end I am splitting the input into

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627823#comment-14627823 ] ASF GitHub Bot commented on FLINK-2292: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34662919 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -306,99 +308,100 @@ extends Actor with ActorLogMessages with

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121559974 Yeah, we can add a way to not have timestamps. But my feeling is that this is pre-mature optimization. The point where this is really relevant is when people

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627824#comment-14627824 ] ASF GitHub Bot commented on FLINK-1967: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121560503 PR looks good to me except for the purely reformatting changes which should be excluded from the PR. Thanks! --- If your project is set up for it, you can reply to

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34663165 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -306,99 +308,100 @@ extends Actor with

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627825#comment-14627825 ] ASF GitHub Bot commented on FLINK-2359: --- Github user fhueske commented on the pull

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627826#comment-14627826 ] ASF GitHub Bot commented on FLINK-2292: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-121562249 Thanks for the checks. So many typos ;-) I opened this pull request as WIP and would encourage other committers to jump in. I have been doing miles of

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627830#comment-14627830 ] Ufuk Celebi commented on FLINK-2355: Would you like to do a more interactive debugging

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627831#comment-14627831 ] ASF GitHub Bot commented on FLINK-2363: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627837#comment-14627837 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-121563616 I see, thanks for the effort! I'll take care of the *Batch API: DataSets to JobGraph* section. --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-121534709 @StephanEwen Any news on this PR? It applies some changes to JobManager WebFrontend. Would be great, if this could be merged before #677 and/or #297 --- If your project

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121534658 Thanks for adding the generator methods. That's definitely more convenient than using `new`. I also prefer `of` instead of `create`. --- If your project is set up for it,

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627742#comment-14627742 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627741#comment-14627741 ] ASF GitHub Bot commented on FLINK-2359: --- Github user mxm commented on the pull

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627750#comment-14627750 ] Ufuk Celebi commented on FLINK-2355: OK. There can be an issue if you are not

[GitHub] flink pull request: Update README.md

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/912#issuecomment-121535828 Thanks @chenliag613 for the pull request! I agree with @chiwanpark. If you're behind a proxy then you probably already know how to work with it. There are also other

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627763#comment-14627763 ] Andra Lungu commented on FLINK-2299: That's what I was chatting with Fabian about this

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627773#comment-14627773 ] Vasia Kalavri commented on FLINK-2361: -- Hey, I have seen this exception before and I

[jira] [Created] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

Stephan Ewen created FLINK-2363: --- Summary: Add an end-to-end overview of program execution in Flink to the docs Key: FLINK-2363 URL: https://issues.apache.org/jira/browse/FLINK-2363 Project: Flink

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/913 [FLINK-2363] [docs] First part of internals - complete job execution overview I found that many people do not understand the model behind Flink. I started drafting/outlining a

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627783#comment-14627783 ] ASF GitHub Bot commented on FLINK-2363: --- GitHub user StephanEwen opened a pull

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627800#comment-14627800 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/913#discussion_r34662306 --- Diff: docs/internals/through_stack.md --- @@ -0,0 +1,181 @@ +--- +title: From Program to Result: A Dive through Stack and Execution +---

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34662347 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627805#comment-14627805 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121557154 I could add a mode where the sources don't attach timestamps and where the StreamRecordSerializer ignores the timestamps and does not multiplex Records and Watermarks.

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627804#comment-14627804 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627759#comment-14627759 ] Stephan Ewen commented on FLINK-2361: - From past error reports about operator

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627795#comment-14627795 ] ASF GitHub Bot commented on FLINK-2363: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627601#comment-14627601 ] ASF GitHub Bot commented on FLINK-2359: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121503903 I also prefer `of` as a method name. --- 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: Update README.md

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/912#issuecomment-121515483 Hi, Thanks for your contribution. But I think this PR is not necessary because the change is not specific to Flink but about the general of git. --- If your project

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627622#comment-14627622 ] Andra Lungu commented on FLINK-2361: Sure, This is the main class:

[GitHub] flink pull request: Update README.md

GitHub user chenliag613 opened a pull request: https://github.com/apache/flink/pull/912 Update README.md add script for setting network proxy for git clone to connect network. Currently many company's network need use proxy, the script is useful for new users. You can merge

[jira] [Created] (FLINK-2364) Link to Guide is Broken

Suminda Dharmasena created FLINK-2364: - Summary: Link to Guide is Broken Key: FLINK-2364 URL: https://issues.apache.org/jira/browse/FLINK-2364 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34665546 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -306,99 +308,100 @@ extends Actor with ActorLogMessages with

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627862#comment-14627862 ] ASF GitHub Bot commented on FLINK-2292: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/910#issuecomment-121592253 I am wondering about two things, maybe I didnt catch something as I was just scrolling through: -Why the output of the distinct methods are not DataStreamLong

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121592265 I added numbers to my google sheet (https://docs.google.com/spreadsheets/d/1mXcy25UOiZ4lEJOia1OM-K-U6np2bWv3x4q5nSnUMdg/edit?usp=sharing) that show the performance with

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34674005 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627996#comment-14627996 ] ASF GitHub Bot commented on FLINK-2131: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [taskmanager] do not process message if not co...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/914 [taskmanager] do not process message if not connected to job manager When a message is received on the task manager, it should not be processed when not connected to the job manager. At least that is

[GitHub] flink pull request: [taskmanager] do not process message if not co...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/914#issuecomment-121605225 Makes sense, +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

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-121605233 @thvasilo I've incorporated different initialization strategies in the KMeans algorithm itself. Please review. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627997#comment-14627997 ] ASF GitHub Bot commented on FLINK-2292: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-121713405 Hello Sachin, I'm currently on vacation until August so someone else needs to so the reviews until then. Regards, Theodore -- Sent

[jira] [Commented] (FLINK-1943) Add Gelly-GSA compiler and translation tests

[ https://issues.apache.org/jira/browse/FLINK-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628562#comment-14628562 ] ASF GitHub Bot commented on FLINK-1943: --- GitHub user vasia opened a pull request:

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628551#comment-14628551 ] ASF GitHub Bot commented on FLINK-2131: --- Github user thvasilo commented on the pull

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628581#comment-14628581 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121720966 No worries, that's why we have the process. :smiley_cat: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2300) Links on FAQ page not rendered correctly

[ https://issues.apache.org/jira/browse/FLINK-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628555#comment-14628555 ] Enrique Bautista Barahona commented on FLINK-2300: -- [~mxm], I've thought

[GitHub] flink pull request: [FLINK-1943] [gelly] Added GSA compiler and tr...

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/916 [FLINK-1943] [gelly] Added GSA compiler and translation tests Thanks @StephanEwen for the help! You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121693041 Thats great, thanks Aljoscha. Sorry for raising so many concerns. I just want to make sure this change will be smooth :) --- If your project is set up for it, you can

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628364#comment-14628364 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-121681480 I now added a switch that disables timestamps and watermark multiplexing. Timestamps and multiplexing are disabled by default, i.e. the performance of existing stuff is

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628455#comment-14628455 ] ASF GitHub Bot commented on FLINK-1967: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-2148) Approximately calculate the number of distinct elements of a stream

[ https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628651#comment-14628651 ] ASF GitHub Bot commented on FLINK-2148: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/910#issuecomment-121733115 This is an interesting issue, exactly because of the current API for aggregations. I think the main purpose of returning the aggregated values inside the original data is

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121739943 Dear @fhueske , I hope I satisfied your requests! Let me know if some other changes are needed. As you suggested I took the issue on documentation.

[GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/910#issuecomment-121733294 By the way, don't the maps need to have parallelism 1 to function properly? --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-2148) Approximately calculate the number of distinct elements of a stream

[ https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628652#comment-14628652 ] ASF GitHub Bot commented on FLINK-2148: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628689#comment-14628689 ] ASF GitHub Bot commented on FLINK-1963: --- Github user pp86 commented on the pull

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628934#comment-14628934 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121775689 Looks good to me, thanks! Will try the changes tomorrow and merge. Thanks for helping with the documentation! --- If your project is set up for it, you can

[jira] [Created] (FLINK-2365) Review of How to contribute page

Enrique Bautista Barahona created FLINK-2365: Summary: Review of How to contribute page Key: FLINK-2365 URL: https://issues.apache.org/jira/browse/FLINK-2365 Project: Flink Issue

[jira] [Commented] (FLINK-2148) Approximately calculate the number of distinct elements of a stream

[ https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627941#comment-14627941 ] ASF GitHub Bot commented on FLINK-2148: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627942#comment-14627942 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-1748) Integrate PageRank implementation into machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14627983#comment-14627983 ] Rohit Shinde commented on FLINK-1748: - I would like to have this issue assigned to me.

  1   2   >