Gabor Gevay created FLINK-8649:
--
Summary: Scala StreamExecutionEnvironment.createInput should pass
on the TypeInfo
Key: FLINK-8649
URL: https://issues.apache.org/jira/browse/FLINK-8649
Project: Flink
Gabor Gevay created FLINK-8117:
--
Summary: Eliminate modulo operation from RoundRobinChannelSelector
and RebalancePartitioner
Key: FLINK-8117
URL: https://issues.apache.org/jira/browse/FLINK-8117
Project:
Gabor Gevay created FLINK-8116:
--
Summary: Stale comments referring to Checkpointed interface
Key: FLINK-8116
URL: https://issues.apache.org/jira/browse/FLINK-8116
Project: Flink
Issue Type: Bug
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
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
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
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
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
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
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
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
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:
Gabor Gevay created FLINK-3722:
--
Summary: The divisions in the InMemorySorters' swap/compare
methods hurt performance
Key: FLINK-3722
URL: https://issues.apache.org/jira/browse/FLINK-3722
Project: Flink
Gabor Gevay created FLINK-3519:
--
Summary: Subclasses of Tuples don't work if the declared type of a
DataSet is not the descendant
Key: FLINK-3519
URL: https://issues.apache.org/jira/browse/FLINK-3519
Pro
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
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
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
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
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
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
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
Gabor Gevay created FLINK-2839:
--
Summary: Failing test:
OperatorStatsAccumulatorTest.testAccumulatorAllStatistics
Key: FLINK-2839
URL: https://issues.apache.org/jira/browse/FLINK-2839
Project: Flink
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: Sc
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
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
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
Pro
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-254
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: B
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/
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
Pro
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
Projec
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
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
Iss
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: Fl
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
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-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: Improvemen
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: https://issues.apache.
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
Co
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
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:
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
I
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
Compo
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: Sub-
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-2121:
--
Summary: FileInputFormat.addFilesInDir miscalculates total size
Key: FLINK-2121
URL: https://issues.apache.org/jira/browse/FLINK-2121
Project: Flink
Issue Type:
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: Flin
49 matches
Mail list logo
