[jira] [Created] (FLINK-7158) Wrong test jar dependency in flink-clients

Stephan Ewen created FLINK-7158: --- Summary: Wrong test jar dependency in flink-clients Key: FLINK-7158 URL: https://issues.apache.org/jira/browse/FLINK-7158 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7150) Code improvements to the ElasticSearch connector

Stephan Ewen created FLINK-7150: --- Summary: Code improvements to the ElasticSearch connector Key: FLINK-7150 URL: https://issues.apache.org/jira/browse/FLINK-7150 Project: Flink Issue Type:

[jira] [Created] (FLINK-7149) Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink

Stephan Ewen created FLINK-7149: --- Summary: Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink Key: FLINK-7149 URL: https://issues.apache.org/jira/browse/FLINK-7149 Project: Flink

[jira] [Created] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

Stephan Ewen created FLINK-6667: --- Summary: Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph Key: FLINK-6667 URL: https://issues.apache.org/jira/browse/FLINK-6667

[jira] [Created] (FLINK-6666) RestartStrategy should differentiate between types of recovery (global / local / resource missing)

Stephan Ewen created FLINK-: --- Summary: RestartStrategy should differentiate between types of recovery (global / local / resource missing) Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

Stephan Ewen created FLINK-6665: --- Summary: Pass a ScheduledExecutorService to the RestartStrategy Key: FLINK-6665 URL: https://issues.apache.org/jira/browse/FLINK-6665 Project: Flink Issue

[jira] [Created] (FLINK-6664) Extend Restart Strategy for Fine-grained Recovery and missing Resources

Stephan Ewen created FLINK-6664: --- Summary: Extend Restart Strategy for Fine-grained Recovery and missing Resources Key: FLINK-6664 URL: https://issues.apache.org/jira/browse/FLINK-6664 Project: Flink

[jira] [Created] (FLINK-6559) Rename 'slaves' to 'workers'

Stephan Ewen created FLINK-6559: --- Summary: Rename 'slaves' to 'workers' Key: FLINK-6559 URL: https://issues.apache.org/jira/browse/FLINK-6559 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6546) Fix dependencies of flink-mesos

Stephan Ewen created FLINK-6546: --- Summary: Fix dependencies of flink-mesos Key: FLINK-6546 URL: https://issues.apache.org/jira/browse/FLINK-6546 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6529) Rework the shading model in Flink

Stephan Ewen created FLINK-6529: --- Summary: Rework the shading model in Flink Key: FLINK-6529 URL: https://issues.apache.org/jira/browse/FLINK-6529 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6501) Make sure NOTICE files are bundled into shaded JAR files

Stephan Ewen created FLINK-6501: --- Summary: Make sure NOTICE files are bundled into shaded JAR files Key: FLINK-6501 URL: https://issues.apache.org/jira/browse/FLINK-6501 Project: Flink Issue

[jira] [Created] (FLINK-6489) Rework 'start-local.bat' to 'start-local-cluster.bat'

Stephan Ewen created FLINK-6489: --- Summary: Rework 'start-local.bat' to 'start-local-cluster.bat' Key: FLINK-6489 URL: https://issues.apache.org/jira/browse/FLINK-6489 Project: Flink Issue

[jira] [Created] (FLINK-6488) Remove 'start-local.sh' script

Stephan Ewen created FLINK-6488: --- Summary: Remove 'start-local.sh' script Key: FLINK-6488 URL: https://issues.apache.org/jira/browse/FLINK-6488 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6487) Remove JobManager local mode

Stephan Ewen created FLINK-6487: --- Summary: Remove JobManager local mode Key: FLINK-6487 URL: https://issues.apache.org/jira/browse/FLINK-6487 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6469) Configure Memory Sizes via units

Stephan Ewen created FLINK-6469: --- Summary: Configure Memory Sizes via units Key: FLINK-6469 URL: https://issues.apache.org/jira/browse/FLINK-6469 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6455) Yarn single-job JobManagers should not allow uploads of new jobs.

Stephan Ewen created FLINK-6455: --- Summary: Yarn single-job JobManagers should not allow uploads of new jobs. Key: FLINK-6455 URL: https://issues.apache.org/jira/browse/FLINK-6455 Project: Flink

[jira] [Created] (FLINK-6454) Add more permission settings to the web UI

Stephan Ewen created FLINK-6454: --- Summary: Add more permission settings to the web UI Key: FLINK-6454 URL: https://issues.apache.org/jira/browse/FLINK-6454 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6453) Web UI metrics charts should update only when a new data point is available

Stephan Ewen created FLINK-6453: --- Summary: Web UI metrics charts should update only when a new data point is available Key: FLINK-6453 URL: https://issues.apache.org/jira/browse/FLINK-6453 Project:

[jira] [Created] (FLINK-6452) Structure Metrics menu in Web UI

Stephan Ewen created FLINK-6452: --- Summary: Structure Metrics menu in Web UI Key: FLINK-6452 URL: https://issues.apache.org/jira/browse/FLINK-6452 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6451) Web UI: Rename 'Metrics' view to 'Task Metrics'

Stephan Ewen created FLINK-6451: --- Summary: Web UI: Rename 'Metrics' view to 'Task Metrics' Key: FLINK-6451 URL: https://issues.apache.org/jira/browse/FLINK-6451 Project: Flink Issue Type:

[jira] [Created] (FLINK-6450) Web UI Subtasks view for TaskManagers has a misleading name

Stephan Ewen created FLINK-6450: --- Summary: Web UI Subtasks view for TaskManagers has a misleading name Key: FLINK-6450 URL: https://issues.apache.org/jira/browse/FLINK-6450 Project: Flink

[jira] [Created] (FLINK-6449) Add a Web UI view for job-level metrics

Stephan Ewen created FLINK-6449: --- Summary: Add a Web UI view for job-level metrics Key: FLINK-6449 URL: https://issues.apache.org/jira/browse/FLINK-6449 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

Stephan Ewen created FLINK-6448: --- Summary: Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' Key: FLINK-6448 URL: https://issues.apache.org/jira/browse/FLINK-6448 Project: Flink

[jira] [Created] (FLINK-6446) Various improvements to the Web Frontend

Stephan Ewen created FLINK-6446: --- Summary: Various improvements to the Web Frontend Key: FLINK-6446 URL: https://issues.apache.org/jira/browse/FLINK-6446 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

Stephan Ewen created FLINK-6444: --- Summary: Add a check that '@VisibleForTesting' methods are only used in tests Key: FLINK-6444 URL: https://issues.apache.org/jira/browse/FLINK-6444 Project: Flink

[jira] [Created] (FLINK-6440) Noisy logs from metric fetcher

Stephan Ewen created FLINK-6440: --- Summary: Noisy logs from metric fetcher Key: FLINK-6440 URL: https://issues.apache.org/jira/browse/FLINK-6440 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6437) Move history server configuration to a separate file

Stephan Ewen created FLINK-6437: --- Summary: Move history server configuration to a separate file Key: FLINK-6437 URL: https://issues.apache.org/jira/browse/FLINK-6437 Project: Flink Issue Type:

[jira] [Created] (FLINK-6415) Make sure Flink artifacts have no specific logger dependency

Stephan Ewen created FLINK-6415: --- Summary: Make sure Flink artifacts have no specific logger dependency Key: FLINK-6415 URL: https://issues.apache.org/jira/browse/FLINK-6415 Project: Flink

[jira] [Created] (FLINK-6410) build fails after changing Scala to 2.11

Stephan Ewen created FLINK-6410: --- Summary: build fails after changing Scala to 2.11 Key: FLINK-6410 URL: https://issues.apache.org/jira/browse/FLINK-6410 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6404) Ensure PendingCheckpoint is registered when calling Checkpoint Hooks

Stephan Ewen created FLINK-6404: --- Summary: Ensure PendingCheckpoint is registered when calling Checkpoint Hooks Key: FLINK-6404 URL: https://issues.apache.org/jira/browse/FLINK-6404 Project: Flink

[jira] [Created] (FLINK-6390) Add Trigger Hooks to the Checkpoint Coordinator

Stephan Ewen created FLINK-6390: --- Summary: Add Trigger Hooks to the Checkpoint Coordinator Key: FLINK-6390 URL: https://issues.apache.org/jira/browse/FLINK-6390 Project: Flink Issue Type: New

[jira] [Created] (FLINK-6340) Introduce a TerminationFuture for Execution

Stephan Ewen created FLINK-6340: --- Summary: Introduce a TerminationFuture for Execution Key: FLINK-6340 URL: https://issues.apache.org/jira/browse/FLINK-6340 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6339) Remove useless and unused class ConnectorSource

Stephan Ewen created FLINK-6339: --- Summary: Remove useless and unused class ConnectorSource Key: FLINK-6339 URL: https://issues.apache.org/jira/browse/FLINK-6339 Project: Flink Issue Type:

[jira] [Created] (FLINK-6338) SimpleStringUtils should be called StringValueUtils

Stephan Ewen created FLINK-6338: --- Summary: SimpleStringUtils should be called StringValueUtils Key: FLINK-6338 URL: https://issues.apache.org/jira/browse/FLINK-6338 Project: Flink Issue Type:

[jira] [Created] (FLINK-6328) Savepoints must not be counted as retained checkpoints

Stephan Ewen created FLINK-6328: --- Summary: Savepoints must not be counted as retained checkpoints Key: FLINK-6328 URL: https://issues.apache.org/jira/browse/FLINK-6328 Project: Flink Issue

[jira] [Created] (FLINK-6071) Savepoints should not count in the number of retained checkpoints

Stephan Ewen created FLINK-6071: --- Summary: Savepoints should not count in the number of retained checkpoints Key: FLINK-6071 URL: https://issues.apache.org/jira/browse/FLINK-6071 Project: Flink

[jira] [Created] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

Stephan Ewen created FLINK-5908: --- Summary: Blob Cache can (rarely) get corrupted on failed blob downloads Key: FLINK-5908 URL: https://issues.apache.org/jira/browse/FLINK-5908 Project: Flink

[jira] [Created] (FLINK-5897) Untie Checkpoint Externalization from FileSystems

Stephan Ewen created FLINK-5897: --- Summary: Untie Checkpoint Externalization from FileSystems Key: FLINK-5897 URL: https://issues.apache.org/jira/browse/FLINK-5897 Project: Flink Issue Type:

[jira] [Created] (FLINK-5895) Reduce logging aggressiveness of FileSystemSafetyNet

Stephan Ewen created FLINK-5895: --- Summary: Reduce logging aggressiveness of FileSystemSafetyNet Key: FLINK-5895 URL: https://issues.apache.org/jira/browse/FLINK-5895 Project: Flink Issue Type:

[jira] [Created] (FLINK-5887) Make CheckpointBarrier type immutable

Stephan Ewen created FLINK-5887: --- Summary: Make CheckpointBarrier type immutable Key: FLINK-5887 URL: https://issues.apache.org/jira/browse/FLINK-5887 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5854) Introduce some Flink-specific base Exception types

Stephan Ewen created FLINK-5854: --- Summary: Introduce some Flink-specific base Exception types Key: FLINK-5854 URL: https://issues.apache.org/jira/browse/FLINK-5854 Project: Flink Issue Type:

[jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

Stephan Ewen created FLINK-5823: --- Summary: Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Key: FLINK-5823 URL: https://issues.apache.org/jira/browse/FLINK-5823 Project: Flink

[jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend

Stephan Ewen created FLINK-5822: --- Summary: Make Checkpoint Coordinator aware of State Backend Key: FLINK-5822 URL: https://issues.apache.org/jira/browse/FLINK-5822 Project: Flink Issue Type:

[jira] [Created] (FLINK-5821) Create StateBackend root interface

Stephan Ewen created FLINK-5821: --- Summary: Create StateBackend root interface Key: FLINK-5821 URL: https://issues.apache.org/jira/browse/FLINK-5821 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

Stephan Ewen created FLINK-5820: --- Summary: Extend State Backend Abstraction to support Global Cleanup Hooks Key: FLINK-5820 URL: https://issues.apache.org/jira/browse/FLINK-5820 Project: Flink

[jira] [Created] (FLINK-5800) Make sure that the CheckpointStreamFactory is instantiated once per operator only

Stephan Ewen created FLINK-5800: --- Summary: Make sure that the CheckpointStreamFactory is instantiated once per operator only Key: FLINK-5800 URL: https://issues.apache.org/jira/browse/FLINK-5800

[jira] [Created] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSysten

Stephan Ewen created FLINK-5789: --- Summary: Make Bucketing Sink independent of Hadoop's FileSysten Key: FLINK-5789 URL: https://issues.apache.org/jira/browse/FLINK-5789 Project: Flink Issue

[jira] [Created] (FLINK-5788) Document assumptions about File Systems and persistence

Stephan Ewen created FLINK-5788: --- Summary: Document assumptions about File Systems and persistence Key: FLINK-5788 URL: https://issues.apache.org/jira/browse/FLINK-5788 Project: Flink Issue

[jira] [Created] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

Stephan Ewen created FLINK-5766: --- Summary: Unify NoAvailableResourceException handling on ExecutionGraph Key: FLINK-5766 URL: https://issues.apache.org/jira/browse/FLINK-5766 Project: Flink

[jira] [Created] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

Stephan Ewen created FLINK-5759: --- Summary: Set an UncaughtExceptionHandler for all Thread Pools in JobManager Key: FLINK-5759 URL: https://issues.apache.org/jira/browse/FLINK-5759 Project: Flink

[jira] [Created] (FLINK-5748) Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService

Stephan Ewen created FLINK-5748: --- Summary: Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService Key: FLINK-5748 URL: https://issues.apache.org/jira/browse/FLINK-5748 Project: Flink

[jira] [Created] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

Stephan Ewen created FLINK-5718: --- Summary: Handle JVM Fatal Exceptions in Tasks Key: FLINK-5718 URL: https://issues.apache.org/jira/browse/FLINK-5718 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5706) Implement Flink's own S3 filesystem

Stephan Ewen created FLINK-5706: --- Summary: Implement Flink's own S3 filesystem Key: FLINK-5706 URL: https://issues.apache.org/jira/browse/FLINK-5706 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5639) Clarify License implications of RabbitMQ Connector

Stephan Ewen created FLINK-5639: --- Summary: Clarify License implications of RabbitMQ Connector Key: FLINK-5639 URL: https://issues.apache.org/jira/browse/FLINK-5639 Project: Flink Issue Type:

[jira] [Created] (FLINK-5630) Followups to AggregationFunction

Stephan Ewen created FLINK-5630: --- Summary: Followups to AggregationFunction Key: FLINK-5630 URL: https://issues.apache.org/jira/browse/FLINK-5630 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5590) Create a proper internal state hierarchy

Stephan Ewen created FLINK-5590: --- Summary: Create a proper internal state hierarchy Key: FLINK-5590 URL: https://issues.apache.org/jira/browse/FLINK-5590 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5585) NullPointer Exception in JobManager.updateAccumulators

Stephan Ewen created FLINK-5585: --- Summary: NullPointer Exception in JobManager.updateAccumulators Key: FLINK-5585 URL: https://issues.apache.org/jira/browse/FLINK-5585 Project: Flink Issue

[jira] [Created] (FLINK-5582) Add a general distributive aggregate function

Stephan Ewen created FLINK-5582: --- Summary: Add a general distributive aggregate function Key: FLINK-5582 URL: https://issues.apache.org/jira/browse/FLINK-5582 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5529) Improve / extends windowing documentation

Stephan Ewen created FLINK-5529: --- Summary: Improve / extends windowing documentation Key: FLINK-5529 URL: https://issues.apache.org/jira/browse/FLINK-5529 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5460) Add documentation how to use Flink with Docker

Stephan Ewen created FLINK-5460: --- Summary: Add documentation how to use Flink with Docker Key: FLINK-5460 URL: https://issues.apache.org/jira/browse/FLINK-5460 Project: Flink Issue Type:

[jira] [Created] (FLINK-5459) Add documentation how to debug classloading and event time issues

Stephan Ewen created FLINK-5459: --- Summary: Add documentation how to debug classloading and event time issues Key: FLINK-5459 URL: https://issues.apache.org/jira/browse/FLINK-5459 Project: Flink

[jira] [Created] (FLINK-5457) Create documentation for Asynchronous I/O

Stephan Ewen created FLINK-5457: --- Summary: Create documentation for Asynchronous I/O Key: FLINK-5457 URL: https://issues.apache.org/jira/browse/FLINK-5457 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5456) Add docs about new state and checkpointing interfaces

Stephan Ewen created FLINK-5456: --- Summary: Add docs about new state and checkpointing interfaces Key: FLINK-5456 URL: https://issues.apache.org/jira/browse/FLINK-5456 Project: Flink Issue

[jira] [Created] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions

Stephan Ewen created FLINK-5455: --- Summary: Create documentation how to upgrade jobs and Flink framework versions Key: FLINK-5455 URL: https://issues.apache.org/jira/browse/FLINK-5455 Project: Flink

[jira] [Created] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state

Stephan Ewen created FLINK-5454: --- Summary: Add Documentation about how to tune Checkpointing for large state Key: FLINK-5454 URL: https://issues.apache.org/jira/browse/FLINK-5454 Project: Flink

[jira] [Created] (FLINK-5430) Bring documentation up to speed for current feature set

Stephan Ewen created FLINK-5430: --- Summary: Bring documentation up to speed for current feature set Key: FLINK-5430 URL: https://issues.apache.org/jira/browse/FLINK-5430 Project: Flink Issue

[jira] [Created] (FLINK-5408) RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

Stephan Ewen created FLINK-5408: --- Summary: RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders Key: FLINK-5408 URL: https://issues.apache.org/jira/browse/FLINK-5408

[jira] [Created] (FLINK-5407) Savepoint for iterative Task fails.

Stephan Ewen created FLINK-5407: --- Summary: Savepoint for iterative Task fails. Key: FLINK-5407 URL: https://issues.apache.org/jira/browse/FLINK-5407 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5369) jsr305 and logging dependencies should be 'provided' by default

Stephan Ewen created FLINK-5369: --- Summary: jsr305 and logging dependencies should be 'provided' by default Key: FLINK-5369 URL: https://issues.apache.org/jira/browse/FLINK-5369 Project: Flink

[jira] [Created] (FLINK-5352) Restore RocksDB 1.1.3 memory behavior

Stephan Ewen created FLINK-5352: --- Summary: Restore RocksDB 1.1.3 memory behavior Key: FLINK-5352 URL: https://issues.apache.org/jira/browse/FLINK-5352 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5338) Make printing sinks non-parallel

Stephan Ewen created FLINK-5338: --- Summary: Make printing sinks non-parallel Key: FLINK-5338 URL: https://issues.apache.org/jira/browse/FLINK-5338 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5336) Make Path immutable

Stephan Ewen created FLINK-5336: --- Summary: Make Path immutable Key: FLINK-5336 URL: https://issues.apache.org/jira/browse/FLINK-5336 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution

Stephan Ewen created FLINK-5332: --- Summary: Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution Key: FLINK-5332 URL: https://issues.apache.org/jira/browse/FLINK-5332

[jira] [Created] (FLINK-5310) Harden the RocksDB JNI library loading

Stephan Ewen created FLINK-5310: --- Summary: Harden the RocksDB JNI library loading Key: FLINK-5310 URL: https://issues.apache.org/jira/browse/FLINK-5310 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5253) Remove special treatment of "dynamic properties"

Stephan Ewen created FLINK-5253: --- Summary: Remove special treatment of "dynamic properties" Key: FLINK-5253 URL: https://issues.apache.org/jira/browse/FLINK-5253 Project: Flink Issue Type:

[jira] [Created] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions

Stephan Ewen created FLINK-5252: --- Summary: Migrate all YARN related configurations to ConfigOptions Key: FLINK-5252 URL: https://issues.apache.org/jira/browse/FLINK-5252 Project: Flink Issue

[jira] [Created] (FLINK-5239) Properly unpack thrown exceptions in RPC methods

Stephan Ewen created FLINK-5239: --- Summary: Properly unpack thrown exceptions in RPC methods Key: FLINK-5239 URL: https://issues.apache.org/jira/browse/FLINK-5239 Project: Flink Issue Type:

[jira] [Created] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager

Stephan Ewen created FLINK-5238: --- Summary: Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager Key: FLINK-5238 URL: https://issues.apache.org/jira/browse/FLINK-5238

[jira] [Created] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager

Stephan Ewen created FLINK-5232: --- Summary: Add a Thread default uncaught exception handler on the JobManager Key: FLINK-5232 URL: https://issues.apache.org/jira/browse/FLINK-5232 Project: Flink

[jira] [Created] (FLINK-5231) JobManager should exit on "OutOfMemoryError"

Stephan Ewen created FLINK-5231: --- Summary: JobManager should exit on "OutOfMemoryError" Key: FLINK-5231 URL: https://issues.apache.org/jira/browse/FLINK-5231 Project: Flink Issue Type:

[jira] [Created] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers

Stephan Ewen created FLINK-5230: --- Summary: Safety nets against leaving dysfunctional JobManagers Key: FLINK-5230 URL: https://issues.apache.org/jira/browse/FLINK-5230 Project: Flink Issue

[jira] [Created] (FLINK-5218) Eagerly close checkpoint streams on cancellation

Stephan Ewen created FLINK-5218: --- Summary: Eagerly close checkpoint streams on cancellation Key: FLINK-5218 URL: https://issues.apache.org/jira/browse/FLINK-5218 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

Stephan Ewen created FLINK-5216: --- Summary: CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion Key: FLINK-5216 URL:

[jira] [Created] (FLINK-5173) Upgrade RocksDB dependency

Stephan Ewen created FLINK-5173: --- Summary: Upgrade RocksDB dependency Key: FLINK-5173 URL: https://issues.apache.org/jira/browse/FLINK-5173 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided"

Stephan Ewen created FLINK-5172: --- Summary: In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" Key: FLINK-5172 URL: https://issues.apache.org/jira/browse/FLINK-5172 Project:

[jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs.

Stephan Ewen created FLINK-5123: --- Summary: Add description how to do proper shading to Flink docs. Key: FLINK-5123 URL: https://issues.apache.org/jira/browse/FLINK-5123 Project: Flink Issue

[jira] [Created] (FLINK-5090) Expose optionally detailed metrics about network queue lengths

Stephan Ewen created FLINK-5090: --- Summary: Expose optionally detailed metrics about network queue lengths Key: FLINK-5090 URL: https://issues.apache.org/jira/browse/FLINK-5090 Project: Flink

[jira] [Created] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

Stephan Ewen created FLINK-5048: --- Summary: Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Key: FLINK-5048 URL: https://issues.apache.org/jira/browse/FLINK-5048

[jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early

Stephan Ewen created FLINK-5038: --- Summary: Errors in the "cancelTask" method prevent closeables from being closed early Key: FLINK-5038 URL: https://issues.apache.org/jira/browse/FLINK-5038 Project:

[jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation

Stephan Ewen created FLINK-5028: --- Summary: Stream Tasks must not go through clean shutdown logic on cancellation Key: FLINK-5028 URL: https://issues.apache.org/jira/browse/FLINK-5028 Project: Flink

[jira] [Created] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator

Stephan Ewen created FLINK-4985: --- Summary: Report Declined/Canceled Checkpoints to Checkpoint Coordinator Key: FLINK-4985 URL: https://issues.apache.org/jira/browse/FLINK-4985 Project: Flink

[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

[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-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-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

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

[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

<    1   2   3   4   5   6   7   8   >