[jira] [Created] (FLINK-11617) CLONE - Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

Jamie Grier created FLINK-11617: --- Summary: CLONE - Handle AmazonKinesisException gracefully in Kinesis Streaming Connector Key: FLINK-11617 URL: https://issues.apache.org/jira/browse/FLINK-11617 Project

[jira] [Created] (FLINK-10888) Expose new global watermark RPC to sources

Jamie Grier created FLINK-10888: --- Summary: Expose new global watermark RPC to sources Key: FLINK-10888 URL: https://issues.apache.org/jira/browse/FLINK-10888 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10887) Add source watermarking tracking to the JobMaster

Jamie Grier created FLINK-10887: --- Summary: Add source watermarking tracking to the JobMaster Key: FLINK-10887 URL: https://issues.apache.org/jira/browse/FLINK-10887 Project: Flink Issue Type: S

[jira] [Created] (FLINK-10886) Event time synchronization across sources

Jamie Grier created FLINK-10886: --- Summary: Event time synchronization across sources Key: FLINK-10886 URL: https://issues.apache.org/jira/browse/FLINK-10886 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-10484) New latency tracking metrics format causes metrics cardinality explosion

Jamie Grier created FLINK-10484: --- Summary: New latency tracking metrics format causes metrics cardinality explosion Key: FLINK-10484 URL: https://issues.apache.org/jira/browse/FLINK-10484 Project: Flink

[jira] [Created] (FLINK-10154) Make sure we always read at least one record in KinesisConnector

Jamie Grier created FLINK-10154: --- Summary: Make sure we always read at least one record in KinesisConnector Key: FLINK-10154 URL: https://issues.apache.org/jira/browse/FLINK-10154 Project: Flink

[jira] [Created] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

Jamie Grier created FLINK-9061: -- Summary: S3 checkpoint data not partitioned well -- causes errors and poor performance Key: FLINK-9061 URL: https://issues.apache.org/jira/browse/FLINK-9061 Project: Flin

[jira] [Created] (FLINK-6199) Single outstanding Async I/O operation per key

Jamie Grier created FLINK-6199: -- Summary: Single outstanding Async I/O operation per key Key: FLINK-6199 URL: https://issues.apache.org/jira/browse/FLINK-6199 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

Jamie Grier created FLINK-5635: -- Summary: Improve Docker tooling to make it easier to build images and launch Flink via Docker tools Key: FLINK-5635 URL: https://issues.apache.org/jira/browse/FLINK-5635

[jira] [Created] (FLINK-5634) Flink should not always redirect stdout to a file.

Jamie Grier created FLINK-5634: -- Summary: Flink should not always redirect stdout to a file. Key: FLINK-5634 URL: https://issues.apache.org/jira/browse/FLINK-5634 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4980) Include example source code in Flink binary distribution

Jamie Grier created FLINK-4980: -- Summary: Include example source code in Flink binary distribution Key: FLINK-4980 URL: https://issues.apache.org/jira/browse/FLINK-4980 Project: Flink Issue Type

[jira] [Created] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints

Jamie Grier created FLINK-4948: -- Summary: Consider using checksums or similar to detect bad checkpoints Key: FLINK-4948 URL: https://issues.apache.org/jira/browse/FLINK-4948 Project: Flink Issu

[jira] [Created] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

Jamie Grier created FLINK-4947: -- Summary: Make all configuration possible via flink-conf.yaml and CLI. Key: FLINK-4947 URL: https://issues.apache.org/jira/browse/FLINK-4947 Project: Flink Issue

[jira] [Created] (FLINK-4391) Provide support for asynchronous operations over streams

Jamie Grier created FLINK-4391: -- Summary: Provide support for asynchronous operations over streams Key: FLINK-4391 URL: https://issues.apache.org/jira/browse/FLINK-4391 Project: Flink Issue Type

[jira] [Created] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

Jamie Grier created FLINK-3680: -- Summary: Remove or improve (not set) text in the Job Plan UI Key: FLINK-3680 URL: https://issues.apache.org/jira/browse/FLINK-3680 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

Jamie Grier created FLINK-3679: -- Summary: DeserializationSchema should handle zero or more outputs for every input Key: FLINK-3679 URL: https://issues.apache.org/jira/browse/FLINK-3679 Project: Flink

[jira] [Created] (FLINK-3627) Task stuck on lock in StreamSource when cancelling

Jamie Grier created FLINK-3627: -- Summary: Task stuck on lock in StreamSource when cancelling Key: FLINK-3627 URL: https://issues.apache.org/jira/browse/FLINK-3627 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

Jamie Grier created FLINK-3617: -- Summary: NPE from CaseClassSerializer when dealing with null Option field Key: FLINK-3617 URL: https://issues.apache.org/jira/browse/FLINK-3617 Project: Flink I