Aljoscha Krettek created FLINK-7477:
---
Summary: Use "hadoop classpath" to augment classpath when available
Key: FLINK-7477
URL: https://issues.apache.org/jira/browse/FLINK-7477
Project: Flink
Aljoscha Krettek created FLINK-7442:
---
Summary: Add option for using a child-first classloader for
loading user code
Key: FLINK-7442
URL: https://issues.apache.org/jira/browse/FLINK-7442
Project:
Aljoscha Krettek created FLINK-7414:
---
Summary: Hardcode scala.version to 2.11 in flink-quickstart-scala
Key: FLINK-7414
URL: https://issues.apache.org/jira/browse/FLINK-7414
Project: Flink
Aljoscha Krettek created FLINK-7413:
---
Summary: Release Hadoop 2.8.x convenience binaries for 1.3.x
Key: FLINK-7413
URL: https://issues.apache.org/jira/browse/FLINK-7413
Project: Flink
Aljoscha Krettek created FLINK-7398:
---
Summary: Table API operators/UDFs must not store Logger
Key: FLINK-7398
URL: https://issues.apache.org/jira/browse/FLINK-7398
Project: Flink
Issue
Aljoscha Krettek created FLINK-7396:
---
Summary: Don't put multiple directories in HADOOP_CONF_DIR in
config.sh
Key: FLINK-7396
URL: https://issues.apache.org/jira/browse/FLINK-7396
Project: Flink
Aljoscha Krettek created FLINK-7362:
---
Summary: CheckpointProperties are not correctly set when restoring
savepoint with HA enabled
Key: FLINK-7362
URL: https://issues.apache.org/jira/browse/FLINK-7362
Aljoscha Krettek created FLINK-7290:
---
Summary: Make release scripts modular
Key: FLINK-7290
URL: https://issues.apache.org/jira/browse/FLINK-7290
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-7281:
---
Summary: Fix various issues in (Maven) release infrastructure
Key: FLINK-7281
URL: https://issues.apache.org/jira/browse/FLINK-7281
Project: Flink
Aljoscha Krettek created FLINK-7268:
---
Summary: Zookeeper Checkpoint Store interacting with Incremental
State Handles can lead to loss of handles
Key: FLINK-7268
URL:
Aljoscha Krettek created FLINK-7241:
---
Summary: Fix YARN high availability documentation
Key: FLINK-7241
URL: https://issues.apache.org/jira/browse/FLINK-7241
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-7164:
---
Summary: Extend integration tests for (externalised) checkpoints,
checkpoint store
Key: FLINK-7164
URL: https://issues.apache.org/jira/browse/FLINK-7164
Aljoscha Krettek created FLINK-7133:
---
Summary: Fix Elasticsearch version interference
Key: FLINK-7133
URL: https://issues.apache.org/jira/browse/FLINK-7133
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-7041:
---
Summary: Deserialize StateBackend from JobCheckpointingSettings
with user classloader
Key: FLINK-7041
URL: https://issues.apache.org/jira/browse/FLINK-7041
Aljoscha Krettek created FLINK-6539:
---
Summary: Add automated end-to-end tests
Key: FLINK-6539
URL: https://issues.apache.org/jira/browse/FLINK-6539
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-6515:
---
Summary: KafkaConsumer checkpointing fails because of ClassLoader
issues
Key: FLINK-6515
URL: https://issues.apache.org/jira/browse/FLINK-6515
Project: Flink
Aljoscha Krettek created FLINK-6514:
---
Summary: Cannot start Flink Cluster in standalone mode
Key: FLINK-6514
URL: https://issues.apache.org/jira/browse/FLINK-6514
Project: Flink
Issue
Aljoscha Krettek created FLINK-6427:
---
Summary: BucketingSink does not sync file length in case of cancel
Key: FLINK-6427
URL: https://issues.apache.org/jira/browse/FLINK-6427
Project: Flink
Aljoscha Krettek created FLINK-6413:
---
Summary: Add stream operator callback to notify about consumed
network buffer
Key: FLINK-6413
URL: https://issues.apache.org/jira/browse/FLINK-6413
Project:
Aljoscha Krettek created FLINK-6383:
---
Summary: Add versioning for AbstractStreamOperator state
Key: FLINK-6383
URL: https://issues.apache.org/jira/browse/FLINK-6383
Project: Flink
Issue
Aljoscha Krettek created FLINK-6354:
---
Summary: Add documentation for migration away from Checkpointed
interface
Key: FLINK-6354
URL: https://issues.apache.org/jira/browse/FLINK-6354
Project: Flink
Aljoscha Krettek created FLINK-6353:
---
Summary: Restoring using CheckpointedRestoring does not work from
1.2 to 1.2
Key: FLINK-6353
URL: https://issues.apache.org/jira/browse/FLINK-6353
Project:
Aljoscha Krettek created FLINK-6323:
---
Summary: Add new Sink interface with access to more meta data
Key: FLINK-6323
URL: https://issues.apache.org/jira/browse/FLINK-6323
Project: Flink
Aljoscha Krettek created FLINK-6318:
---
Summary: NFA serialisation doesn't work with TypeSerializers that
load classes
Key: FLINK-6318
URL: https://issues.apache.org/jira/browse/FLINK-6318
Project:
Aljoscha Krettek created FLINK-6255:
---
Summary: Remove PatternStream.getSideOutput()
Key: FLINK-6255
URL: https://issues.apache.org/jira/browse/FLINK-6255
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-6254:
---
Summary: Consolidate late data methods on PatternStream and
WindowedStream
Key: FLINK-6254
URL: https://issues.apache.org/jira/browse/FLINK-6254
Project: Flink
Aljoscha Krettek created FLINK-6246:
---
Summary: Fix generic type of OutputTag in operator Output
Key: FLINK-6246
URL: https://issues.apache.org/jira/browse/FLINK-6246
Project: Flink
Issue
Aljoscha Krettek created FLINK-6188:
---
Summary: Some setParallelism() method can't cope with default
parallelism
Key: FLINK-6188
URL: https://issues.apache.org/jira/browse/FLINK-6188
Project: Flink
Aljoscha Krettek created FLINK-6164:
---
Summary: Make ProcessWindowFunction a RichFunction
Key: FLINK-6164
URL: https://issues.apache.org/jira/browse/FLINK-6164
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-6163:
---
Summary: Document per-window state in ProcessWindowFunction
Key: FLINK-6163
URL: https://issues.apache.org/jira/browse/FLINK-6163
Project: Flink
Issue
Aljoscha Krettek created FLINK-6135:
---
Summary: Allowing adding inputs to StreamOperator
Key: FLINK-6135
URL: https://issues.apache.org/jira/browse/FLINK-6135
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-6131:
---
Summary: Add side inputs for DataStream API
Key: FLINK-6131
URL: https://issues.apache.org/jira/browse/FLINK-6131
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-6118:
---
Summary: Chained operators forward watermark without checking
Key: FLINK-6118
URL: https://issues.apache.org/jira/browse/FLINK-6118
Project: Flink
Aljoscha Krettek created FLINK-6116:
---
Summary: Watermarks don't work when unioning with same DataStream
Key: FLINK-6116
URL: https://issues.apache.org/jira/browse/FLINK-6116
Project: Flink
Aljoscha Krettek created FLINK-6107:
---
Summary: Add custom checkstyle for flink-streaming-java
Key: FLINK-6107
URL: https://issues.apache.org/jira/browse/FLINK-6107
Project: Flink
Issue
Aljoscha Krettek created FLINK-5972:
---
Summary: Don't allow shrinking merging windows
Key: FLINK-5972
URL: https://issues.apache.org/jira/browse/FLINK-5972
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-5969:
---
Summary: Add savepoint backwards compatibility tests from 1.2 to
1.3
Key: FLINK-5969
URL: https://issues.apache.org/jira/browse/FLINK-5969
Project: Flink
Aljoscha Krettek created FLINK-5968:
---
Summary: Document WindowedStream.aggregate()
Key: FLINK-5968
URL: https://issues.apache.org/jira/browse/FLINK-5968
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-5967:
---
Summary: Document AggregatingState
Key: FLINK-5967
URL: https://issues.apache.org/jira/browse/FLINK-5967
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-5933:
---
Summary: Allow Evictor for merging windows
Key: FLINK-5933
URL: https://issues.apache.org/jira/browse/FLINK-5933
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-5929:
---
Summary: Allow Access to Per-Window State in ProcessWindowFunction
Key: FLINK-5929
URL: https://issues.apache.org/jira/browse/FLINK-5929
Project: Flink
Aljoscha Krettek created FLINK-5917:
---
Summary: Remove MapState.size()
Key: FLINK-5917
URL: https://issues.apache.org/jira/browse/FLINK-5917
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-5880:
---
Summary: Add documentation for object reuse for DataStream API
Key: FLINK-5880
URL: https://issues.apache.org/jira/browse/FLINK-5880
Project: Flink
Aljoscha Krettek created FLINK-5774:
---
Summary: ContinuousFileProcessingTest has test instability
Key: FLINK-5774
URL: https://issues.apache.org/jira/browse/FLINK-5774
Project: Flink
Issue
Aljoscha Krettek created FLINK-5743:
---
Summary: Mark WindowedStream.aggregate* methods as PublicEvolving
Key: FLINK-5743
URL: https://issues.apache.org/jira/browse/FLINK-5743
Project: Flink
Aljoscha Krettek created FLINK-5741:
---
Summary: Add tests for window function wrappers with RichFunctions
Key: FLINK-5741
URL: https://issues.apache.org/jira/browse/FLINK-5741
Project: Flink
Aljoscha Krettek created FLINK-5740:
---
Summary: Make WrappingFunction an interface and move to flink-core
Key: FLINK-5740
URL: https://issues.apache.org/jira/browse/FLINK-5740
Project: Flink
Aljoscha Krettek created FLINK-5721:
---
Summary: Add FoldingState to State Documentation
Key: FLINK-5721
URL: https://issues.apache.org/jira/browse/FLINK-5721
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-5720:
---
Summary: Deprecate "Folding" in all of DataStream API
Key: FLINK-5720
URL: https://issues.apache.org/jira/browse/FLINK-5720
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-5713:
---
Summary: Protect against NPE in WindowOperator window cleanup
Key: FLINK-5713
URL: https://issues.apache.org/jira/browse/FLINK-5713
Project: Flink
Aljoscha Krettek created FLINK-5709:
---
Summary: Add Max Parallelism to Parallel Execution Doc
Key: FLINK-5709
URL: https://issues.apache.org/jira/browse/FLINK-5709
Project: Flink
Issue
Aljoscha Krettek created FLINK-5647:
---
Summary: Fix RocksDB Backend Cleanup
Key: FLINK-5647
URL: https://issues.apache.org/jira/browse/FLINK-5647
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-5616:
---
Summary: YarnPreConfiguredMasterHaServicesTest fails sometimes
Key: FLINK-5616
URL: https://issues.apache.org/jira/browse/FLINK-5616
Project: Flink
Aljoscha Krettek created FLINK-5374:
---
Summary: Extend Unit Tests for RegisteredBackendStateMetaInfo
Key: FLINK-5374
URL: https://issues.apache.org/jira/browse/FLINK-5374
Project: Flink
Aljoscha Krettek created FLINK-5373:
---
Summary: Extend Unit Tests for StateAssignmentOperation
Key: FLINK-5373
URL: https://issues.apache.org/jira/browse/FLINK-5373
Project: Flink
Issue
Aljoscha Krettek created FLINK-5372:
---
Summary: Fix
RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
Key: FLINK-5372
URL: https://issues.apache.org/jira/browse/FLINK-5372
Project: Flink
Aljoscha Krettek created FLINK-5366:
---
Summary: Add end-to-end tests for Savepoint Backwards Compatibility
Key: FLINK-5366
URL: https://issues.apache.org/jira/browse/FLINK-5366
Project: Flink
Aljoscha Krettek created FLINK-5363:
---
Summary: Fire timers when window state is currently empty
Key: FLINK-5363
URL: https://issues.apache.org/jira/browse/FLINK-5363
Project: Flink
Issue
Aljoscha Krettek created FLINK-5250:
---
Summary: Make AbstractUdfStreamOperator aware of WrappingFunction
Key: FLINK-5250
URL: https://issues.apache.org/jira/browse/FLINK-5250
Project: Flink
Aljoscha Krettek created FLINK-5240:
---
Summary: Properly Close StateBackend in StreamTask when
closing/canceling
Key: FLINK-5240
URL: https://issues.apache.org/jira/browse/FLINK-5240
Project: Flink
Aljoscha Krettek created FLINK-5237:
---
Summary: Consolidate and harmonize Window Translation Tests
Key: FLINK-5237
URL: https://issues.apache.org/jira/browse/FLINK-5237
Project: Flink
Issue
Aljoscha Krettek created FLINK-5155:
---
Summary: Deprecate ValueStateDescriptor constructors with default
value
Key: FLINK-5155
URL: https://issues.apache.org/jira/browse/FLINK-5155
Project: Flink
Aljoscha Krettek created FLINK-5154:
---
Summary: Duplicate TypeSerializer when writing RocksDB Snapshot
Key: FLINK-5154
URL: https://issues.apache.org/jira/browse/FLINK-5154
Project: Flink
Aljoscha Krettek created FLINK-5130:
---
Summary: Remove Deprecated Methods from WindowedStream
Key: FLINK-5130
URL: https://issues.apache.org/jira/browse/FLINK-5130
Project: Flink
Issue
Aljoscha Krettek created FLINK-5126:
---
Summary: Remove Checked Exceptions from State Interfaces
Key: FLINK-5126
URL: https://issues.apache.org/jira/browse/FLINK-5126
Project: Flink
Issue
Aljoscha Krettek created FLINK-5125:
---
Summary: ContinuousFileProcessingCheckpointITCase is Flaky
Key: FLINK-5125
URL: https://issues.apache.org/jira/browse/FLINK-5125
Project: Flink
Issue
Aljoscha Krettek created FLINK-5037:
---
Summary: Instability in AbstractUdfStreamOperatorLifecycleTest
Key: FLINK-5037
URL: https://issues.apache.org/jira/browse/FLINK-5037
Project: Flink
Aljoscha Krettek created FLINK-5035:
---
Summary: Don't Write TypeSerializer to Heap State Snapshot
Key: FLINK-5035
URL: https://issues.apache.org/jira/browse/FLINK-5035
Project: Flink
Issue
Aljoscha Krettek created FLINK-5034:
---
Summary: Don't Write StateDescriptor to RocksDB Snapshot
Key: FLINK-5034
URL: https://issues.apache.org/jira/browse/FLINK-5034
Project: Flink
Issue
Aljoscha Krettek created FLINK-5026:
---
Summary: Rename TimelyFlatMap to Process
Key: FLINK-5026
URL: https://issues.apache.org/jira/browse/FLINK-5026
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-5015:
---
Summary: Add Tests/ITCase for Kafka Per-Partition Watermarks
Key: FLINK-5015
URL: https://issues.apache.org/jira/browse/FLINK-5015
Project: Flink
Aljoscha Krettek created FLINK-5012:
---
Summary: Provide Timestamp in TimelyFlatMapFunction
Key: FLINK-5012
URL: https://issues.apache.org/jira/browse/FLINK-5012
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-5003:
---
Summary: Provide Access to State Stores in Operator Snapshot
Context
Key: FLINK-5003
URL: https://issues.apache.org/jira/browse/FLINK-5003
Project: Flink
Aljoscha Krettek created FLINK-5000:
---
Summary: Rename Methods in ManagedInitializationContext
Key: FLINK-5000
URL: https://issues.apache.org/jira/browse/FLINK-5000
Project: Flink
Issue
Aljoscha Krettek created FLINK-4994:
---
Summary: Don't Clear Trigger State and Merging Window Set When
Purging
Key: FLINK-4994
URL: https://issues.apache.org/jira/browse/FLINK-4994
Project: Flink
Aljoscha Krettek created FLINK-4993:
---
Summary: Don't Allow Trigger.onMerge() to return TriggerResult
Key: FLINK-4993
URL: https://issues.apache.org/jira/browse/FLINK-4993
Project: Flink
Aljoscha Krettek created FLINK-4959:
---
Summary: Write Documentation for Timely FlatMap Functions
Key: FLINK-4959
URL: https://issues.apache.org/jira/browse/FLINK-4959
Project: Flink
Issue
Aljoscha Krettek created FLINK-4957:
---
Summary: Provide API for TimelyCoFlatMapFunction
Key: FLINK-4957
URL: https://issues.apache.org/jira/browse/FLINK-4957
Project: Flink
Issue Type: Test
Aljoscha Krettek created FLINK-4955:
---
Summary: Add Translations Tests for
KeyedStream.flatMap(TimelyFlatMapFunction)
Key: FLINK-4955
URL: https://issues.apache.org/jira/browse/FLINK-4955
Project:
Aljoscha Krettek created FLINK-4940:
---
Summary: Add Support for Broadcast/Global State
Key: FLINK-4940
URL: https://issues.apache.org/jira/browse/FLINK-4940
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4907:
---
Summary: Add Test for Timers/State Provided by
AbstractStreamOperator
Key: FLINK-4907
URL: https://issues.apache.org/jira/browse/FLINK-4907
Project: Flink
Aljoscha Krettek created FLINK-4892:
---
Summary: Snapshot TimerService using Key-Grouped State
Key: FLINK-4892
URL: https://issues.apache.org/jira/browse/FLINK-4892
Project: Flink
Issue
Aljoscha Krettek created FLINK-4884:
---
Summary: Eagerly Store MergingWindowSet in State in WindowOperator
Key: FLINK-4884
URL: https://issues.apache.org/jira/browse/FLINK-4884
Project: Flink
Aljoscha Krettek created FLINK-4866:
---
Summary: Make Trigger.clear() Abstract to Enforce Implementation
Key: FLINK-4866
URL: https://issues.apache.org/jira/browse/FLINK-4866
Project: Flink
Aljoscha Krettek created FLINK-4859:
---
Summary: Clearly Separate Responsibilities of StreamOperator and
StreamTask
Key: FLINK-4859
URL: https://issues.apache.org/jira/browse/FLINK-4859
Project:
Aljoscha Krettek created FLINK-4858:
---
Summary: Remove Legacy Checkpointing Interfaces
Key: FLINK-4858
URL: https://issues.apache.org/jira/browse/FLINK-4858
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4675:
---
Summary: Remove Parameter from WindowAssigner.getDefaultTrigger()
Key: FLINK-4675
URL: https://issues.apache.org/jira/browse/FLINK-4675
Project: Flink
Aljoscha Krettek created FLINK-4589:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4589
URL: https://issues.apache.org/jira/browse/FLINK-4589
Project: Flink
Issue
Aljoscha Krettek created FLINK-4588:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4588
URL: https://issues.apache.org/jira/browse/FLINK-4588
Project: Flink
Issue
Aljoscha Krettek created FLINK-4579:
---
Summary: Add StateBackendFactory for RocksDB Backend
Key: FLINK-4579
URL: https://issues.apache.org/jira/browse/FLINK-4579
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4556:
---
Summary: Make Queryable State Key-Group Aware
Key: FLINK-4556
URL: https://issues.apache.org/jira/browse/FLINK-4556
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4552:
---
Summary: Refactor WindowOperator/Trigger Tests
Key: FLINK-4552
URL: https://issues.apache.org/jira/browse/FLINK-4552
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4548:
---
Summary: Refactor ContinuousFileMonitoringTest to use OneShotLatch
Key: FLINK-4548
URL: https://issues.apache.org/jira/browse/FLINK-4548
Project: Flink
Aljoscha Krettek created FLINK-4415:
---
Summary: Enhance Trigger Interface with onFire() and onCleanup()
Key: FLINK-4415
URL: https://issues.apache.org/jira/browse/FLINK-4415
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
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-4340:
---
Summary: Remove RocksDB Semi-Async Checkpoint Mode
Key: FLINK-4340
URL: https://issues.apache.org/jira/browse/FLINK-4340
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-4329:
---
Summary: Streaming File Source Must Correctly Handle
Timestamps/Watermarks
Key: FLINK-4329
URL: https://issues.apache.org/jira/browse/FLINK-4329
Project: Flink
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:
201 - 300 of 405 matches
Mail list logo