Stephan Ewen created FLINK-4912:
---
Summary: Introduce RECONCILIATING state in ExecutionGraph
Key: FLINK-4912
URL: https://issues.apache.org/jira/browse/FLINK-4912
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4911:
---
Summary: Non-disruptive JobManager Failures
Key: FLINK-4911
URL: https://issues.apache.org/jira/browse/FLINK-4911
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4904:
---
Summary: Add a limit for how much data may be spilled in
checkpoint alignments
Key: FLINK-4904
URL: https://issues.apache.org/jira/browse/FLINK-4904
Project: Flink
Stephan Ewen created FLINK-4836:
---
Summary: Implement Mini Cluster
Key: FLINK-4836
URL: https://issues.apache.org/jira/browse/FLINK-4836
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4835:
---
Summary: Implement standalone High Availability Services
Key: FLINK-4835
URL: https://issues.apache.org/jira/browse/FLINK-4835
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4834:
---
Summary: Implement unified High Availability Services Abstraction
Key: FLINK-4834
URL: https://issues.apache.org/jira/browse/FLINK-4834
Project: Flink
Issue
Stephan Ewen created FLINK-4818:
---
Summary: RestartStrategy should track how many failed restore
attempts the same checkpoint has and fall back to earlier checkpoints
Key: FLINK-4818
URL:
Stephan Ewen created FLINK-4817:
---
Summary: Checkpoint Coordinator should be called to restore state
with a specific checkpoint ID
Key: FLINK-4817
URL: https://issues.apache.org/jira/browse/FLINK-4817
Stephan Ewen created FLINK-4816:
---
Summary: Executions from "DEPLOYING" should retain restored
checkpoint information
Key: FLINK-4816
URL: https://issues.apache.org/jira/browse/FLINK-4816
Project: Flink
Stephan Ewen created FLINK-4815:
---
Summary: Automatic fallback to earlier checkpoints when checkpoint
restore fails
Key: FLINK-4815
URL: https://issues.apache.org/jira/browse/FLINK-4815
Project: Flink
Stephan Ewen created FLINK-4811:
---
Summary: Checkpoint Overview should list failed checkpoints
Key: FLINK-4811
URL: https://issues.apache.org/jira/browse/FLINK-4811
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4810:
---
Summary: Checkpoint Coordinator should fail ExecutionGraph after
"n" unsuccessful checkpoints
Key: FLINK-4810
URL: https://issues.apache.org/jira/browse/FLINK-4810
Stephan Ewen created FLINK-4809:
---
Summary: Operators should tolerate checkpoint failures
Key: FLINK-4809
URL: https://issues.apache.org/jira/browse/FLINK-4809
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4808:
---
Summary: Allow skipping failed checkpoints
Key: FLINK-4808
URL: https://issues.apache.org/jira/browse/FLINK-4808
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4776:
---
Summary: Move ExecutionGraph initialization into a dedicated class
Key: FLINK-4776
URL: https://issues.apache.org/jira/browse/FLINK-4776
Project: Flink
Issue
Stephan Ewen created FLINK-4770:
---
Summary: Migrate Job Execution configuration options
Key: FLINK-4770
URL: https://issues.apache.org/jira/browse/FLINK-4770
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4769:
---
Summary: Migrate Metrics configuration options
Key: FLINK-4769
URL: https://issues.apache.org/jira/browse/FLINK-4769
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4768:
---
Summary: Migrate High Availability configuration options
Key: FLINK-4768
URL: https://issues.apache.org/jira/browse/FLINK-4768
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4766:
---
Summary: Migrate TaskManager configuration options
Key: FLINK-4766
URL: https://issues.apache.org/jira/browse/FLINK-4766
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4767:
---
Summary: Migrate JobManager configuration options
Key: FLINK-4767
URL: https://issues.apache.org/jira/browse/FLINK-4767
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4765:
---
Summary: Migrate ConfigConstants to ConfigOptions
Key: FLINK-4765
URL: https://issues.apache.org/jira/browse/FLINK-4765
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4764:
---
Summary: Introduce config options
Key: FLINK-4764
URL: https://issues.apache.org/jira/browse/FLINK-4764
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4758:
---
Summary: Remove IOReadableWritable from classes where not needed
Key: FLINK-4758
URL: https://issues.apache.org/jira/browse/FLINK-4758
Project: Flink
Issue
Stephan Ewen created FLINK-4757:
---
Summary: Unify "GlobalJobParameters" and "Configuration"
Key: FLINK-4757
URL: https://issues.apache.org/jira/browse/FLINK-4757
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4750:
---
Summary: Ensure that active processing time triggers complete
before closing operators
Key: FLINK-4750
URL: https://issues.apache.org/jira/browse/FLINK-4750
Project:
Stephan Ewen created FLINK-4749:
---
Summary: Remove redundant processing time timers and futures in
the window operator
Key: FLINK-4749
URL: https://issues.apache.org/jira/browse/FLINK-4749
Project:
Stephan Ewen created FLINK-4748:
---
Summary: Fix shutdown of automatic watermark context
Key: FLINK-4748
URL: https://issues.apache.org/jira/browse/FLINK-4748
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4747:
---
Summary: Instability due to pending processing timers on operator
close
Key: FLINK-4747
URL: https://issues.apache.org/jira/browse/FLINK-4747
Project: Flink
Stephan Ewen created FLINK-4737:
---
Summary: Add more compression algorithms to FileInputFormat
Key: FLINK-4737
URL: https://issues.apache.org/jira/browse/FLINK-4737
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4710:
---
Summary: Remove transitive Guice dependency from Hadoop
Key: FLINK-4710
URL: https://issues.apache.org/jira/browse/FLINK-4710
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4708:
---
Summary: Scope Mini Kerberos Cluster dependencies as test
dependencies
Key: FLINK-4708
URL: https://issues.apache.org/jira/browse/FLINK-4708
Project: Flink
Stephan Ewen created FLINK-4702:
---
Summary: Kafka consumer must commit offsets asynchronously
Key: FLINK-4702
URL: https://issues.apache.org/jira/browse/FLINK-4702
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4698:
---
Summary: Visualize additional checkpoint information
Key: FLINK-4698
URL: https://issues.apache.org/jira/browse/FLINK-4698
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4696:
---
Summary: Limit the number of Akka Dispatcher Threads in
LocalMiniCluster
Key: FLINK-4696
URL: https://issues.apache.org/jira/browse/FLINK-4696
Project: Flink
Stephan Ewen created FLINK-4685:
---
Summary: Gather operator checkpoint durations data sizes from the
runtime
Key: FLINK-4685
URL: https://issues.apache.org/jira/browse/FLINK-4685
Project: Flink
Stephan Ewen created FLINK-4684:
---
Summary: Remove obsolete classloader from CheckpointCoordinator
Key: FLINK-4684
URL: https://issues.apache.org/jira/browse/FLINK-4684
Project: Flink
Issue
Stephan Ewen created FLINK-4672:
---
Summary: TaskManager accidentally decorates Kill messages
Key: FLINK-4672
URL: https://issues.apache.org/jira/browse/FLINK-4672
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4645:
---
Summary: Hard to register Kryo Serializers due to generics
Key: FLINK-4645
URL: https://issues.apache.org/jira/browse/FLINK-4645
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4642:
---
Summary: Remove unnecessary Guava dependency from
flink-streaming-java
Key: FLINK-4642
URL: https://issues.apache.org/jira/browse/FLINK-4642
Project: Flink
Stephan Ewen created FLINK-4567:
---
Summary: Enhance SerializedThrowable to properly preserver cause
chains
Key: FLINK-4567
URL: https://issues.apache.org/jira/browse/FLINK-4567
Project: Flink
Stephan Ewen created FLINK-4544:
---
Summary: TaskManager metrics are vulnerable to custom JMX bean
installation
Key: FLINK-4544
URL: https://issues.apache.org/jira/browse/FLINK-4544
Project: Flink
Stephan Ewen created FLINK-4543:
---
Summary: Race Deadlock in SpilledSubpartitionViewTest
Key: FLINK-4543
URL: https://issues.apache.org/jira/browse/FLINK-4543
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4539:
---
Summary: Duplicate/inconsistent logic for physical memory size in
classes "Hardware" and "EnvironmentInformation"
Key: FLINK-4539
URL:
Stephan Ewen created FLINK-4527:
---
Summary: Drop the "flinkAccumulators" from the Execution
Key: FLINK-4527
URL: https://issues.apache.org/jira/browse/FLINK-4527
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4525:
---
Summary: Drop the "eager split pre-assignment" code paths
Key: FLINK-4525
URL: https://issues.apache.org/jira/browse/FLINK-4525
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4466:
---
Summary: Add a metric availability test.
Key: FLINK-4466
URL: https://issues.apache.org/jira/browse/FLINK-4466
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4434:
---
Summary: Add a testing RPC service
Key: FLINK-4434
URL: https://issues.apache.org/jira/browse/FLINK-4434
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4431:
---
Summary: Introduce a "VisibleForTesting" annotation
Key: FLINK-4431
URL: https://issues.apache.org/jira/browse/FLINK-4431
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4423:
---
Summary: Introduce a Clock utility for monotonous system timestamps
Key: FLINK-4423
URL: https://issues.apache.org/jira/browse/FLINK-4423
Project: Flink
Issue
Stephan Ewen created FLINK-4422:
---
Summary: Convert all time interval measurements to
System.nanoTime()
Key: FLINK-4422
URL: https://issues.apache.org/jira/browse/FLINK-4422
Project: Flink
Stephan Ewen created FLINK-4421:
---
Summary: Make clocks and time measurements monotonous
Key: FLINK-4421
URL: https://issues.apache.org/jira/browse/FLINK-4421
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4417:
---
Summary: Checkpoints should be subsumed by CheckpointID not, by
timestamp
Key: FLINK-4417
URL: https://issues.apache.org/jira/browse/FLINK-4417
Project: Flink
Stephan Ewen created FLINK-4403:
---
Summary: RPC proxy classloading should use Flink class' classloader
Key: FLINK-4403
URL: https://issues.apache.org/jira/browse/FLINK-4403
Project: Flink
Issue
Stephan Ewen created FLINK-4399:
---
Summary: Add support for oversized messages
Key: FLINK-4399
URL: https://issues.apache.org/jira/browse/FLINK-4399
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4388:
---
Summary: Race condition during initialization of
MemorySegmentFactory
Key: FLINK-4388
URL: https://issues.apache.org/jira/browse/FLINK-4388
Project: Flink
Stephan Ewen created FLINK-4386:
---
Summary: Add as way to assert that code runs in the RpcEndpoint's
Main Thread
Key: FLINK-4386
URL: https://issues.apache.org/jira/browse/FLINK-4386
Project: Flink
Stephan Ewen created FLINK-4384:
---
Summary: Add a "scheduleRunAsync()" feature to the RpcEndpoint
Key: FLINK-4384
URL: https://issues.apache.org/jira/browse/FLINK-4384
Project: Flink
Issue
Stephan Ewen created FLINK-4370:
---
Summary: Offer a default IntelliJ inspection profile with Flink
Key: FLINK-4370
URL: https://issues.apache.org/jira/browse/FLINK-4370
Project: Flink
Issue
Stephan Ewen created FLINK-4362:
---
Summary: Auto generate message sender classes via Java Proxies
Key: FLINK-4362
URL: https://issues.apache.org/jira/browse/FLINK-4362
Project: Flink
Issue
Stephan Ewen created FLINK-4346:
---
Summary: Implement basic RPC abstraction
Key: FLINK-4346
URL: https://issues.apache.org/jira/browse/FLINK-4346
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4345:
---
Summary: Implement new ResourceManager
Key: FLINK-4345
URL: https://issues.apache.org/jira/browse/FLINK-4345
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4343:
---
Summary: Implement new TaskManager
Key: FLINK-4343
URL: https://issues.apache.org/jira/browse/FLINK-4343
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4342:
---
Summary: Fix dependencies of flink-connector-filesystem
Key: FLINK-4342
URL: https://issues.apache.org/jira/browse/FLINK-4342
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4338:
---
Summary: Implement Slot Pool
Key: FLINK-4338
URL: https://issues.apache.org/jira/browse/FLINK-4338
Project: Flink
Issue Type: Sub-task
Components:
Stephan Ewen created FLINK-4337:
---
Summary: Remove unnecessary Scala suffix from Hadoop1 artifact
Key: FLINK-4337
URL: https://issues.apache.org/jira/browse/FLINK-4337
Project: Flink
Issue
Stephan Ewen created FLINK-4333:
---
Summary: Name mixup in Savepoint versions
Key: FLINK-4333
URL: https://issues.apache.org/jira/browse/FLINK-4333
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4332:
---
Summary: Savepoint Serializer mixed read()/readFully()
Key: FLINK-4332
URL: https://issues.apache.org/jira/browse/FLINK-4332
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4323:
---
Summary: Checkpoint Coordinator Removes HA Checkpoints in Shutdown
Key: FLINK-4323
URL: https://issues.apache.org/jira/browse/FLINK-4323
Project: Flink
Issue
Stephan Ewen created FLINK-4322:
---
Summary: Unify CheckpointCoordinator and SavepointCoordinator
Key: FLINK-4322
URL: https://issues.apache.org/jira/browse/FLINK-4322
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4321:
---
Summary: Initialize TaskExecutions directly with their starting
state
Key: FLINK-4321
URL: https://issues.apache.org/jira/browse/FLINK-4321
Project: Flink
Stephan Ewen created FLINK-4320:
---
Summary: Fix misleading ScheduleMode names
Key: FLINK-4320
URL: https://issues.apache.org/jira/browse/FLINK-4320
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4319:
---
Summary: Rework Cluster Management (FLIP-6)
Key: FLINK-4319
URL: https://issues.apache.org/jira/browse/FLINK-4319
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4316:
---
Summary: Make flink-core independent of Hadoop
Key: FLINK-4316
URL: https://issues.apache.org/jira/browse/FLINK-4316
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4315:
---
Summary: Remove Hadoop Dependency from flink-java
Key: FLINK-4315
URL: https://issues.apache.org/jira/browse/FLINK-4315
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4313:
---
Summary: Inconsistent code for Key/Value in the
CheckpointCoordinator
Key: FLINK-4313
URL: https://issues.apache.org/jira/browse/FLINK-4313
Project: Flink
Stephan Ewen created FLINK-4312:
---
Summary: Remove Serializabiliy of ExecutionGraph
Key: FLINK-4312
URL: https://issues.apache.org/jira/browse/FLINK-4312
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-4310:
---
Summary: Move BinaryCompatibility Check plugin to relevant projects
Key: FLINK-4310
URL: https://issues.apache.org/jira/browse/FLINK-4310
Project: Flink
Issue
Stephan Ewen created FLINK-4307:
---
Summary: Broken user-facing API for ListState
Key: FLINK-4307
URL: https://issues.apache.org/jira/browse/FLINK-4307
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4306:
---
Summary: Fix Flink and Storm dependencies in flink-storm and
flink-storm-examples
Key: FLINK-4306
URL: https://issues.apache.org/jira/browse/FLINK-4306
Project: Flink
Stephan Ewen created FLINK-4298:
---
Summary: Clean up Storm Compatibility Dependencies
Key: FLINK-4298
URL: https://issues.apache.org/jira/browse/FLINK-4298
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4293:
---
Summary: Malformatted Apache Haders
Key: FLINK-4293
URL: https://issues.apache.org/jira/browse/FLINK-4293
Project: Flink
Issue Type: Bug
Affects Versions:
Stephan Ewen created FLINK-4292:
---
Summary: HCatalog project incorrectly set up
Key: FLINK-4292
URL: https://issues.apache.org/jira/browse/FLINK-4292
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4290:
---
Summary: CassandraConnectorTest deadlocks
Key: FLINK-4290
URL: https://issues.apache.org/jira/browse/FLINK-4290
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-4256:
---
Summary: Fine-grained recovery
Key: FLINK-4256
URL: https://issues.apache.org/jira/browse/FLINK-4256
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4245:
---
Summary: Metric naming improvements
Key: FLINK-4245
URL: https://issues.apache.org/jira/browse/FLINK-4245
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-4243:
---
Summary: Change "Scope" to "Namespace" for Metrics
Key: FLINK-4243
URL: https://issues.apache.org/jira/browse/FLINK-4243
Project: Flink
Issue Type:
Stephan Ewen created FLINK-4233:
---
Summary: Simplify leader election / leader session ID assignment
Key: FLINK-4233
URL: https://issues.apache.org/jira/browse/FLINK-4233
Project: Flink
Issue
Stephan Ewen created FLINK-4196:
---
Summary: Remove "recoveryTimestamp"
Key: FLINK-4196
URL: https://issues.apache.org/jira/browse/FLINK-4196
Project: Flink
Issue Type: Bug
Components:
Stephan Ewen created FLINK-4052:
---
Summary: Unstable test
Key: FLINK-4052
URL: https://issues.apache.org/jira/browse/FLINK-4052
Project: Flink
Issue Type: Bug
Components: Tests
Stephan Ewen created FLINK-3995:
---
Summary: Properly Structure Test Utils and Dependencies
Key: FLINK-3995
URL: https://issues.apache.org/jira/browse/FLINK-3995
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-3990:
---
Summary: ZooKeeperLeaderElectionTest kills the JVM
Key: FLINK-3990
URL: https://issues.apache.org/jira/browse/FLINK-3990
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-3959:
---
Summary: Remove implicit sinks
Key: FLINK-3959
URL: https://issues.apache.org/jira/browse/FLINK-3959
Project: Flink
Issue Type: Sub-task
Components:
Stephan Ewen created FLINK-3752:
---
Summary: Add Per-Kafka-Partition Watermark Generation to the docs
Key: FLINK-3752
URL: https://issues.apache.org/jira/browse/FLINK-3752
Project: Flink
Issue
Stephan Ewen created FLINK-3700:
---
Summary: Replace Guava Preconditions class with Flink Preconditions
Key: FLINK-3700
URL: https://issues.apache.org/jira/browse/FLINK-3700
Project: Flink
Issue
Stephan Ewen created FLINK-3674:
---
Summary: Add an interface for EventTime aware User Function
Key: FLINK-3674
URL: https://issues.apache.org/jira/browse/FLINK-3674
Project: Flink
Issue Type:
Stephan Ewen created FLINK-3602:
---
Summary: Recursive Types are not supported / crash TypeExtractor
Key: FLINK-3602
URL: https://issues.apache.org/jira/browse/FLINK-3602
Project: Flink
Issue
Stephan Ewen created FLINK-3595:
---
Summary: Kafka09 consumer thread does not interrupt when stuck in
record emission
Key: FLINK-3595
URL: https://issues.apache.org/jira/browse/FLINK-3595
Project: Flink
Stephan Ewen created FLINK-3554:
---
Summary: Bounded sources should emit a Max Watermark when they are
done
Key: FLINK-3554
URL: https://issues.apache.org/jira/browse/FLINK-3554
Project: Flink
Stephan Ewen created FLINK-3552:
---
Summary: Change socket WordCount to be properly windowed
Key: FLINK-3552
URL: https://issues.apache.org/jira/browse/FLINK-3552
Project: Flink
Issue Type:
Stephan Ewen created FLINK-3551:
---
Summary: Sync Scala and Java Streaming Examples
Key: FLINK-3551
URL: https://issues.apache.org/jira/browse/FLINK-3551
Project: Flink
Issue Type: Sub-task
401 - 500 of 711 matches
Mail list logo