[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537627#comment-15537627 ] ASF GitHub Bot commented on FLINK-4618: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2579: [FLINK-4618] FlinkKafkaConsumer09 should start from the n...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2579 Btw, just a small tip: the Flink community usually use git rebase on the current master before submitting PRs to reduce the unnecessary merge commit ;) --- If your project is set up for it, you

[GitHub] flink issue #2579: [FLINK-4618] FlinkKafkaConsumer09 should start from the n...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2579 Thank you for working on this @static-max! Changes look good, will merge this. I'll also add an IT test when merging to ensure that the Kafka consumer is starting at the right place. ---

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537605#comment-15537605 ] ASF GitHub Bot commented on FLINK-4618: --- Github user tzulitai commented on the issue:

[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-tabpanel=15537379#comment-15537379 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81433030 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537374#comment-15537374 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81432816 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537307#comment-15537307 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81430771 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/KMeansITSuite.scala --- @@ -0,0 +1,142 @@ +/* + * Licensed to the

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81430683 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/clustering/KMeansITSuite.scala --- @@ -0,0 +1,142 @@ +/* + * Licensed to the

[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-tabpanel=15537304#comment-15537304 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the 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-tabpanel=15537293#comment-15537293 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81430196 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537288#comment-15537288 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81430070 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537282#comment-15537282 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81429867 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537259#comment-15537259 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

[GitHub] flink issue #757: [FLINK-2131][ml]: Initialization schemes for k-means clust...

Github user skonto commented on the issue: https://github.com/apache/flink/pull/757 any progress with this PR? --- 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

[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-tabpanel=15537261#comment-15537261 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on the issue:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81429258 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * 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-tabpanel=15537255#comment-15537255 ] ASF GitHub Bot commented on FLINK-2131: --- Github user skonto commented on a diff in the pull request:

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

Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/757#discussion_r81429036 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,614 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537081#comment-15537081 ] Melmoth commented on FLINK-4618: I made a PR: https://github.com/apache/flink/pull/2579 >

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537079#comment-15537079 ] ASF GitHub Bot commented on FLINK-4618: --- GitHub user static-max opened a pull request:

[GitHub] flink pull request #2579: [FLINK-4618] FlinkKafkaConsumer09 should start fro...

GitHub user static-max opened a pull request: https://github.com/apache/flink/pull/2579 [FLINK-4618] FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka This PR addresses https://issues.apache.org/jira/browse/FLINK-4618, which causes the last

[jira] [Created] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation

Ashish Walia created FLINK-4721: --- Summary: Getting exception when using a key of type Option[String] in distinct operation Key: FLINK-4721 URL: https://issues.apache.org/jira/browse/FLINK-4721 Project:

[jira] [Comment Edited] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536832#comment-15536832 ] Melmoth edited comment on FLINK-4618 at 9/30/16 7:37 PM: - Hi [~tzulitai], I will

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536832#comment-15536832 ] Melmoth commented on FLINK-4618: Hi tzulitai, I will give it a try this weekend. > FlinkKafkaConsumer09

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 9/30/16 4:16 PM: -

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

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

[GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2571 Great to hear that we're on the same page :) >I think it's no need to stick to the failed slot when the allocation fails by rpc. Just put it back to the free pool, and give us another shot.

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536359#comment-15536359 ] ASF GitHub Bot commented on FLINK-3719: --- Github user iampeter commented on the issue:

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2467 Thanks, that's better @mushketyk, but I think would be even better if you did not identify the elements explicitly by ids ('#canvas', '#job-panel'), but have the directive contain the two splitable

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536348#comment-15536348 ] Greg Hogan commented on FLINK-4315: --- >From the coding guidelines

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536325#comment-15536325 ] Chesnay Schepler commented on FLINK-4315: - i doubt it, i would keep it open as is and maybe add

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536310#comment-15536310 ] Konstantin Boudnik commented on FLINK-4315: --- But if a PR is closed without merging, would it be

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 9/30/16 3:06 PM: -

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536220#comment-15536220 ] ASF GitHub Bot commented on FLINK-4348: --- Github user KurtYoung commented on the issue:

[GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2571 @mxm Thanks for your thoughts, i really like the discussion.:smirk: You just pointed out another point which i missed in the previous reply. Actually, i noticed that right after i posted

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 9/30/16 2:57 PM: -

[jira] [Closed] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4379. --- > Add Rescalable Non-Partitioned State > > > Key:

[jira] [Resolved] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4379. - Resolution: Implemented Fix Version/s: 1.2.0 Implemented in

[jira] [Closed] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4573. --- > Potential resource leak due to unclosed RandomAccessFile in > TaskManagerLogHandler >

[jira] [Resolved] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4573. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 2afc092461cf68cf0f3c26a3ab4c58a7bd68cf71

[jira] [Resolved] (FLINK-4702) Kafka consumer must commit offsets asynchronously

[ https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4702. - Resolution: Fixed Fixed in - 1.2.0 via 92f4539afc714f7dbd293c3ad677b3b5807c6911 - 1.1.3 via

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536178#comment-15536178 ] Anton Mushin commented on FLINK-4604: - [~twalthr],thanks! I have any question about this issue. 1. Am

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536156#comment-15536156 ] ASF GitHub Bot commented on FLINK-4478: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2435 Thanks for the review @mxm. Concerning your questions: 1. Double checking is necessary due to concurrent accesses. Of course one could also use locks but that way it is less blocking.

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 9/30/16 2:35 PM: -

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536134#comment-15536134 ] ASF GitHub Bot commented on FLINK-4478: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2435#discussion_r81348862 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java --- @@ -0,0 +1,328 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536131#comment-15536131 ] ASF GitHub Bot commented on FLINK-4478: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2435#discussion_r81348543 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java --- @@ -0,0 +1,328 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536120#comment-15536120 ] Vasia Kalavri commented on FLINK-1815: -- The motivation for this issue was to (1) provide an easy way

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536083#comment-15536083 ] Greg Hogan commented on FLINK-4315: --- The general challenge would be keeping a 2.0 branch in sync with

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536077#comment-15536077 ] Chesnay Schepler commented on FLINK-4315: - We decided against a 2.0 branch as it would increase

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536049#comment-15536049 ] Konstantin Boudnik commented on FLINK-4315: --- Is there a branch for 2.0 release? If not, perhaps

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536044#comment-15536044 ] Greg Hogan commented on FLINK-4315: --- I think it's great to have this pull request to document an

[GitHub] flink issue #2578: Event B should be unique.

Github user nderraugh commented on the issue: https://github.com/apache/flink/pull/2578 opened a new PR with a single commit to fix the figure. If there's a better way I should have gone about correcting this fix by closing the old PR and opening this one let me know, I can always

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536006#comment-15536006 ] Greg Hogan commented on FLINK-1815: --- Questions: - It feels like we're making up our own format (as

[jira] [Commented] (FLINK-4718) Confusing label in Parallel Streams Diagram

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

[GitHub] flink pull request #2578: Event B should be unique.

GitHub user nderraugh opened a pull request: https://github.com/apache/flink/pull/2578 Event B should be unique. FLINK-4718 Confusing label in Parallel Streams Diagram Minor text change to clarify a mildly confusing label in a diagram. You can merge this pull request into

[jira] [Commented] (FLINK-4718) Confusing label in Parallel Streams Diagram

[ https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535963#comment-15535963 ] ASF GitHub Bot commented on FLINK-4718: --- Github user nderraugh closed the pull request at:

[GitHub] flink pull request #2575: 'Id' is the key of the stream and not the id of th...

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

[GitHub] flink issue #2575: 'Id' is the key of the stream and not the id of the event...

Github user nderraugh commented on the issue: https://github.com/apache/flink/pull/2575 will reopen a clean PR for this change. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535940#comment-15535940 ] Timo Walther commented on FLINK-4604: - [~anmu] yes sure. I assigned the issue to you. If you need any

[jira] [Updated] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4604: Assignee: Anton Mushin > Add support for standard deviation/variance >

[jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

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

[GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2571 @KurtYoung It is guaranteed that the ResourceManager will receive an RPC response of some sort. Either a reply from the TaskExecutor, or a timeout/error which is returned by the future. If the request

[jira] [Commented] (FLINK-4702) Kafka consumer must commit offsets asynchronously

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

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2577 Rebasing right now... --- 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,

[jira] [Commented] (FLINK-4702) Kafka consumer must commit offsets asynchronously

[ https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535913#comment-15535913 ] ASF GitHub Bot commented on FLINK-4702: --- Github user StephanEwen closed the pull request at:

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

[ https://issues.apache.org/jira/browse/FLINK-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535915#comment-15535915 ] ASF GitHub Bot commented on FLINK-4720: --- Github user zentol commented on the issue:

[GitHub] flink issue #2574: [FLINK-4702] [kafka connector] Commit offsets to Kafka as...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2574 Merged in 92f4539afc714f7dbd293c3ad677b3b5807c6911 Addresses @tzulitai comments. Fixed the warning log message by using atomic swap when setting the next offsets to be committed. If it

[jira] [Commented] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535900#comment-15535900 ] ASF GitHub Bot commented on FLINK-4379: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535901#comment-15535901 ] ASF GitHub Bot commented on FLINK-4573: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un...

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

[GitHub] flink pull request #2512: [FLINK-4379] Rescalable non-partitioned state

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2512 --- 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-4720) Implement an archived version of the execution graph

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

[GitHub] flink pull request #2577: [FLINK-4720] Implement archived version of the Exe...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2577 [FLINK-4720] Implement archived version of the ExecutionGraph This PR allows an ExecutionGraph to be archived. The archived version is a serializable snapshot of the EG at the time it was archived.

[jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 9/30/16 12:12 PM: --

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535824#comment-15535824 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Hi [~aljoscha], I'm struggling a bit on

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535820#comment-15535820 ] ASF GitHub Bot commented on FLINK-2254: --- Github user mushketyk commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 Makes sense to me. I'll implement this during weekend. --- 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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535769#comment-15535769 ] ASF GitHub Bot commented on FLINK-2254: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2564 Agreed, I would amend my earlier suggestion to say we only need to start with two projection methods (for each of top and bottom), something like `public Graph>

[GitHub] flink issue #2575: 'Id' is the key of the stream and not the id of the event...

Github user nderraugh commented on the issue: https://github.com/apache/flink/pull/2575 OK. That clears it up too. I'll fix it up in a little while. On Sep 30, 2016 6:38 AM, "Fabian Hueske" wrote: > Sorry @nderraugh

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535760#comment-15535760 ] ASF GitHub Bot commented on FLINK-2254: --- Github user vasia commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user vasia commented on the issue: https://github.com/apache/flink/pull/2564 What I meant is simply creating an edge with a Tuple2 label containing the labels of the two edges in the bipartite graph. Makes sense? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535748#comment-15535748 ] Vasia Kalavri commented on FLINK-1815: -- Hi [~fobeligi], representing a graph as an adjacency list is

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535717#comment-15535717 ] Faye Beligianni commented on FLINK-1815: Hello [~greghogan], maybe it would be a good idea to

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535709#comment-15535709 ] Anton Mushin commented on FLINK-4604: - Hello. Could I start to resolve this ticket? > Add support

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

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

[GitHub] flink pull request #2576: [FLINK-4315] Remove Hadoop Dependency from flink-j...

GitHub user kenmy opened a pull request: https://github.com/apache/flink/pull/2576 [FLINK-4315] Remove Hadoop Dependency from flink-java This PR breaks public API. Don't merge it before 2.0. I have moved the org.apache.hadoop dependency from flink-java to

[GitHub] flink issue #2575: 'Id' is the key of the stream and not the id of the event...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2575 Sorry @nderraugh, seems like I misinterpreted the figure then... :-( --- 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

[jira] [Created] (FLINK-4720) Implement an archived version of the execution graph

Chesnay Schepler created FLINK-4720: --- Summary: Implement an archived version of the execution graph Key: FLINK-4720 URL: https://issues.apache.org/jira/browse/FLINK-4720 Project: Flink

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 Tuple8 does not seem to friendly to me either. What do you mean by "attaching the labels"? Is it something similar to what we do with Edge/Vertex classes right, inheriting Tuple and providing

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15535642#comment-15535642 ] ASF GitHub Bot commented on FLINK-2254: --- Github user mushketyk commented on the issue:

  1   2   >