[jira] [Created] (FLINK-2677) Add a general-purpose keyed-window operator

Stephan Ewen created FLINK-2677: --- Summary: Add a general-purpose keyed-window operator Key: FLINK-2677 URL: https://issues.apache.org/jira/browse/FLINK-2677 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

Stephan Ewen created FLINK-2683: --- Summary: Add utilities for heap-backed keyed state in time panes Key: FLINK-2683 URL: https://issues.apache.org/jira/browse/FLINK-2683 Project: Flink Issue

[jira] [Created] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

Stephan Ewen created FLINK-2646: --- Summary: Rich functions should provide a method "closeAfterFailure()" Key: FLINK-2646 URL: https://issues.apache.org/jira/browse/FLINK-2646 Project: Flink

[jira] [Created] (FLINK-2647) Stream operators need to differentiate between close() and dispose()

Stephan Ewen created FLINK-2647: --- Summary: Stream operators need to differentiate between close() and dispose() Key: FLINK-2647 URL: https://issues.apache.org/jira/browse/FLINK-2647 Project: Flink

[jira] [Created] (FLINK-2635) Unify StreamInputProcessor and OneInputStreamTask

Stephan Ewen created FLINK-2635: --- Summary: Unify StreamInputProcessor and OneInputStreamTask Key: FLINK-2635 URL: https://issues.apache.org/jira/browse/FLINK-2635 Project: Flink Issue Type:

[jira] [Created] (FLINK-2636) Clean up StreamRecord and Watermark types

Stephan Ewen created FLINK-2636: --- Summary: Clean up StreamRecord and Watermark types Key: FLINK-2636 URL: https://issues.apache.org/jira/browse/FLINK-2636 Project: Flink Issue Type:

[jira] [Created] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script

Stephan Ewen created FLINK-2641: --- Summary: Integrate the off-heap memory configuration with the TaskManager start script Key: FLINK-2641 URL: https://issues.apache.org/jira/browse/FLINK-2641 Project:

[jira] [Created] (FLINK-2640) Integrate the off-heap configurations with YARN runner

Stephan Ewen created FLINK-2640: --- Summary: Integrate the off-heap configurations with YARN runner Key: FLINK-2640 URL: https://issues.apache.org/jira/browse/FLINK-2640 Project: Flink Issue

[jira] [Created] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method

Stephan Ewen created FLINK-2638: --- Summary: Add @SafeVarargs to the environment.fromElements(...) method Key: FLINK-2638 URL: https://issues.apache.org/jira/browse/FLINK-2638 Project: Flink

[jira] [Created] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

Stephan Ewen created FLINK-2624: --- Summary: RabbitMQ source / sink should participate in checkpointing Key: FLINK-2624 URL: https://issues.apache.org/jira/browse/FLINK-2624 Project: Flink Issue

[jira] [Created] (FLINK-2586) Unstable Storm Compatibility Tests

Stephan Ewen created FLINK-2586: --- Summary: Unstable Storm Compatibility Tests Key: FLINK-2586 URL: https://issues.apache.org/jira/browse/FLINK-2586 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2554) Add exception reporting handler

Stephan Ewen created FLINK-2554: --- Summary: Add exception reporting handler Key: FLINK-2554 URL: https://issues.apache.org/jira/browse/FLINK-2554 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2547) Provide Cluster Status Info

Stephan Ewen created FLINK-2547: --- Summary: Provide Cluster Status Info Key: FLINK-2547 URL: https://issues.apache.org/jira/browse/FLINK-2547 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2520) StreamFaultToleranceTestBase does not allow for multiple tests

Stephan Ewen created FLINK-2520: --- Summary: StreamFaultToleranceTestBase does not allow for multiple tests Key: FLINK-2520 URL: https://issues.apache.org/jira/browse/FLINK-2520 Project: Flink

[jira] [Created] (FLINK-2524) Add getTaskNameWithSubtasks() to RuntimeContext

Stephan Ewen created FLINK-2524: --- Summary: Add getTaskNameWithSubtasks() to RuntimeContext Key: FLINK-2524 URL: https://issues.apache.org/jira/browse/FLINK-2524 Project: Flink Issue Type:

[jira] [Created] (FLINK-2519) BarrierBuffers get stuck infinitely when some inputs end early

Stephan Ewen created FLINK-2519: --- Summary: BarrierBuffers get stuck infinitely when some inputs end early Key: FLINK-2519 URL: https://issues.apache.org/jira/browse/FLINK-2519 Project: Flink

[jira] [Created] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more

Stephan Ewen created FLINK-2515: --- Summary: CheckpointCoordinator triggers checkpoints even if not all sources are running any more Key: FLINK-2515 URL: https://issues.apache.org/jira/browse/FLINK-2515

[jira] [Created] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

Stephan Ewen created FLINK-2508: --- Summary: Confusing sharing of StreamExecutionEnvironment Key: FLINK-2508 URL: https://issues.apache.org/jira/browse/FLINK-2508 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2509) Improve error messages when user code classes are not found

Stephan Ewen created FLINK-2509: --- Summary: Improve error messages when user code classes are not found Key: FLINK-2509 URL: https://issues.apache.org/jira/browse/FLINK-2509 Project: Flink

[jira] [Created] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

Stephan Ewen created FLINK-2510: --- Summary: KafkaConnector should access partition metadata from master/cluster Key: FLINK-2510 URL: https://issues.apache.org/jira/browse/FLINK-2510 Project: Flink

[jira] [Created] (FLINK-2492) Rename remaining runtime classes from match to join

Stephan Ewen created FLINK-2492: --- Summary: Rename remaining runtime classes from match to join Key: FLINK-2492 URL: https://issues.apache.org/jira/browse/FLINK-2492 Project: Flink Issue Type:

[jira] [Created] (FLINK-2493) Simplify names of example program JARs

Stephan Ewen created FLINK-2493: --- Summary: Simplify names of example program JARs Key: FLINK-2493 URL: https://issues.apache.org/jira/browse/FLINK-2493 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

Stephan Ewen created FLINK-2474: --- Summary: Occasional failures in PartitionedStateCheckpointingITCase Key: FLINK-2474 URL: https://issues.apache.org/jira/browse/FLINK-2474 Project: Flink Issue

[jira] [Created] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client

Stephan Ewen created FLINK-2473: --- Summary: Add a timeout to ActorSystem shutdown in the Client Key: FLINK-2473 URL: https://issues.apache.org/jira/browse/FLINK-2473 Project: Flink Issue Type:

[jira] [Created] (FLINK-2463) Chow execution config in dashboard

Stephan Ewen created FLINK-2463: --- Summary: Chow execution config in dashboard Key: FLINK-2463 URL: https://issues.apache.org/jira/browse/FLINK-2463 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2438) Improve performance of channel events

Stephan Ewen created FLINK-2438: --- Summary: Improve performance of channel events Key: FLINK-2438 URL: https://issues.apache.org/jira/browse/FLINK-2438 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2426) Create a read-only variant of the Configuration

Stephan Ewen created FLINK-2426: --- Summary: Create a read-only variant of the Configuration Key: FLINK-2426 URL: https://issues.apache.org/jira/browse/FLINK-2426 Project: Flink Issue Type:

[jira] [Created] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs

Stephan Ewen created FLINK-2427: --- Summary: Allow the BarrierBuffer to maintain multiple queues of blocked inputs Key: FLINK-2427 URL: https://issues.apache.org/jira/browse/FLINK-2427 Project: Flink

[jira] [Created] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment

Stephan Ewen created FLINK-2425: --- Summary: Give access to TaskManager config and hostname in the Runtime Environment Key: FLINK-2425 URL: https://issues.apache.org/jira/browse/FLINK-2425 Project: Flink

[jira] [Created] (FLINK-2428) Clean up unused properties in StreamConfig

Stephan Ewen created FLINK-2428: --- Summary: Clean up unused properties in StreamConfig Key: FLINK-2428 URL: https://issues.apache.org/jira/browse/FLINK-2428 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2429) Remove the enableCheckpointing() without interval variant

Stephan Ewen created FLINK-2429: --- Summary: Remove the enableCheckpointing() without interval variant Key: FLINK-2429 URL: https://issues.apache.org/jira/browse/FLINK-2429 Project: Flink Issue

[jira] [Created] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface

Stephan Ewen created FLINK-2418: --- Summary: Add an end-to-end streaming fault tolerance test for the Checkpointed interface Key: FLINK-2418 URL: https://issues.apache.org/jira/browse/FLINK-2418

[jira] [Created] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests

Stephan Ewen created FLINK-2421: --- Summary: StreamRecordSerializer incorrectly duplicates and misses tests Key: FLINK-2421 URL: https://issues.apache.org/jira/browse/FLINK-2421 Project: Flink

[jira] [Created] (FLINK-2407) Add an API switch to select between exactly once and at least once fault tolerance

Stephan Ewen created FLINK-2407: --- Summary: Add an API switch to select between exactly once and at least once fault tolerance Key: FLINK-2407 URL: https://issues.apache.org/jira/browse/FLINK-2407

[jira] [Created] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

Stephan Ewen created FLINK-2406: --- Summary: Abstract BarrierBuffer to an exchangeable BarrierHandler Key: FLINK-2406 URL: https://issues.apache.org/jira/browse/FLINK-2406 Project: Flink Issue

[jira] [Created] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

Stephan Ewen created FLINK-2404: --- Summary: LongCounters should have an addValue() method for primitive longs Key: FLINK-2404 URL: https://issues.apache.org/jira/browse/FLINK-2404 Project: Flink

[jira] [Created] (FLINK-2402) Add a non-blocking BarrierTracker

Stephan Ewen created FLINK-2402: --- Summary: Add a non-blocking BarrierTracker Key: FLINK-2402 URL: https://issues.apache.org/jira/browse/FLINK-2402 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2397) Unify two backend servers to one server

Stephan Ewen created FLINK-2397: --- Summary: Unify two backend servers to one server Key: FLINK-2397 URL: https://issues.apache.org/jira/browse/FLINK-2397 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2393) Add a stateless at-least-once mode for streaming

Stephan Ewen created FLINK-2393: --- Summary: Add a stateless at-least-once mode for streaming Key: FLINK-2393 URL: https://issues.apache.org/jira/browse/FLINK-2393 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2385) Scala DataSet.distinct should have parenthesis

Stephan Ewen created FLINK-2385: --- Summary: Scala DataSet.distinct should have parenthesis Key: FLINK-2385 URL: https://issues.apache.org/jira/browse/FLINK-2385 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue

Stephan Ewen created FLINK-2389: --- Summary: Add dashboard frontend architecture amd build infrastructue Key: FLINK-2389 URL: https://issues.apache.org/jira/browse/FLINK-2389 Project: Flink

[jira] [Created] (FLINK-2357) New JobManager Runtime Web Frontend

Stephan Ewen created FLINK-2357: --- Summary: New JobManager Runtime Web Frontend Key: FLINK-2357 URL: https://issues.apache.org/jira/browse/FLINK-2357 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2358) Add Netty-HTTP based server and server handlers

Stephan Ewen created FLINK-2358: --- Summary: Add Netty-HTTP based server and server handlers Key: FLINK-2358 URL: https://issues.apache.org/jira/browse/FLINK-2358 Project: Flink Issue Type:

[jira] [Created] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

Stephan Ewen created FLINK-2351: --- Summary: Deprecate config builders in InputFormats and Output formats Key: FLINK-2351 URL: https://issues.apache.org/jira/browse/FLINK-2351 Project: Flink

[jira] [Created] (FLINK-2350) Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat

Stephan Ewen created FLINK-2350: --- Summary: Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat Key: FLINK-2350 URL: https://issues.apache.org/jira/browse/FLINK-2350 Project:

[jira] [Created] (FLINK-2343) Change default garbage collector in streaming environments

Stephan Ewen created FLINK-2343: --- Summary: Change default garbage collector in streaming environments Key: FLINK-2343 URL: https://issues.apache.org/jira/browse/FLINK-2343 Project: Flink Issue

[jira] [Created] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other

Stephan Ewen created FLINK-2339: --- Summary: Prevent asynchronous checkpoint calls from overtaking each other Key: FLINK-2339 URL: https://issues.apache.org/jira/browse/FLINK-2339 Project: Flink

[jira] [Created] (FLINK-2333) Stream Data Sink that periodically rolls files

Stephan Ewen created FLINK-2333: --- Summary: Stream Data Sink that periodically rolls files Key: FLINK-2333 URL: https://issues.apache.org/jira/browse/FLINK-2333 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2327) Log the limit of open file handles at startup

Stephan Ewen created FLINK-2327: --- Summary: Log the limit of open file handles at startup Key: FLINK-2327 URL: https://issues.apache.org/jira/browse/FLINK-2327 Project: Flink Issue Type:

[jira] [Created] (FLINK-2331) Whitelist some exceptions to be valid in YARN logs

Stephan Ewen created FLINK-2331: --- Summary: Whitelist some exceptions to be valid in YARN logs Key: FLINK-2331 URL: https://issues.apache.org/jira/browse/FLINK-2331 Project: Flink Issue Type:

[jira] [Created] (FLINK-2330) Make FromElementsFunction checkpointable

Stephan Ewen created FLINK-2330: --- Summary: Make FromElementsFunction checkpointable Key: FLINK-2330 URL: https://issues.apache.org/jira/browse/FLINK-2330 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2314) Make Streaming File Sources Persistent

Stephan Ewen created FLINK-2314: --- Summary: Make Streaming File Sources Persistent Key: FLINK-2314 URL: https://issues.apache.org/jira/browse/FLINK-2314 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

Stephan Ewen created FLINK-2315: --- Summary: Hadoop Writables cannot exploit implementing NormalizableKey Key: FLINK-2315 URL: https://issues.apache.org/jira/browse/FLINK-2315 Project: Flink

[jira] [Created] (FLINK-2284) Confusing/inconsistent PartitioningStrategy

Stephan Ewen created FLINK-2284: --- Summary: Confusing/inconsistent PartitioningStrategy Key: FLINK-2284 URL: https://issues.apache.org/jira/browse/FLINK-2284 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2270) Error in KafkaSource Documentation

Stephan Ewen created FLINK-2270: --- Summary: Error in KafkaSource Documentation Key: FLINK-2270 URL: https://issues.apache.org/jira/browse/FLINK-2270 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2231) Create a Serializer for Scala Enumerations

Stephan Ewen created FLINK-2231: --- Summary: Create a Serializer for Scala Enumerations Key: FLINK-2231 URL: https://issues.apache.org/jira/browse/FLINK-2231 Project: Flink Issue Type:

[jira] [Created] (FLINK-2177) NillPointer in task resource release

Stephan Ewen created FLINK-2177: --- Summary: NillPointer in task resource release Key: FLINK-2177 URL: https://issues.apache.org/jira/browse/FLINK-2177 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2130) RabbitMQ source does not fail when failing to retrieve elements

Stephan Ewen created FLINK-2130: --- Summary: RabbitMQ source does not fail when failing to retrieve elements Key: FLINK-2130 URL: https://issues.apache.org/jira/browse/FLINK-2130 Project: Flink

[jira] [Created] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

Stephan Ewen created FLINK-2098: --- Summary: Checkpoint barrier initiation at source is not aligned with snapshotting Key: FLINK-2098 URL: https://issues.apache.org/jira/browse/FLINK-2098 Project: Flink

[jira] [Created] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

Stephan Ewen created FLINK-2070: --- Summary: Confusing methods print() that print on client vs on TaskManager Key: FLINK-2070 URL: https://issues.apache.org/jira/browse/FLINK-2070 Project: Flink

[jira] [Created] (FLINK-2071) Projection function can fail non serializable

Stephan Ewen created FLINK-2071: --- Summary: Projection function can fail non serializable Key: FLINK-2071 URL: https://issues.apache.org/jira/browse/FLINK-2071 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2076) Bug in re-openable hash join

Stephan Ewen created FLINK-2076: --- Summary: Bug in re-openable hash join Key: FLINK-2076 URL: https://issues.apache.org/jira/browse/FLINK-2076 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2058) Hadoop Input Splits do not use proper UserCodeClassloader

Stephan Ewen created FLINK-2058: --- Summary: Hadoop Input Splits do not use proper UserCodeClassloader Key: FLINK-2058 URL: https://issues.apache.org/jira/browse/FLINK-2058 Project: Flink Issue

[jira] [Created] (FLINK-2057) Remove IOReadableWritable interface from input splits

Stephan Ewen created FLINK-2057: --- Summary: Remove IOReadableWritable interface from input splits Key: FLINK-2057 URL: https://issues.apache.org/jira/browse/FLINK-2057 Project: Flink Issue

[jira] [Created] (FLINK-2063) Streaming checkpoints consider only input and output vertices

Stephan Ewen created FLINK-2063: --- Summary: Streaming checkpoints consider only input and output vertices Key: FLINK-2063 URL: https://issues.apache.org/jira/browse/FLINK-2063 Project: Flink

[jira] [Created] (FLINK-2046) Quickstarts are missing on the new Website

Stephan Ewen created FLINK-2046: --- Summary: Quickstarts are missing on the new Website Key: FLINK-2046 URL: https://issues.apache.org/jira/browse/FLINK-2046 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2041) Optimizer plans with memory for pipeline breakers, even though they are not used any more

Stephan Ewen created FLINK-2041: --- Summary: Optimizer plans with memory for pipeline breakers, even though they are not used any more Key: FLINK-2041 URL: https://issues.apache.org/jira/browse/FLINK-2041

[jira] [Created] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed

Stephan Ewen created FLINK-2010: --- Summary: Add test that verifies that chained tasks are properly checkpointed Key: FLINK-2010 URL: https://issues.apache.org/jira/browse/FLINK-2010 Project: Flink

[jira] [Created] (FLINK-2011) Improve error message when user-defined serialization logic is wrong

Stephan Ewen created FLINK-2011: --- Summary: Improve error message when user-defined serialization logic is wrong Key: FLINK-2011 URL: https://issues.apache.org/jira/browse/FLINK-2011 Project: Flink

[jira] [Created] (FLINK-2004) Memory leack in presence of failed checkpoints in KafkaSource

Stephan Ewen created FLINK-2004: --- Summary: Memory leack in presence of failed checkpoints in KafkaSource Key: FLINK-2004 URL: https://issues.apache.org/jira/browse/FLINK-2004 Project: Flink

[jira] [Created] (FLINK-1969) Remove old profile code

Stephan Ewen created FLINK-1969: --- Summary: Remove old profile code Key: FLINK-1969 URL: https://issues.apache.org/jira/browse/FLINK-1969 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-1972) Remove instanceID in streaming tasks

Stephan Ewen created FLINK-1972: --- Summary: Remove instanceID in streaming tasks Key: FLINK-1972 URL: https://issues.apache.org/jira/browse/FLINK-1972 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1953) Rework Checkpoint Coordinator

Stephan Ewen created FLINK-1953: --- Summary: Rework Checkpoint Coordinator Key: FLINK-1953 URL: https://issues.apache.org/jira/browse/FLINK-1953 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1879) Simplify JobClient

Stephan Ewen created FLINK-1879: --- Summary: Simplify JobClient Key: FLINK-1879 URL: https://issues.apache.org/jira/browse/FLINK-1879 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator

Stephan Ewen created FLINK-1845: --- Summary: NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator Key: FLINK-1845 URL: https://issues.apache.org/jira/browse/FLINK-1845 Project: Flink

[jira] [Created] (FLINK-1839) Failures in TwitterStreamITCase

Stephan Ewen created FLINK-1839: --- Summary: Failures in TwitterStreamITCase Key: FLINK-1839 URL: https://issues.apache.org/jira/browse/FLINK-1839 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1801) NetworkEnvironment should start without JobManager association

Stephan Ewen created FLINK-1801: --- Summary: NetworkEnvironment should start without JobManager association Key: FLINK-1801 URL: https://issues.apache.org/jira/browse/FLINK-1801 Project: Flink

[jira] [Created] (FLINK-1802) BlobManager directories should be checked before TaskManager startup

Stephan Ewen created FLINK-1802: --- Summary: BlobManager directories should be checked before TaskManager startup Key: FLINK-1802 URL: https://issues.apache.org/jira/browse/FLINK-1802 Project: Flink

[jira] [Created] (FLINK-1760) Add support for building Flink with Scala 2.11

Stephan Ewen created FLINK-1760: --- Summary: Add support for building Flink with Scala 2.11 Key: FLINK-1760 URL: https://issues.apache.org/jira/browse/FLINK-1760 Project: Flink Issue Type:

[jira] [Created] (FLINK-1762) Make Statefulness of a Streaming Function explicit

Stephan Ewen created FLINK-1762: --- Summary: Make Statefulness of a Streaming Function explicit Key: FLINK-1762 URL: https://issues.apache.org/jira/browse/FLINK-1762 Project: Flink Issue Type:

[jira] [Created] (FLINK-1765) Reducer grouping is skippted when parallelism is one

Stephan Ewen created FLINK-1765: --- Summary: Reducer grouping is skippted when parallelism is one Key: FLINK-1765 URL: https://issues.apache.org/jira/browse/FLINK-1765 Project: Flink Issue Type:

[jira] [Created] (FLINK-1763) Remove cancel from streaming SinkFunction

Stephan Ewen created FLINK-1763: --- Summary: Remove cancel from streaming SinkFunction Key: FLINK-1763 URL: https://issues.apache.org/jira/browse/FLINK-1763 Project: Flink Issue Type:

[jira] [Created] (FLINK-1764) Rework record copying logic in streaming API

Stephan Ewen created FLINK-1764: --- Summary: Rework record copying logic in streaming API Key: FLINK-1764 URL: https://issues.apache.org/jira/browse/FLINK-1764 Project: Flink Issue Type:

[jira] [Created] (FLINK-1721) Flakey Yarn Tests

Stephan Ewen created FLINK-1721: --- Summary: Flakey Yarn Tests Key: FLINK-1721 URL: https://issues.apache.org/jira/browse/FLINK-1721 Project: Flink Issue Type: Bug Components: YARN

[jira] [Created] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set.

Stephan Ewen created FLINK-1730: --- Summary: Add a FlinkTools.persist style method to the Data Set. Key: FLINK-1730 URL: https://issues.apache.org/jira/browse/FLINK-1730 Project: Flink Issue

[jira] [Created] (FLINK-1712) Restructure Maven Projects

Stephan Ewen created FLINK-1712: --- Summary: Restructure Maven Projects Key: FLINK-1712 URL: https://issues.apache.org/jira/browse/FLINK-1712 Project: Flink Issue Type: Improvement Affects

[jira] [Created] (FLINK-1711) Replace all usages off commons.Validate with guava.check

Stephan Ewen created FLINK-1711: --- Summary: Replace all usages off commons.Validate with guava.check Key: FLINK-1711 URL: https://issues.apache.org/jira/browse/FLINK-1711 Project: Flink Issue

[jira] [Created] (FLINK-1705) InstanceConnectionInfo returns wrong hostname when no DNS entry exists

Stephan Ewen created FLINK-1705: --- Summary: InstanceConnectionInfo returns wrong hostname when no DNS entry exists Key: FLINK-1705 URL: https://issues.apache.org/jira/browse/FLINK-1705 Project: Flink

[jira] [Created] (FLINK-1691) Inprove CountCollectITCase

Stephan Ewen created FLINK-1691: --- Summary: Inprove CountCollectITCase Key: FLINK-1691 URL: https://issues.apache.org/jira/browse/FLINK-1691 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-1671) Add execution modes for programs

Stephan Ewen created FLINK-1671: --- Summary: Add execution modes for programs Key: FLINK-1671 URL: https://issues.apache.org/jira/browse/FLINK-1671 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-1675) Rework Accumulators

Stephan Ewen created FLINK-1675: --- Summary: Rework Accumulators Key: FLINK-1675 URL: https://issues.apache.org/jira/browse/FLINK-1675 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-1667) Add tests for recovery with distributed process failure

Stephan Ewen created FLINK-1667: --- Summary: Add tests for recovery with distributed process failure Key: FLINK-1667 URL: https://issues.apache.org/jira/browse/FLINK-1667 Project: Flink Issue

[jira] [Created] (FLINK-1668) Add a config option to specify delays between restarts

Stephan Ewen created FLINK-1668: --- Summary: Add a config option to specify delays between restarts Key: FLINK-1668 URL: https://issues.apache.org/jira/browse/FLINK-1668 Project: Flink Issue

[jira] [Created] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots

Stephan Ewen created FLINK-1648: --- Summary: Add a mode where the system automatically sets the parallelism to the available task slots Key: FLINK-1648 URL: https://issues.apache.org/jira/browse/FLINK-1648

[jira] [Created] (FLINK-1649) Give a good error message when a user program emits a null record

Stephan Ewen created FLINK-1649: --- Summary: Give a good error message when a user program emits a null record Key: FLINK-1649 URL: https://issues.apache.org/jira/browse/FLINK-1649 Project: Flink

[jira] [Created] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

Stephan Ewen created FLINK-1650: --- Summary: Suppress Akka's Netty Shutdown Errors through the log config Key: FLINK-1650 URL: https://issues.apache.org/jira/browse/FLINK-1650 Project: Flink

[jira] [Created] (FLINK-1626) Spurious failure in MatchTask cancelling test

Stephan Ewen created FLINK-1626: --- Summary: Spurious failure in MatchTask cancelling test Key: FLINK-1626 URL: https://issues.apache.org/jira/browse/FLINK-1626 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1631) Port collisions in ProcessReaping tests

Stephan Ewen created FLINK-1631: --- Summary: Port collisions in ProcessReaping tests Key: FLINK-1631 URL: https://issues.apache.org/jira/browse/FLINK-1631 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager

Stephan Ewen created FLINK-1608: --- Summary: TaskManagers may pick wrong network interface when starting before JobManager Key: FLINK-1608 URL: https://issues.apache.org/jira/browse/FLINK-1608 Project:

[jira] [Created] (FLINK-1598) Give better error messages when serializers run out of space.

Stephan Ewen created FLINK-1598: --- Summary: Give better error messages when serializers run out of space. Key: FLINK-1598 URL: https://issues.apache.org/jira/browse/FLINK-1598 Project: Flink

<    2   3   4   5   6   7   8   >