Aljoscha Krettek created FLINK-1720:
---
Summary: Integrate ScalaDoc in Scala sources into overall JavaDoc
Key: FLINK-1720
URL: https://issues.apache.org/jira/browse/FLINK-1720
Project: Flink
Aljoscha Krettek created FLINK-1623:
---
Summary: Rename Expression API and Operation Representation
Key: FLINK-1623
URL: https://issues.apache.org/jira/browse/FLINK-1623
Project: Flink
Issue
Aljoscha Krettek created FLINK-1622:
---
Summary: Add ReducePartial and GroupReducePartial Operators
Key: FLINK-1622
URL: https://issues.apache.org/jira/browse/FLINK-1622
Project: Flink
Issue
Aljoscha Krettek created FLINK-1936:
---
Summary: Normalize keys and default values in ConfigConstants.java
Key: FLINK-1936
URL: https://issues.apache.org/jira/browse/FLINK-1936
Project: Flink
Aljoscha Krettek created FLINK-1971:
---
Summary: Add user function type to StreamOperator
Key: FLINK-1971
URL: https://issues.apache.org/jira/browse/FLINK-1971
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-1977:
---
Summary: Rework Stream Operators to always be push based
Key: FLINK-1977
URL: https://issues.apache.org/jira/browse/FLINK-1977
Project: Flink
Issue
Aljoscha Krettek created FLINK-1985:
---
Summary: Streaming does not correctly forward ExecutionConfig to
runtime
Key: FLINK-1985
URL: https://issues.apache.org/jira/browse/FLINK-1985
Project: Flink
Aljoscha Krettek created FLINK-2000:
---
Summary: Add SQL-style aggregations for Table API
Key: FLINK-2000
URL: https://issues.apache.org/jira/browse/FLINK-2000
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2009:
---
Summary: Time-Based Windows fail with Chaining Disabled
Key: FLINK-2009
URL: https://issues.apache.org/jira/browse/FLINK-2009
Project: Flink
Issue
Aljoscha Krettek created FLINK-1903:
---
Summary: Joins where one side uses a field more than once don't
work
Key: FLINK-1903
URL: https://issues.apache.org/jira/browse/FLINK-1903
Project: Flink
Aljoscha Krettek created FLINK-1904:
---
Summary: Add cross() to Table API
Key: FLINK-1904
URL: https://issues.apache.org/jira/browse/FLINK-1904
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-1880:
---
Summary: TaskManagerTest fails spuriously
Key: FLINK-1880
URL: https://issues.apache.org/jira/browse/FLINK-1880
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-1851:
---
Summary: Java Table API does not support Casting
Key: FLINK-1851
URL: https://issues.apache.org/jira/browse/FLINK-1851
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2182:
---
Summary: Add stateful Streaming Sequence Source
Key: FLINK-2182
URL: https://issues.apache.org/jira/browse/FLINK-2182
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2163:
---
Summary: VertexCentricConfigurationITCase sometimes fails on Travis
Key: FLINK-2163
URL: https://issues.apache.org/jira/browse/FLINK-2163
Project: Flink
Aljoscha Krettek created FLINK-2160:
---
Summary: Change Streaming Source Interface to run(Context)/cancel()
Key: FLINK-2160
URL: https://issues.apache.org/jira/browse/FLINK-2160
Project: Flink
Aljoscha Krettek created FLINK-2191:
---
Summary: Inconsistent use of Closure Cleaner in Streaming API
Key: FLINK-2191
URL: https://issues.apache.org/jira/browse/FLINK-2191
Project: Flink
Aljoscha Krettek created FLINK-2277:
---
Summary: In Scala API delta Iterations can not be set to unmanaged
Key: FLINK-2277
URL: https://issues.apache.org/jira/browse/FLINK-2277
Project: Flink
Aljoscha Krettek created FLINK-2221:
---
Summary: Checkpoints to file:// are not cleaned up
Key: FLINK-2221
URL: https://issues.apache.org/jira/browse/FLINK-2221
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2234:
---
Summary: CoStreamWindow is Dependent on Input Ordering
Key: FLINK-2234
URL: https://issues.apache.org/jira/browse/FLINK-2234
Project: Flink
Issue
Aljoscha Krettek created FLINK-2236:
---
Summary: RowSerializer and CaseClassComparator are not in sync
regarding Null-Values
Key: FLINK-2236
URL: https://issues.apache.org/jira/browse/FLINK-2236
Aljoscha Krettek created FLINK-2203:
---
Summary: Add Support for Null-Values in RowSerializer
Key: FLINK-2203
URL: https://issues.apache.org/jira/browse/FLINK-2203
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2122:
---
Summary: Make all internal streaming operators Checkpointable
Key: FLINK-2122
URL: https://issues.apache.org/jira/browse/FLINK-2122
Project: Flink
Aljoscha Krettek created FLINK-2124:
---
Summary: FromElementsFunction is not really Serializable
Key: FLINK-2124
URL: https://issues.apache.org/jira/browse/FLINK-2124
Project: Flink
Issue
Aljoscha Krettek created FLINK-2103:
---
Summary: Expose partitionBy to the user in Stream API
Key: FLINK-2103
URL: https://issues.apache.org/jira/browse/FLINK-2103
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2290:
---
Summary: CoRecordReader Does Not Read Events From Both Inputs When
No Elements Arrive
Key: FLINK-2290
URL: https://issues.apache.org/jira/browse/FLINK-2290
Aljoscha Krettek created FLINK-2317:
---
Summary: Stream Jobs with Windows Leave Lingering State
Key: FLINK-2317
URL: https://issues.apache.org/jira/browse/FLINK-2317
Project: Flink
Issue
Aljoscha Krettek created FLINK-2294:
---
Summary: Keyed State does not work with DOP=1
Key: FLINK-2294
URL: https://issues.apache.org/jira/browse/FLINK-2294
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-2074:
---
Summary: Sliding Window Keeps Emitting Elements After Source Stops
Producing
Key: FLINK-2074
URL: https://issues.apache.org/jira/browse/FLINK-2074
Project:
Aljoscha Krettek created FLINK-2081:
---
Summary: Change order of restore state and open for Streaming
Operators
Key: FLINK-2081
URL: https://issues.apache.org/jira/browse/FLINK-2081
Project: Flink
Aljoscha Krettek created FLINK-2558:
---
Summary: Add Streaming Connector for Elasticsearch
Key: FLINK-2558
URL: https://issues.apache.org/jira/browse/FLINK-2558
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2559:
---
Summary: Fix Javadoc Code Examples
Key: FLINK-2559
URL: https://issues.apache.org/jira/browse/FLINK-2559
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-2551:
---
Summary: Fix Several Bugs in Input/Output Formats
Key: FLINK-2551
URL: https://issues.apache.org/jira/browse/FLINK-2551
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-2550:
---
Summary: Rework DataStream API
Key: FLINK-2550
URL: https://issues.apache.org/jira/browse/FLINK-2550
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-2295:
---
Summary: TwoInput Task do not react to/forward checkpoint barriers
Key: FLINK-2295
URL: https://issues.apache.org/jira/browse/FLINK-2295
Project: Flink
Aljoscha Krettek created FLINK-2470:
---
Summary: Stream Iteration can Hang after some Data
Key: FLINK-2470
URL: https://issues.apache.org/jira/browse/FLINK-2470
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2398:
---
Summary: Decouple StreamGraph Building from the API
Key: FLINK-2398
URL: https://issues.apache.org/jira/browse/FLINK-2398
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2382:
---
Summary: Live Metric Reporting Does Not Work for Two-Input
StreamTasks
Key: FLINK-2382
URL: https://issues.apache.org/jira/browse/FLINK-2382
Project: Flink
Aljoscha Krettek created FLINK-2383:
---
Summary: Add new Window Operator that can use Timestamps/Watermarks
Key: FLINK-2383
URL: https://issues.apache.org/jira/browse/FLINK-2383
Project: Flink
Aljoscha Krettek created FLINK-2891:
---
Summary: Key for Keyed State is not set upon Window Evaluation
Key: FLINK-2891
URL: https://issues.apache.org/jira/browse/FLINK-2891
Project: Flink
Aljoscha Krettek created FLINK-2922:
---
Summary: Add Queryable Window Operator
Key: FLINK-2922
URL: https://issues.apache.org/jira/browse/FLINK-2922
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-2870:
---
Summary: Add support for accumulating/discarding for Event-Time
Windows
Key: FLINK-2870
URL: https://issues.apache.org/jira/browse/FLINK-2870
Project: Flink
Aljoscha Krettek created FLINK-2864:
---
Summary: Make State of General-Purpose Window Operators
Fault-Tolerant
Key: FLINK-2864
URL: https://issues.apache.org/jira/browse/FLINK-2864
Project: Flink
Aljoscha Krettek created FLINK-2877:
---
Summary: Move Streaming API out of Staging
Key: FLINK-2877
URL: https://issues.apache.org/jira/browse/FLINK-2877
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2830:
---
Summary: Add Fold Window Operation for new Windowing API
Key: FLINK-2830
URL: https://issues.apache.org/jira/browse/FLINK-2830
Project: Flink
Issue
Aljoscha Krettek created FLINK-3024:
---
Summary: TimestampExtractor Does not Work When returning
Long.MIN_VALUE
Key: FLINK-3024
URL: https://issues.apache.org/jira/browse/FLINK-3024
Project: Flink
Aljoscha Krettek created FLINK-2577:
---
Summary: Watermarks Stall When a Source Finishes Prematurely
Key: FLINK-2577
URL: https://issues.apache.org/jira/browse/FLINK-2577
Project: Flink
Aljoscha Krettek created FLINK-2643:
---
Summary: Change Travis Build Profile to Exclude Hadoop
2.0.0-alpha, Include 2.7.0
Key: FLINK-2643
URL: https://issues.apache.org/jira/browse/FLINK-2643
Aljoscha Krettek created FLINK-2780:
---
Summary: Remove Old Windowing Logic and API
Key: FLINK-2780
URL: https://issues.apache.org/jira/browse/FLINK-2780
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-2819:
---
Summary: Add Windowed Join/CoGroup Operator Based on Tagged Union
Key: FLINK-2819
URL: https://issues.apache.org/jira/browse/FLINK-2819
Project: Flink
Aljoscha Krettek created FLINK-2747:
---
Summary: TypeExtractor does not correctly analyze Scala Immutables
(AnyVal)
Key: FLINK-2747
URL: https://issues.apache.org/jira/browse/FLINK-2747
Project:
Aljoscha Krettek created FLINK-3178:
---
Summary: Make Closing Behavior of Window Operators Configurable
Key: FLINK-3178
URL: https://issues.apache.org/jira/browse/FLINK-3178
Project: Flink
Aljoscha Krettek created FLINK-3174:
---
Summary: Add merging WindowAssigner
Key: FLINK-3174
URL: https://issues.apache.org/jira/browse/FLINK-3174
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3177:
---
Summary: Add Stream Operator that Discards Late Elements
Key: FLINK-3177
URL: https://issues.apache.org/jira/browse/FLINK-3177
Project: Flink
Issue
Aljoscha Krettek created FLINK-3201:
---
Summary: Enhance Partitioned State Interface with State Types
Key: FLINK-3201
URL: https://issues.apache.org/jira/browse/FLINK-3201
Project: Flink
Aljoscha Krettek created FLINK-3200:
---
Summary: Use Partitioned State Abstraction in WindowOperator
Key: FLINK-3200
URL: https://issues.apache.org/jira/browse/FLINK-3200
Project: Flink
Aljoscha Krettek created FLINK-3202:
---
Summary: Make Timer/Trigger Service Scoped to Key/Namespace
Key: FLINK-3202
URL: https://issues.apache.org/jira/browse/FLINK-3202
Project: Flink
Issue
Aljoscha Krettek created FLINK-4028:
---
Summary: AbstractAlignedProcessingTimeWindowOperator creates wrong
TimeWindow
Key: FLINK-4028
URL: https://issues.apache.org/jira/browse/FLINK-4028
Project:
Aljoscha Krettek created FLINK-4062:
---
Summary: Update Window Documentation
Key: FLINK-4062
URL: https://issues.apache.org/jira/browse/FLINK-4062
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-4063:
---
Summary: Add Metrics Support for Triggers
Key: FLINK-4063
URL: https://issues.apache.org/jira/browse/FLINK-4063
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3977:
---
Summary: Subclasses of InternalWindowFunction must support
OutputTypeConfigurable
Key: FLINK-3977
URL: https://issues.apache.org/jira/browse/FLINK-3977
Aljoscha Krettek created FLINK-4082:
---
Summary: Add Setting for LargeRecordHandler
Key: FLINK-4082
URL: https://issues.apache.org/jira/browse/FLINK-4082
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3242:
---
Summary: User-specified StateBackend is not Respected if
Checkpointing is Disabled
Key: FLINK-3242
URL: https://issues.apache.org/jira/browse/FLINK-3242
Aljoscha Krettek created FLINK-3243:
---
Summary: Fix Interplay of TimeCharacteristic and Time Windows
Key: FLINK-3243
URL: https://issues.apache.org/jira/browse/FLINK-3243
Project: Flink
Aljoscha Krettek created FLINK-3336:
---
Summary: Add Semi-Rebalance Data Shipping for DataStream
Key: FLINK-3336
URL: https://issues.apache.org/jira/browse/FLINK-3336
Project: Flink
Issue
Aljoscha Krettek created FLINK-3528:
---
Summary: Add Incremental Fold for Non-Keyed Window Operator
Key: FLINK-3528
URL: https://issues.apache.org/jira/browse/FLINK-3528
Project: Flink
Issue
Aljoscha Krettek created FLINK-3548:
---
Summary: Remove unnecessary generic parameter from
SingleOutputStreamOperator
Key: FLINK-3548
URL: https://issues.apache.org/jira/browse/FLINK-3548
Project:
Aljoscha Krettek created FLINK-3521:
---
Summary: Make Iterable part of method signature for WindowFunction
Key: FLINK-3521
URL: https://issues.apache.org/jira/browse/FLINK-3521
Project: Flink
Aljoscha Krettek created FLINK-3527:
---
Summary: Scala DataStream has no transform method
Key: FLINK-3527
URL: https://issues.apache.org/jira/browse/FLINK-3527
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3513:
---
Summary: Fix interplay of automatic Operator UID and Changing name
of WindowOperator
Key: FLINK-3513
URL: https://issues.apache.org/jira/browse/FLINK-3513
Aljoscha Krettek created FLINK-3278:
---
Summary: Add Partitioned State Backend Based on RocksDB
Key: FLINK-3278
URL: https://issues.apache.org/jira/browse/FLINK-3278
Project: Flink
Issue
Aljoscha Krettek created FLINK-3400:
---
Summary: RocksDB Backend does not work when not in Flink lib folder
Key: FLINK-3400
URL: https://issues.apache.org/jira/browse/FLINK-3400
Project: Flink
Aljoscha Krettek created FLINK-3417:
---
Summary: Add RocksDB StateBackendFactory and integrate with Flink
Config
Key: FLINK-3417
URL: https://issues.apache.org/jira/browse/FLINK-3417
Project: Flink
Aljoscha Krettek created FLINK-3419:
---
Summary: Drop partitionByHash from DataStream
Key: FLINK-3419
URL: https://issues.apache.org/jira/browse/FLINK-3419
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3430:
---
Summary: Remove "no POJO" warning in TypeAnalyzer
Key: FLINK-3430
URL: https://issues.apache.org/jira/browse/FLINK-3430
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3436:
---
Summary: Remove ComplexIntegrationITCase
Key: FLINK-3436
URL: https://issues.apache.org/jira/browse/FLINK-3436
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3439:
---
Summary: Remove final Long.MAX_VALUE Watermark in StreamSource
Key: FLINK-3439
URL: https://issues.apache.org/jira/browse/FLINK-3439
Project: Flink
Aljoscha Krettek created FLINK-3614:
---
Summary: Remove Non-Keyed Window Operator
Key: FLINK-3614
URL: https://issues.apache.org/jira/browse/FLINK-3614
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3714:
---
Summary: Add Support for "Allowed Lateness"
Key: FLINK-3714
URL: https://issues.apache.org/jira/browse/FLINK-3714
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-3715:
---
Summary: Move Accumulating/Discarding from Trigger to
WindowOperator
Key: FLINK-3715
URL: https://issues.apache.org/jira/browse/FLINK-3715
Project: Flink
Aljoscha Krettek created FLINK-3706:
---
Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue
unstable
Key: FLINK-3706
URL: https://issues.apache.org/jira/browse/FLINK-3706
Project: Flink
Aljoscha Krettek created FLINK-3747:
---
Summary: Consolidate TimestampAssigner Methods in Kafka Consumer
Key: FLINK-3747
URL: https://issues.apache.org/jira/browse/FLINK-3747
Project: Flink
Aljoscha Krettek created FLINK-3730:
---
Summary: Fix RocksDB Local Directory Initialization
Key: FLINK-3730
URL: https://issues.apache.org/jira/browse/FLINK-3730
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3646:
---
Summary: Use Processing-Time Clock in Window Assigners/Triggers
Key: FLINK-3646
URL: https://issues.apache.org/jira/browse/FLINK-3646
Project: Flink
Aljoscha Krettek created FLINK-3647:
---
Summary: Change StreamSource to use Processing-Time Clock Service
Key: FLINK-3647
URL: https://issues.apache.org/jira/browse/FLINK-3647
Project: Flink
Aljoscha Krettek created FLINK-3648:
---
Summary: Introduce Trigger Test Harness
Key: FLINK-3648
URL: https://issues.apache.org/jira/browse/FLINK-3648
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-3654:
---
Summary: Disable Write-Ahead-Log in RocksDB State
Key: FLINK-3654
URL: https://issues.apache.org/jira/browse/FLINK-3654
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3659:
---
Summary: Allow ConnectedStreams to Be Keyed on Only One Side
Key: FLINK-3659
URL: https://issues.apache.org/jira/browse/FLINK-3659
Project: Flink
Aljoscha Krettek created FLINK-3643:
---
Summary: Improve Window Triggers
Key: FLINK-3643
URL: https://issues.apache.org/jira/browse/FLINK-3643
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3669:
---
Summary: WindowOperator registers a log of timers at StreamTask
Key: FLINK-3669
URL: https://issues.apache.org/jira/browse/FLINK-3669
Project: Flink
Aljoscha Krettek created FLINK-3591:
---
Summary: Replace Quickstart K-Means Example by Streaming Example
Key: FLINK-3591
URL: https://issues.apache.org/jira/browse/FLINK-3591
Project: Flink
Aljoscha Krettek created FLINK-3581:
---
Summary: Add Non-Keyed Window Trigger
Key: FLINK-3581
URL: https://issues.apache.org/jira/browse/FLINK-3581
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3582:
---
Summary: Add Iterator over State for All Keys in Partitioned State
Key: FLINK-3582
URL: https://issues.apache.org/jira/browse/FLINK-3582
Project: Flink
Aljoscha Krettek created FLINK-3575:
---
Summary: Update Working With State Section in Doc
Key: FLINK-3575
URL: https://issues.apache.org/jira/browse/FLINK-3575
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-3651:
---
Summary: Fix faulty RollingSink Restore
Key: FLINK-3651
URL: https://issues.apache.org/jira/browse/FLINK-3651
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-3760:
---
Summary: Fix StateDescriptor.readObject
Key: FLINK-3760
URL: https://issues.apache.org/jira/browse/FLINK-3760
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-4282:
---
Summary: Add Offset Parameter to WindowAssigners
Key: FLINK-4282
URL: https://issues.apache.org/jira/browse/FLINK-4282
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4369:
---
Summary: Evictingwindowoperator Must Actually Evict Elements
Key: FLINK-4369
URL: https://issues.apache.org/jira/browse/FLINK-4369
Project: Flink
Aljoscha Krettek created FLINK-4381:
---
Summary: Refactor State to Prepare For Key-Group State Backends
Key: FLINK-4381
URL: https://issues.apache.org/jira/browse/FLINK-4381
Project: Flink
Aljoscha Krettek created FLINK-4380:
---
Summary: Introduce KeyGroupAssigner and Max-Parallelism Parameter
Key: FLINK-4380
URL: https://issues.apache.org/jira/browse/FLINK-4380
Project: Flink
1 - 100 of 405 matches
Mail list logo