[jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

2016-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3394: --- Component/s: (was: Distributed Coordination) Local Runtime > Clear up the contrac

[jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3322: --- Component/s: (was: Distributed Coordination) Local Runtime > MemoryManager create

[jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3322: --- Assignee: (was: Gabor Horvath) > MemoryManager creates too much GC pressure with iterative jobs >

[jira] [Resolved] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-3291. Resolution: Fixed > Object reuse bug in MergeIterator.HeadStream.nextHead >

[jira] [Updated] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3722: --- Assignee: (was: Gabor Gevay) > The divisions in the InMemorySorters' swap/compare methods hurt per

[jira] [Commented] (FLINK-3999) Rename the `running` flag in the drivers to `canceled`

2016-08-24 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435446#comment-15435446 ] Gabor Gevay commented on FLINK-3999: Yes, thank you for working on it! > Rename the `

[jira] [Updated] (FLINK-3999) Rename the `running` flag in the drivers to `canceled`

2016-08-24 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3999: --- Assignee: Neelesh Srinivas Salian > Rename the `running` flag in the drivers to `canceled` > -

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436605#comment-15436605 ] Gabor Gevay commented on FLINK-3322: I think it would be very good to finally solve th

[jira] [Comment Edited] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436605#comment-15436605 ] Gabor Gevay edited comment on FLINK-3322 at 8/25/16 10:05 AM: --

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437410#comment-15437410 ] Gabor Gevay commented on FLINK-3322: Yes, I volunteer to help :) > MemoryManager crea

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-08-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438599#comment-15438599 ] Gabor Gevay commented on FLINK-3322: Yes, I think Stephan meant that you would be main

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-08-31 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2662: --- Priority: Critical (was: Major) > CompilerException: "Bug: Plan generation for Unions picked a ship s

[jira] [Created] (FLINK-4575) DataSet aggregate methods should support POJOs

2016-09-04 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-4575: -- Summary: DataSet aggregate methods should support POJOs Key: FLINK-4575 URL: https://issues.apache.org/jira/browse/FLINK-4575 Project: Flink Issue Type: Improvem

[jira] [Assigned] (FLINK-4575) DataSet aggregate methods should support POJOs

2016-09-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-4575: -- Assignee: Gabor Gevay > DataSet aggregate methods should support POJOs > --

[jira] [Created] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types

2016-09-04 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-4578: -- Summary: AggregateOperator incorrectly sets ForwardedField with nested composite types Key: FLINK-4578 URL: https://issues.apache.org/jira/browse/FLINK-4578 Project: Flin

[jira] [Updated] (FLINK-4575) DataSet aggregate methods should support POJOs

2016-09-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-4575: --- Assignee: (was: Gabor Gevay) > DataSet aggregate methods should support POJOs > --

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

2016-09-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463360#comment-15463360 ] Gabor Gevay commented on FLINK-4575: This is a bit harder than I thought, because of a

[jira] [Commented] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types

2016-09-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463363#comment-15463363 ] Gabor Gevay commented on FLINK-4578: A hacky solution might be to create some dummy {{

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474531#comment-15474531 ] Gabor Gevay commented on FLINK-3322: I had an offline chat with [~StephanEwen], and an

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474575#comment-15474575 ] Gabor Gevay commented on FLINK-3322: I've just realized that what I wrote above doesn'

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-11 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15482191#comment-15482191 ] Gabor Gevay commented on FLINK-3322: [~ram_krish] You are right, making the sorters re

[jira] [Resolved] (FLINK-2144) Incremental count, average, and variance for windows

2017-04-03 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-2144. Resolution: Won't Fix > Incremental count, average, and variance for windows > -

[jira] [Reopened] (FLINK-2144) Incremental count, average, and variance for windows

2017-04-03 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reopened FLINK-2144: Reopening to change it back to "Won't fix", instead of "Fixed" > Incremental count, average, and varian

[jira] [Commented] (FLINK-2147) Approximate calculation of frequencies in data streams

2017-04-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955166#comment-15955166 ] Gabor Gevay commented on FLINK-2147: Maybe we could over-partition the sketch into max

[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"

2016-07-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367631#comment-15367631 ] Gabor Gevay commented on FLINK-4029: You might want to reuse the FieldAccessor infrast

[jira] [Commented] (FLINK-3279) Optionally disable DistinctOperator combiner

2016-07-15 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379599#comment-15379599 ] Gabor Gevay commented on FLINK-3279: https://issues.apache.org/jira/browse/FLINK-3479?

[jira] [Comment Edited] (FLINK-3279) Optionally disable DistinctOperator combiner

2016-07-15 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379599#comment-15379599 ] Gabor Gevay edited comment on FLINK-3279 at 7/15/16 4:00 PM: -

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2016-07-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393704#comment-15393704 ] Gabor Gevay commented on FLINK-2237: I think we should have a separate {{setCombineHin

[jira] [Updated] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-07-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3722: --- Component/s: (was: Distributed Coordination) Local Runtime > The divisions in the

[jira] [Assigned] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-07-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-3722: -- Assignee: Gabor Gevay > The divisions in the InMemorySorters' swap/compare methods hurt perform

[jira] [Comment Edited] (FLINK-3999) Rename the `running` flag in the drivers to `canceled`

2016-10-18 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587764#comment-15587764 ] Gabor Gevay edited comment on FLINK-3999 at 10/19/16 5:47 AM: --

[jira] [Resolved] (FLINK-3999) Rename the `running` flag in the drivers to `canceled`

2016-10-18 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-3999. Resolution: Won't Fix See comment here: https://github.com/apache/flink/pull/2642#issuecomment-25462

[jira] [Created] (FLINK-4867) Investigate code generation for improving sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-4867: -- Summary: Investigate code generation for improving sort performance Key: FLINK-4867 URL: https://issues.apache.org/jira/browse/FLINK-4867 Project: Flink Issue Ty

[jira] [Created] (FLINK-4868) Insertion sort could avoid the swaps

2016-10-20 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-4868: -- Summary: Insertion sort could avoid the swaps Key: FLINK-4868 URL: https://issues.apache.org/jira/browse/FLINK-4868 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4868) Insertion sort could avoid the swaps

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-4868: --- Description: This is about the fallback to insertion sort at the beginning of {{QuickSort.sortInterna

[jira] [Updated] (FLINK-4860) Sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-4860: --- Component/s: Local Runtime > Sort performance > > > Key: FLINK-4860 >

[jira] [Updated] (FLINK-4860) Sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-4860: --- Labels: performance (was: ) > Sort performance > > > Key: FLINK-4860

[jira] [Updated] (FLINK-4869) Store record pointer after record keys

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-4869: --- Labels: performance (was: ) > Store record pointer after record keys > --

[jira] [Commented] (FLINK-4867) Investigate code generation for improving sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592367#comment-15592367 ] Gabor Gevay commented on FLINK-4867: That's nice, thanks! > Investigate code generati

[jira] [Assigned] (FLINK-4867) Investigate code generation for improving sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-4867: -- Assignee: Gabor Gevay > Investigate code generation for improving sort performance > --

[jira] [Commented] (FLINK-4867) Investigate code generation for improving sort performance

2016-10-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592359#comment-15592359 ] Gabor Gevay commented on FLINK-4867: Hm, this sounds quite interesting. Could you plea

[jira] [Commented] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set.

2017-02-13 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15863673#comment-15863673 ] Gabor Gevay commented on FLINK-1730: Hi [~kateri] I'm also really looking forward to

[jira] [Commented] (FLINK-5888) ForwardedFields annotation is not generating optimised execution plan in example KMeans job

2017-02-22 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15878779#comment-15878779 ] Gabor Gevay commented on FLINK-5888: Just a wild guess: Is it possible that the shuffl

[jira] [Created] (FLINK-7629) Scala stream aggregations should support nested field expressions

2017-09-15 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7629: -- Summary: Scala stream aggregations should support nested field expressions Key: FLINK-7629 URL: https://issues.apache.org/jira/browse/FLINK-7629 Project: Flink

[jira] [Updated] (FLINK-7629) Scala stream aggregations should support nested field expressions

2017-09-17 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-7629: --- Description: In the Scala API, {{KeyedStream.maxBy}} and similar methods currently only work with a f

[jira] [Created] (FLINK-7680) Add "Performance Tuning" section to docs

2017-09-24 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7680: -- Summary: Add "Performance Tuning" section to docs Key: FLINK-7680 URL: https://issues.apache.org/jira/browse/FLINK-7680 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7685) CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly"

2017-09-25 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7685: -- Summary: CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly" Key: FLINK-7685 URL: https://issue

[jira] [Created] (FLINK-7702) Javadocs link broken

2017-09-27 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7702: -- Summary: Javadocs link broken Key: FLINK-7702 URL: https://issues.apache.org/jira/browse/FLINK-7702 Project: Flink Issue Type: Bug Components: Document

[jira] [Updated] (FLINK-7702) Javadocs link broken

2017-09-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-7702: --- Fix Version/s: 1.4.0 > Javadocs link broken > > > Key: FLINK-7702

[jira] [Commented] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories

2017-10-10 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198727#comment-16198727 ] Gabor Gevay commented on FLINK-1268: This issue just happened to me. I ran my job loca

[jira] [Updated] (FLINK-5734) Implement code generation for NormalizedKeySorter

2017-09-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-5734: --- Fix Version/s: 1.4.0 > Implement code generation for NormalizedKeySorter > ---

[jira] [Updated] (FLINK-5734) Implement code generation for NormalizedKeySorter

2017-09-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-5734: --- Description: Link to design document : https://docs.google.com/document/d/1anGQhBn9qI0yqe7twVvrDIiym4

[jira] [Assigned] (FLINK-5734) Implement code generation for NormalizedKeySorter

2017-09-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-5734: -- Assignee: Gabor Gevay > Implement code generation for NormalizedKeySorter > ---

[jira] [Resolved] (FLINK-4867) Investigate code generation for improving sort performance

2017-09-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-4867. Resolution: Done I'm closing this, as [~heytitle] did the performance investigation, and concluded

[jira] [Updated] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

2015-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2548: --- Summary: In a VertexCentricIteration, the run time of one iteration should be proportional to the size

[jira] [Commented] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

2015-08-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706579#comment-14706579 ] Gabor Gevay commented on FLINK-2548: I changed the title of the issue to refer to the

[jira] [Commented] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

2015-08-23 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14708364#comment-14708364 ] Gabor Gevay commented on FLINK-2548: OK, you are probably right. I ran some more test

[jira] [Resolved] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset

2015-08-23 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-2548. Resolution: Won't Fix > In a VertexCentricIteration, the run time of one iteration should be > prop

[jira] [Updated] (FLINK-2181) SessionWindowing example has a memleak

2015-09-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2181: --- Assignee: (was: Gabor Gevay) > SessionWindowing example has a memleak > --

[jira] [Created] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2015-09-12 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2662: -- Summary: CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." Key: FLINK-2662 URL: https://issues.apache.org/jira/browse/FLINK-26

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2015-09-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909174#comment-14909174 ] Gabor Gevay commented on FLINK-2237: Couldn't the CompactingHashTable be reused here?

[jira] [Created] (FLINK-2806) No TypeInfo for Scala's Nothing type

2015-10-02 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2806: -- Summary: No TypeInfo for Scala's Nothing type Key: FLINK-2806 URL: https://issues.apache.org/jira/browse/FLINK-2806 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-2809) DataSet[Unit] doesn't work

2015-10-02 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2809: -- Summary: DataSet[Unit] doesn't work Key: FLINK-2809 URL: https://issues.apache.org/jira/browse/FLINK-2809 Project: Flink Issue Type: Bug Components: Sc

[jira] [Assigned] (FLINK-2237) Add hash-based Aggregation

2015-10-03 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-2237: -- Assignee: Gabor Gevay > Add hash-based Aggregation > -- > >

[jira] [Created] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs

2015-10-04 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2818: -- Summary: The *ReduceDriver classes have incorrect javadocs Key: FLINK-2818 URL: https://issues.apache.org/jira/browse/FLINK-2818 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-13 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3166: -- Summary: The first program in ObjectReuseITCase has the wrong expected result, and it succeeds Key: FLINK-3166 URL: https://issues.apache.org/jira/browse/FLINK-3166 Proje

[jira] [Updated] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-13 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3166: --- Component/s: Tests > The first program in ObjectReuseITCase has the wrong expected result, and it > s

[jira] [Updated] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-13 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3166: --- Component/s: Documentation Distributed Runtime > The first program in ObjectReuseITCa

[jira] [Created] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted

2016-01-20 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3266: -- Summary: LocalFlinkMiniCluster leaks resources when multiple jobs are submitted Key: FLINK-3266 URL: https://issues.apache.org/jira/browse/FLINK-3266 Project: Flink

[jira] [Commented] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted

2016-01-20 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15108861#comment-15108861 ] Gabor Gevay commented on FLINK-3266: Threads staying alive are the most apparent, but

[jira] [Commented] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted

2016-01-21 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110349#comment-15110349 ] Gabor Gevay commented on FLINK-3266: They have names like `ForkJoinPool-168-worker-3`

[jira] [Assigned] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2016-01-22 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-2246: -- Assignee: Gabor Gevay > Add chained combine driver strategy for ReduceFunction > --

[jira] [Commented] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2016-01-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15115174#comment-15115174 ] Gabor Gevay commented on FLINK-2246: I have added a commit to https://github.com/apach

[jira] [Created] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-01-26 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3291: -- Summary: Object reuse bug in MergeIterator.HeadStream.nextHead Key: FLINK-3291 URL: https://issues.apache.org/jira/browse/FLINK-3291 Project: Flink Issue Type: B

[jira] [Updated] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-01-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3291: --- Component/s: Distributed Runtime > Object reuse bug in MergeIterator.HeadStream.nextHead > ---

[jira] [Comment Edited] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-02 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128225#comment-15128225 ] Gabor Gevay edited comment on FLINK-3291 at 2/2/16 1:14 PM: I'

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-02 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128225#comment-15128225 ] Gabor Gevay commented on FLINK-3291: I'm almost done with the fix, see here: https://g

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-02 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128243#comment-15128243 ] Gabor Gevay commented on FLINK-3291: > `ReduceDriver.run` owns two objects but is not

[jira] [Created] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it

2016-02-02 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3321: -- Summary: TupleSerializerBase.getLength should know the length when all fields know it Key: FLINK-3321 URL: https://issues.apache.org/jira/browse/FLINK-3321 Project: Flink

[jira] [Updated] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it

2016-02-02 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3321: --- Labels: starter (was: ) > TupleSerializerBase.getLength should know the length when all fields know i

[jira] [Created] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-02-02 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3322: -- Summary: MemoryManager creates too much GC pressure with iterative jobs Key: FLINK-3322 URL: https://issues.apache.org/jira/browse/FLINK-3322 Project: Flink Iss

[jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-02-02 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3322: --- Fix Version/s: 1.0.0 > MemoryManager creates too much GC pressure with iterative jobs > --

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-03 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130452#comment-15130452 ] Gabor Gevay commented on FLINK-3291: OK, sorry, I think I have now understood what you

[jira] [Created] (FLINK-3333) Documentation about object reuse should be improved

2016-02-04 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-: -- Summary: Documentation about object reuse should be improved Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3335) DataSourceTask object reuse when disabled

2016-02-04 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132453#comment-15132453 ] Gabor Gevay commented on FLINK-3335: Are you sure that adding that copy is the best so

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

2016-02-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-: --- Component/s: Documentation > Documentation about object reuse should be improved > ---

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-05 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134152#comment-15134152 ] Gabor Gevay commented on FLINK-3291: @Greg, my current problem is that I'm not sure wh

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

2016-02-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-: --- Priority: Major (was: Minor) > Documentation about object reuse should be improved >

[jira] [Commented] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted

2016-02-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136812#comment-15136812 ] Gabor Gevay commented on FLINK-3266: These are two thread dumps, one before running th

[jira] [Commented] (FLINK-3363) JobManager does not shut down dedicated executor properly

2016-02-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136813#comment-15136813 ] Gabor Gevay commented on FLINK-3363: Is this a different issue from https://issues.apa

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

2016-02-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-: --- Priority: Critical (was: Major) > Documentation about object reuse should be improved > -

[jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-: --- Priority: Blocker (was: Critical) > Documentation about object reuse should be improved > ---

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139018#comment-15139018 ] Gabor Gevay commented on FLINK-: I have raised the priority to Blocker, because it

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139219#comment-15139219 ] Gabor Gevay commented on FLINK-: OK, this would also be a clear improvement over t

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139435#comment-15139435 ] Gabor Gevay commented on FLINK-: One more thing: if we decide to go with including

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-12 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144755#comment-15144755 ] Gabor Gevay commented on FLINK-3291: {quote} The initial idea of a contract for Mutabl

[jira] [Created] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

2016-02-12 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3394: -- Summary: Clear up the contract of MutableObjectIterator.next(reuse) Key: FLINK-3394 URL: https://issues.apache.org/jira/browse/FLINK-3394 Project: Flink Issue Ty

[jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

2016-02-12 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3394: --- Fix Version/s: 1.0.0 > Clear up the contract of MutableObjectIterator.next(reuse) > --

[jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

2016-02-12 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3394: --- Description: {{MutableObjectIterator.next(reuse)}} has the following contract (according to [~Stephan

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-02-12 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144823#comment-15144823 ] Gabor Gevay commented on FLINK-3291: I tried to do that, but with the one I came up wi

  1   2   3   >