[jira] [Created] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer

Stephan Ewen created FLINK-4984: --- Summary: Add Cancellation Barriers to BarrierTracker and BarrierBuffer Key: FLINK-4984 URL: https://issues.apache.org/jira/browse/FLINK-4984 Project: Flink Is

[jira] [Created] (FLINK-4976) Add a way to abort in flight checkpoints

Stephan Ewen created FLINK-4976: --- Summary: Add a way to abort in flight checkpoints Key: FLINK-4976 URL: https://issues.apache.org/jira/browse/FLINK-4976 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment

Stephan Ewen created FLINK-4975: --- Summary: Add a limit for how much data may be buffered during checkpoint alignment Key: FLINK-4975 URL: https://issues.apache.org/jira/browse/FLINK-4975 Project: Flink

[jira] [Created] (FLINK-4971) Unify Stream Sinks and OutputFormats

Stephan Ewen created FLINK-4971: --- Summary: Unify Stream Sinks and OutputFormats Key: FLINK-4971 URL: https://issues.apache.org/jira/browse/FLINK-4971 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4930) Implement FLIP-6 YARN client

Stephan Ewen created FLINK-4930: --- Summary: Implement FLIP-6 YARN client Key: FLINK-4930 URL: https://issues.apache.org/jira/browse/FLINK-4930 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-4931) Implement FLIP-6 YARN client

Stephan Ewen created FLINK-4931: --- Summary: Implement FLIP-6 YARN client Key: FLINK-4931 URL: https://issues.apache.org/jira/browse/FLINK-4931 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-4929) Implement YARN TaskManager Runner

Stephan Ewen created FLINK-4929: --- Summary: Implement YARN TaskManager Runner Key: FLINK-4929 URL: https://issues.apache.org/jira/browse/FLINK-4929 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4928) Implement YARN Application Master Runner

Stephan Ewen created FLINK-4928: --- Summary: Implement YARN Application Master Runner Key: FLINK-4928 URL: https://issues.apache.org/jira/browse/FLINK-4928 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4927) Implement YARN Resource Manager

Stephan Ewen created FLINK-4927: --- Summary: Implement YARN Resource Manager Key: FLINK-4927 URL: https://issues.apache.org/jira/browse/FLINK-4927 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-4926) Implement FLIP-6 Flink-on-YARN jobs

Stephan Ewen created FLINK-4926: --- Summary: Implement FLIP-6 Flink-on-YARN jobs Key: FLINK-4926 URL: https://issues.apache.org/jira/browse/FLINK-4926 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4920) Add a Scala Function Gauge

Stephan Ewen created FLINK-4920: --- Summary: Add a Scala Function Gauge Key: FLINK-4920 URL: https://issues.apache.org/jira/browse/FLINK-4920 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

Stephan Ewen created FLINK-4917: --- Summary: Deprecate "CheckpointedAsynchronously" interface Key: FLINK-4917 URL: https://issues.apache.org/jira/browse/FLINK-4917 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-4916) BufferSpiller should distribute files across temp directories

Stephan Ewen created FLINK-4916: --- Summary: BufferSpiller should distribute files across temp directories Key: FLINK-4916 URL: https://issues.apache.org/jira/browse/FLINK-4916 Project: Flink Is

[jira] [Created] (FLINK-4915) Define parameters for reconciliation

Stephan Ewen created FLINK-4915: --- Summary: Define parameters for reconciliation Key: FLINK-4915 URL: https://issues.apache.org/jira/browse/FLINK-4915 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4914) Define parameters for reconciliation

Stephan Ewen created FLINK-4914: --- Summary: Define parameters for reconciliation Key: FLINK-4914 URL: https://issues.apache.org/jira/browse/FLINK-4914 Project: Flink Issue Type: Sub-task

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

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: Sub-

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

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

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

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 Componen

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

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: Sub-t

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

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 Ty

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

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: https://issues.apache.org/ji

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

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 Pr

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

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

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

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: Su

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

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 Proj

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

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: Sub-tas

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

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 Aff

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

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 T

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

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

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

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: Sub-t

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

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

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

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

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 Compon

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

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 Typ

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

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: Sub-t

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

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: Fl

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

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: Flink

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

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

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 I

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

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: Im

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

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

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 Is

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

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: Bug

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

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-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker

Stephan Ewen created FLINK-4697: --- Summary: Gather more detailed checkpoint stats in CheckpointStatsTracker Key: FLINK-4697 URL: https://issues.apache.org/jira/browse/FLINK-4697 Project: Flink

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

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

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

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 Type

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

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

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: Bug

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

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 Is

[jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

Stephan Ewen created FLINK-4625: --- Summary: Guard Flink processes against blocking shutdown hooks Key: FLINK-4625 URL: https://issues.apache.org/jira/browse/FLINK-4625 Project: Flink Issue Type:

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

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 I

[jira] [Created] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

Stephan Ewen created FLINK-4566: --- Summary: ProducerFailedException does not properly preserve Exception causes Key: FLINK-4566 URL: https://issues.apache.org/jira/browse/FLINK-4566 Project: Flink

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

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

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: Improvem

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

Stephan Ewen created FLINK-4539: --- Summary: Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" Key: FLINK-4539 URL: https://issues.apache.org/jira/browse/FLINK-45

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

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: Impro

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

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: Impr

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

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-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

Stephan Ewen created FLINK-4435: --- Summary: Replace Guava's VisibleForTesting annotation with Flink's annotation Key: FLINK-4435 URL: https://issues.apache.org/jira/browse/FLINK-4435 Project: Flink

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

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 Componen

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

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: Improvemen

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

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()

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 Issu

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

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: Improvem

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

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

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

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-4392) Make RPC Service Thread Safe

Stephan Ewen created FLINK-4392: --- Summary: Make RPC Service Thread Safe Key: FLINK-4392 URL: https://issues.apache.org/jira/browse/FLINK-4392 Project: Flink Issue Type: Sub-task Compo

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

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 Iss

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

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

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 Type:

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

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 Type

[jira] [Created] (FLINK-4368) Eagerly initialize RrcProtocol members

Stephan Ewen created FLINK-4368: --- Summary: Eagerly initialize RrcProtocol members Key: FLINK-4368 URL: https://issues.apache.org/jira/browse/FLINK-4368 Project: Flink Issue Type: Sub-task

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

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 Type:

[jira] [Created] (FLINK-4361) Replace Scala Futures

Stephan Ewen created FLINK-4361: --- Summary: Replace Scala Futures Key: FLINK-4361 URL: https://issues.apache.org/jira/browse/FLINK-4361 Project: Flink Issue Type: Sub-task Components:

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

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

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 C

[jira] [Created] (FLINK-4344) Implement new JobManager

Stephan Ewen created FLINK-4344: --- Summary: Implement new JobManager Key: FLINK-4344 URL: https://issues.apache.org/jira/browse/FLINK-4344 Project: Flink Issue Type: New Feature Compon

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

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 Compo

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

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-4339) Implement Slot Pool Core

Stephan Ewen created FLINK-4339: --- Summary: Implement Slot Pool Core Key: FLINK-4339 URL: https://issues.apache.org/jira/browse/FLINK-4339 Project: Flink Issue Type: Sub-task Component

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

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: Cl

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

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 Type:

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

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 Compon

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

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

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 T

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

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

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 Iss

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

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)

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

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 C

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

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

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 Iss

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

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

<    1   2   3   4   5   6   7   8   9   >