[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-1767:
--
Assignee: Gabor Gevay
StreamExecutionEnvironment's execute should return JobExecutionResult
[
https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355858#comment-14355858
]
Gabor Gevay commented on FLINK-1617:
Hello!
I am also interested in working on this
[
https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-1797:
--
Assignee: Gabor Gevay
Add jumping pre-reducer for Count and Time windows
[
https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385396#comment-14385396
]
Gabor Gevay commented on FLINK-1797:
May I have a go at this issue?
By jumping window
[
https://issues.apache.org/jira/browse/FLINK-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548386#comment-14548386
]
Gabor Gevay commented on FLINK-2039:
Since I am about to refactor the relevant code
[
https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-1670:
--
Assignee: Gabor Gevay
Collect method for streaming
Gabor Gevay created FLINK-2181:
--
Summary: SessionWindowing example has a memleak
Key: FLINK-2181
URL: https://issues.apache.org/jira/browse/FLINK-2181
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2147:
---
Labels: statistics (was: )
Approximate calculation of frequencies in data streams
Gabor Gevay created FLINK-2148:
--
Summary: Approximately calculate the number of distinct elements
of a stream
Key: FLINK-2148
URL: https://issues.apache.org/jira/browse/FLINK-2148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2145:
---
Labels: statistics (was: )
Median calculation for windows
--
Gabor Gevay created FLINK-2145:
--
Summary: Median calculation for windows
Key: FLINK-2145
URL: https://issues.apache.org/jira/browse/FLINK-2145
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Labels: statistics (was: )
Implement count, average, and variance for windows
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Description:
By count I mean the number of elements in the window.
These can be implemented very
Gabor Gevay created FLINK-2146:
--
Summary: Fast calculation of min/max with arbitrary eviction and
triggers
Key: FLINK-2146
URL: https://issues.apache.org/jira/browse/FLINK-2146
Project: Flink
Gabor Gevay created FLINK-2143:
--
Summary: Add an overload to reduceWindow which takes the inverse
of the reduceFunction as a second parameter
Key: FLINK-2143
URL: https://issues.apache.org/jira/browse/FLINK-2143
Gabor Gevay created FLINK-2142:
--
Summary: GSoC project: Exact and Approximate Statistics for Data
Streams and Windows
Key: FLINK-2142
URL: https://issues.apache.org/jira/browse/FLINK-2142
Project: Flink
Gabor Gevay created FLINK-2144:
--
Summary: Implement count, average, and variance for windows
Key: FLINK-2144
URL: https://issues.apache.org/jira/browse/FLINK-2144
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2142:
---
Description:
The goal of this project is to implement basic statistics of data streams and
windows
[
https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2145:
---
Description:
The PreReducer for this has the following algorithm: We maintain two multisets
(as, for
Gabor Gevay created FLINK-2147:
--
Summary: Approximate calculation of frequencies in data streams
Key: FLINK-2147
URL: https://issues.apache.org/jira/browse/FLINK-2147
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Description:
By count I mean the number of elements in the window.
These can be implemented very
Gabor Gevay created FLINK-2255:
--
Summary: In the TopSpeedWindowing examples, every window contains
only 1 element, because event time is in millisec, but eviction is in sec
Key: FLINK-2255
URL:
Gabor Gevay created FLINK-2114:
--
Summary: PunctuationPolicy.toString() throws NullPointerException
if extractor is null
Key: FLINK-2114
URL: https://issues.apache.org/jira/browse/FLINK-2114
Project:
[
https://issues.apache.org/jira/browse/FLINK-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay resolved FLINK-2114.
Resolution: Fixed
PunctuationPolicy.toString() throws NullPointerException if extractor is null
Gabor Gevay created FLINK-2121:
--
Summary: FileInputFormat.addFilesInDir miscalculates total size
Key: FLINK-2121
URL: https://issues.apache.org/jira/browse/FLINK-2121
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2540:
---
Component/s: Core
LocalBufferPool.requestBuffer gets into infinite loop
Gabor Gevay created FLINK-2540:
--
Summary: LocalBufferPool.requestBuffer gets into infinite loop
Key: FLINK-2540
URL: https://issues.apache.org/jira/browse/FLINK-2540
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2540:
---
Fix Version/s: 0.9.1
0.10
LocalBufferPool.requestBuffer gets into infinite loop
Gabor Gevay created FLINK-2542:
--
Summary: It should be documented that it is required from a join
key to override hashCode(), when it is not a POJO
Key: FLINK-2542
URL:
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703423#comment-14703423
]
Gabor Gevay commented on FLINK-2548:
{quote}
Actually, the second co-group is not a
Gabor Gevay created FLINK-2548:
--
Summary: VertexCentricIteration should avoid doing a coGroup with
the edges and the solution set
Key: FLINK-2548
URL: https://issues.apache.org/jira/browse/FLINK-2548
[
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
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706579#comment-14706579
]
Gabor Gevay commented on FLINK-2548:
I changed the title of the issue to refer to the
[
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
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708364#comment-14708364
]
Gabor Gevay commented on FLINK-2548:
OK, you are probably right.
I ran some more
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704730#comment-14704730
]
Gabor Gevay commented on FLINK-2548:
{quote}
CoGrouping with the solution set is a
Gabor Gevay created FLINK-2437:
--
Summary: TypeExtractor.analyzePojo has some problems around the
default constructor detection
Key: FLINK-2437
URL: https://issues.apache.org/jira/browse/FLINK-2437
Gabor Gevay created FLINK-2447:
--
Summary: TypeExtractor returns wrong type info when a Tuple has
two fields of the same POJO type
Key: FLINK-2447
URL: https://issues.apache.org/jira/browse/FLINK-2447
[
https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2447:
---
Description:
Consider the following code:
DataSetFooBarPojo d1 = env.fromElements(new FooBarPojo());
[
https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2447:
---
Component/s: Java API
TypeExtractor returns wrong type info when a Tuple has two fields of the same
[
https://issues.apache.org/jira/browse/FLINK-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14647915#comment-14647915
]
Gabor Gevay commented on FLINK-2437:
I just realized that it is not a problem that
[
https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2447:
---
Fix Version/s: 0.9.1
0.10
TypeExtractor returns wrong type info when a Tuple has
[
https://issues.apache.org/jira/browse/FLINK-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2360:
---
Fix Version/s: 0.9.1
0.10
EOFException
Key:
Gabor Gevay created FLINK-2527:
--
Summary: If a VertexUpdateFunction calls setNewVertexValue more
than once, the MessagingFunction will only see the first value set
Key: FLINK-2527
URL:
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14698423#comment-14698423
]
Gabor Gevay commented on FLINK-2527:
I'm also leaning towards (1) now. I have actually
Gabor Gevay created FLINK-2374:
--
Summary: File.setWritable doesn't work on Windows, which makes
several tests fail
Key: FLINK-2374
URL: https://issues.apache.org/jira/browse/FLINK-2374
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631270#comment-14631270
]
Gabor Gevay commented on FLINK-2374:
Yes, it appears to be a duplicate, sorry.
[
https://issues.apache.org/jira/browse/FLINK-2374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay closed FLINK-2374.
--
Resolution: Duplicate
File.setWritable doesn't work on Windows, which makes several tests fail
[
https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631386#comment-14631386
]
Gabor Gevay commented on FLINK-2359:
You're welcome!
Add factory methods to the Java
[
https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14626676#comment-14626676
]
Gabor Gevay commented on FLINK-2359:
Oh, I didn't know about the diamond thing,
Gabor Gevay created FLINK-2359:
--
Summary: Add factory methods to the Java TupleX types
Key: FLINK-2359
URL: https://issues.apache.org/jira/browse/FLINK-2359
Project: Flink
Issue Type:
Gabor Gevay created FLINK-2369:
--
Summary: On Windows, in testFailingSortingDataSinkTask the temp
file is not removed
Key: FLINK-2369
URL: https://issues.apache.org/jira/browse/FLINK-2369
Project: Flink
Gabor Gevay created FLINK-2376:
--
Summary: testFindConnectableAddress sometimes fails on Windows
because of the time limit
Key: FLINK-2376
URL: https://issues.apache.org/jira/browse/FLINK-2376
Project:
Gabor Gevay created FLINK-2377:
--
Summary: AbstractTestBase.deleteAllTempFiles sometimes fails on
Windows
Key: FLINK-2377
URL: https://issues.apache.org/jira/browse/FLINK-2377
Project: Flink
Gabor Gevay created FLINK-2378:
--
Summary: complexIntegrationTest1 and testGroupByFeedback sometimes
fail on Windows
Key: FLINK-2378
URL: https://issues.apache.org/jira/browse/FLINK-2378
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14633525#comment-14633525
]
Gabor Gevay commented on FLINK-2377:
Yes, I have found the problem:
[
https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-2148:
--
Assignee: Gabor Gevay
Approximately calculate the number of distinct elements of a stream
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976982#comment-14976982
]
Gabor Gevay commented on FLINK-2662:
That's strange. I have also tried to reproduce this now, and it
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978124#comment-14978124
]
Gabor Gevay commented on FLINK-2662:
It is working on my work laptop...
> CompilerException: "Bug:
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978675#comment-14978675
]
Gabor Gevay commented on FLINK-2662:
Yes, because I checked out the branch that is referred here in
[
https://issues.apache.org/jira/browse/FLINK-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002124#comment-15002124
]
Gabor Gevay commented on FLINK-2757:
This might be related to
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006330#comment-15006330
]
Gabor Gevay commented on FLINK-2662:
Hi,
Unfortunately, I haven't made any progress. It is still
[
https://issues.apache.org/jira/browse/FLINK-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2847:
---
Labels: test-stability (was: )
> Fix flaky test in StormTestBase.testJob
>
Gabor Gevay created FLINK-2839:
--
Summary: Failing test:
OperatorStatsAccumulatorTest.testAccumulatorAllStatistics
Key: FLINK-2839
URL: https://issues.apache.org/jira/browse/FLINK-2839
Project: Flink
[
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
>
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-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-2237:
--
Assignee: Gabor Gevay
> Add hash-based Aggregation
> --
>
>
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14909174#comment-14909174
]
Gabor Gevay commented on FLINK-2237:
Couldn't the CompactingHashTable be reused here? The driver would
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
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-1730:
---
Priority: Major (was: Minor)
> Add a FlinkTools.persist style method to the Data Set.
>
Gabor Gevay created FLINK-3999:
--
Summary: Rename the `running` flag in the drivers to `canceled`
Key: FLINK-3999
URL: https://issues.apache.org/jira/browse/FLINK-3999
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303994#comment-15303994
]
Gabor Gevay commented on FLINK-3291:
This bug occurred when object reuse is enabled. This is disabled
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136812#comment-15136812
]
Gabor Gevay commented on FLINK-3266:
These are two thread dumps, one before running the job, and one
[
https://issues.apache.org/jira/browse/FLINK-3363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136813#comment-15136813
]
Gabor Gevay commented on FLINK-3363:
Is this a different issue from
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:
[
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
>
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15139018#comment-15139018
]
Gabor Gevay commented on FLINK-:
I have raised the priority to Blocker, because it seems that
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15139219#comment-15139219
]
Gabor Gevay commented on FLINK-:
OK, this would also be a clear improvement over the current
[
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
>
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
[
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)
>
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15144755#comment-15144755
]
Gabor Gevay commented on FLINK-3291:
{quote}
The initial idea of a contract for
[
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
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15139435#comment-15139435
]
Gabor Gevay commented on FLINK-:
One more thing: if we decide to go with including chaining, then
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132453#comment-15132453
]
Gabor Gevay commented on FLINK-3335:
Are you sure that adding that copy is the best solution here? An
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15134152#comment-15134152
]
Gabor Gevay commented on FLINK-3291:
@Greg, my current problem is that I'm not sure what should be the
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15130452#comment-15130452
]
Gabor Gevay commented on FLINK-3291:
OK, sorry, I think I have now understood what you meant by
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
[
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
[
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
>
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:
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128243#comment-15128243
]
Gabor Gevay commented on FLINK-3291:
> `ReduceDriver.run` owns two objects but is not tracking the
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167415#comment-15167415
]
Gabor Gevay commented on FLINK-3322:
It's making it even worse:
false, 500m: 30s
false, 5000m: 115s
1 - 100 of 214 matches
Mail list logo
