[jira] [Created] (FLINK-4912) Introduce RECONCILIATING state in ExecutionGraph

2016-10-25 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4911) Non-disruptive JobManager Failures

2016-10-25 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4904) Add a limit for how much data may be spilled in checkpoint alignments

2016-10-25 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4836) Implement Mini Cluster

2016-10-16 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4835) Implement standalone High Availability Services

2016-10-16 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4834) Implement unified High Availability Services Abstraction

2016-10-16 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4818) RestartStrategy should track how many failed restore attempts the same checkpoint has and fall back to earlier checkpoints

2016-10-12 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2016-10-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4816) Executions from "DEPLOYING" should retain restored checkpoint information

2016-10-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails

2016-10-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4811) Checkpoint Overview should list failed checkpoints

2016-10-12 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2016-10-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4809) Operators should tolerate checkpoint failures

2016-10-12 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4808) Allow skipping failed checkpoints

2016-10-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4770) Migrate Job Execution configuration options

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4769) Migrate Metrics configuration options

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4768) Migrate High Availability configuration options

2016-10-07 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4766) Migrate TaskManager configuration options

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4767) Migrate JobManager configuration options

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4764) Introduce config options

2016-10-07 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4758) Remove IOReadableWritable from classes where not needed

2016-10-06 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"

2016-10-06 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4750) Ensure that active processing time triggers complete before closing operators

2016-10-05 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator

2016-10-05 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context

2016-10-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close

2016-10-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat

2016-10-04 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4710) Remove transitive Guice dependency from Hadoop

2016-09-29 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies

2016-09-29 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4702) Kafka consumer must commit offsets asynchronously

2016-09-27 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4698) Visualize additional checkpoint information

2016-09-27 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

2016-09-26 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

2016-09-26 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4672) TaskManager accidentally decorates Kill messages

2016-09-23 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-20 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

2016-09-20 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

2016-09-02 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

2016-08-31 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

2016-08-31 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation"

2016-08-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4539: --- Summary: Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" Key: FLINK-4539 URL:

[jira] [Created] (FLINK-4527) Drop the "flinkAccumulators" from the Execution

2016-08-29 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4525) Drop the "eager split pre-assignment" code paths

2016-08-29 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4466) Add a metric availability test.

2016-08-24 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4434) Add a testing RPC service

2016-08-19 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4431) Introduce a "VisibleForTesting" annotation

2016-08-19 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4423) Introduce a Clock utility for monotonous system timestamps

2016-08-18 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4422) Convert all time interval measurements to System.nanoTime()

2016-08-18 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4421) Make clocks and time measurements monotonous

2016-08-18 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp

2016-08-17 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4403) RPC proxy classloading should use Flink class' classloader

2016-08-16 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4399) Add support for oversized messages

2016-08-15 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4388) Race condition during initialization of MemorySegmentFactory

2016-08-12 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread

2016-08-11 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-11 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

2016-08-10 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4362) Auto generate message sender classes via Java Proxies

2016-08-10 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4346) Implement basic RPC abstraction

2016-08-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4345) Implement new ResourceManager

2016-08-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4343) Implement new TaskManager

2016-08-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4342) Fix dependencies of flink-connector-filesystem

2016-08-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4338) Implement Slot Pool

2016-08-09 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact

2016-08-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4333) Name mixup in Savepoint versions

2016-08-08 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4332) Savepoint Serializer mixed read()/readFully()

2016-08-08 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4321) Initialize TaskExecutions directly with their starting state

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4320) Fix misleading ScheduleMode names

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4319) Rework Cluster Management (FLIP-6)

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-08-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator

2016-08-04 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4312) Remove Serializabiliy of ExecutionGraph

2016-08-04 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-03 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4307) Broken user-facing API for ListState

2016-08-02 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples

2016-08-02 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4298) Clean up Storm Compatibility Dependencies

2016-08-01 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4293) Malformatted Apache Haders

2016-08-01 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4292) HCatalog project incorrectly set up

2016-08-01 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4256) Fine-grained recovery

2016-07-22 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4245) Metric naming improvements

2016-07-21 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4243) Change "Scope" to "Namespace" for Metrics

2016-07-21 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4233) Simplify leader election / leader session ID assignment

2016-07-19 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-4196) Remove "recoveryTimestamp"

2016-07-11 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-4052) Unstable test

2016-06-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3995) Properly Structure Test Utils and Dependencies

2016-05-31 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

2016-05-29 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3959) Remove implicit sinks

2016-05-23 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs

2016-04-13 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

2016-04-05 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3674) Add an interface for EventTime aware User Function

2016-03-29 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-3602) Recursive Types are not supported / crash TypeExtractor

2016-03-10 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3595) Kafka09 consumer thread does not interrupt when stuck in record emission

2016-03-09 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3554) Bounded sources should emit a Max Watermark when they are done

2016-03-01 Thread Stephan Ewen (JIRA)
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

[jira] [Created] (FLINK-3552) Change socket WordCount to be properly windowed

2016-02-29 Thread Stephan Ewen (JIRA)
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:

[jira] [Created] (FLINK-3551) Sync Scala and Java Streaming Examples

2016-02-29 Thread Stephan Ewen (JIRA)
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

<    1   2   3   4   5   6   7   8   >