[jira] [Created] (FLINK-3030) Enhance Dashboard to show Execution Attempts

Stephan Ewen created FLINK-3030: --- Summary: Enhance Dashboard to show Execution Attempts Key: FLINK-3030 URL: https://issues.apache.org/jira/browse/FLINK-3030 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-3040) Add docs describing how to configure State Backends

Stephan Ewen created FLINK-3040: --- Summary: Add docs describing how to configure State Backends Key: FLINK-3040 URL: https://issues.apache.org/jira/browse/FLINK-3040 Project: Flink Issue Type: I

[jira] [Created] (FLINK-3042) Define a way to let types create their own TypeInformation

Stephan Ewen created FLINK-3042: --- Summary: Define a way to let types create their own TypeInformation Key: FLINK-3042 URL: https://issues.apache.org/jira/browse/FLINK-3042 Project: Flink Issue

[jira] [Created] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated

Stephan Ewen created FLINK-3043: --- Summary: Kafka Connector description in Streaming API guide is wrong/outdated Key: FLINK-3043 URL: https://issues.apache.org/jira/browse/FLINK-3043 Project: Flink

[jira] [Created] (FLINK-3044) In YARN mode, configure FsStateBackend by default.

Stephan Ewen created FLINK-3044: --- Summary: In YARN mode, configure FsStateBackend by default. Key: FLINK-3044 URL: https://issues.apache.org/jira/browse/FLINK-3044 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-3049) Move "Either" type to package "org.apache.flink.types"

Stephan Ewen created FLINK-3049: --- Summary: Move "Either" type to package "org.apache.flink.types" Key: FLINK-3049 URL: https://issues.apache.org/jira/browse/FLINK-3049 Project: Flink Issue Type

[jira] [Created] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints

Stephan Ewen created FLINK-3051: --- Summary: Define a maximum number of concurrent inflight checkpoints Key: FLINK-3051 URL: https://issues.apache.org/jira/browse/FLINK-3051 Project: Flink Issue

[jira] [Created] (FLINK-3069) Make state materialization asynchronous

Stephan Ewen created FLINK-3069: --- Summary: Make state materialization asynchronous Key: FLINK-3069 URL: https://issues.apache.org/jira/browse/FLINK-3069 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3070) Create an asynchronous state handle interface

Stephan Ewen created FLINK-3070: --- Summary: Create an asynchronous state handle interface Key: FLINK-3070 URL: https://issues.apache.org/jira/browse/FLINK-3070 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-3071) Add asynchronous materialization thread

Stephan Ewen created FLINK-3071: --- Summary: Add asynchronous materialization thread Key: FLINK-3071 URL: https://issues.apache.org/jira/browse/FLINK-3071 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling

Stephan Ewen created FLINK-3081: --- Summary: Kafka Periodic Offset Committer does not properly terminate on canceling Key: FLINK-3081 URL: https://issues.apache.org/jira/browse/FLINK-3081 Project: Flink

[jira] [Created] (FLINK-3083) Add docs how to configure streaming fault tolerance

Stephan Ewen created FLINK-3083: --- Summary: Add docs how to configure streaming fault tolerance Key: FLINK-3083 URL: https://issues.apache.org/jira/browse/FLINK-3083 Project: Flink Issue Type: I

[jira] [Created] (FLINK-3084) File State Backend should not write very small state into files

Stephan Ewen created FLINK-3084: --- Summary: File State Backend should not write very small state into files Key: FLINK-3084 URL: https://issues.apache.org/jira/browse/FLINK-3084 Project: Flink

[jira] [Created] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()"

Stephan Ewen created FLINK-3085: --- Summary: Move State Backend Initialization from "registerInputOutput()" to "invoke()" Key: FLINK-3085 URL: https://issues.apache.org/jira/browse/FLINK-3085 Project: Fli

[jira] [Created] (FLINK-3125) Web dashboard does not start when log files are not found

Stephan Ewen created FLINK-3125: --- Summary: Web dashboard does not start when log files are not found Key: FLINK-3125 URL: https://issues.apache.org/jira/browse/FLINK-3125 Project: Flink Issue T

[jira] [Created] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import

Stephan Ewen created FLINK-3136: --- Summary: Scala Closure Cleaner uses wrong ASM import Key: FLINK-3136 URL: https://issues.apache.org/jira/browse/FLINK-3136 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3138) Method References are not supported as lambda expressions

Stephan Ewen created FLINK-3138: --- Summary: Method References are not supported as lambda expressions Key: FLINK-3138 URL: https://issues.apache.org/jira/browse/FLINK-3138 Project: Flink Issue T

[jira] [Created] (FLINK-3169) Drop {{Key}} type from Record Data Model

Stephan Ewen created FLINK-3169: --- Summary: Drop {{Key}} type from Record Data Model Key: FLINK-3169 URL: https://issues.apache.org/jira/browse/FLINK-3169 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view

Stephan Ewen created FLINK-3171: --- Summary: Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view Key: FLINK-3171 URL: https://issues.apache.org/jira/browse/FLINK-3171 Proj

[jira] [Created] (FLINK-3194) Remove web client

Stephan Ewen created FLINK-3194: --- Summary: Remove web client Key: FLINK-3194 URL: https://issues.apache.org/jira/browse/FLINK-3194 Project: Flink Issue Type: Improvement Components: W

[jira] [Created] (FLINK-3195) Restructure examples projects and package streaming examples

Stephan Ewen created FLINK-3195: --- Summary: Restructure examples projects and package streaming examples Key: FLINK-3195 URL: https://issues.apache.org/jira/browse/FLINK-3195 Project: Flink Iss

[jira] [Created] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically

Stephan Ewen created FLINK-3213: --- Summary: Union of two streams with different parallelism should adjust parallelism automatically Key: FLINK-3213 URL: https://issues.apache.org/jira/browse/FLINK-3213 P

[jira] [Created] (FLINK-3236) Flink user code classloader should have Flink classloader as parent classloader

Stephan Ewen created FLINK-3236: --- Summary: Flink user code classloader should have Flink classloader as parent classloader Key: FLINK-3236 URL: https://issues.apache.org/jira/browse/FLINK-3236 Project:

[jira] [Created] (FLINK-3246) Consolidate maven project names with *-parent suffix

Stephan Ewen created FLINK-3246: --- Summary: Consolidate maven project names with *-parent suffix Key: FLINK-3246 URL: https://issues.apache.org/jira/browse/FLINK-3246 Project: Flink Issue Type:

[jira] [Created] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue

Stephan Ewen created FLINK-3247: --- Summary: Kafka Connector unusable with quickstarts - shading issue Key: FLINK-3247 URL: https://issues.apache.org/jira/browse/FLINK-3247 Project: Flink Issue T

[jira] [Created] (FLINK-3255) Chaining behavior should not depend on parallelism

Stephan Ewen created FLINK-3255: --- Summary: Chaining behavior should not depend on parallelism Key: FLINK-3255 URL: https://issues.apache.org/jira/browse/FLINK-3255 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-3260) ExecutionGraph gets stuck in state FAILING

Stephan Ewen created FLINK-3260: --- Summary: ExecutionGraph gets stuck in state FAILING Key: FLINK-3260 URL: https://issues.apache.org/jira/browse/FLINK-3260 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3261) Tasks should eagerly report back when they cannot start a checkpoint

Stephan Ewen created FLINK-3261: --- Summary: Tasks should eagerly report back when they cannot start a checkpoint Key: FLINK-3261 URL: https://issues.apache.org/jira/browse/FLINK-3261 Project: Flink

[jira] [Created] (FLINK-3267) Disable reference tracking in Kryo fallback serializer

Stephan Ewen created FLINK-3267: --- Summary: Disable reference tracking in Kryo fallback serializer Key: FLINK-3267 URL: https://issues.apache.org/jira/browse/FLINK-3267 Project: Flink Issue Type

[jira] [Created] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase

Stephan Ewen created FLINK-3268: --- Summary: Unstable test JobManagerSubmittedJobGraphsRecoveryITCase Key: FLINK-3268 URL: https://issues.apache.org/jira/browse/FLINK-3268 Project: Flink Issue Ty

[jira] [Created] (FLINK-3286) Remove JDEB Debian Package code from flink-dist

Stephan Ewen created FLINK-3286: --- Summary: Remove JDEB Debian Package code from flink-dist Key: FLINK-3286 URL: https://issues.apache.org/jira/browse/FLINK-3286 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3300) Concurrency Bug in Yarn JobManager

Stephan Ewen created FLINK-3300: --- Summary: Concurrency Bug in Yarn JobManager Key: FLINK-3300 URL: https://issues.apache.org/jira/browse/FLINK-3300 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core

Stephan Ewen created FLINK-3303: --- Summary: Move all non-batch specific classes in flink-java to flink-core Key: FLINK-3303 URL: https://issues.apache.org/jira/browse/FLINK-3303 Project: Flink

[jira] [Created] (FLINK-3305) Remove JavaKaffee serializer util

Stephan Ewen created FLINK-3305: --- Summary: Remove JavaKaffee serializer util Key: FLINK-3305 URL: https://issues.apache.org/jira/browse/FLINK-3305 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3306) Auto type registration at Kryo is buggy

Stephan Ewen created FLINK-3306: --- Summary: Auto type registration at Kryo is buggy Key: FLINK-3306 URL: https://issues.apache.org/jira/browse/FLINK-3306 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3312) Add convenience accessor methods for extended state interface

Stephan Ewen created FLINK-3312: --- Summary: Add convenience accessor methods for extended state interface Key: FLINK-3312 URL: https://issues.apache.org/jira/browse/FLINK-3312 Project: Flink Is

[jira] [Created] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly

Stephan Ewen created FLINK-3314: --- Summary: Early cancel calls can cause Tasks to not cancel properly Key: FLINK-3314 URL: https://issues.apache.org/jira/browse/FLINK-3314 Project: Flink Issue T

[jira] [Created] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

Stephan Ewen created FLINK-3328: --- Summary: Incorrectly shaded dependencies in flink-runtime Key: FLINK-3328 URL: https://issues.apache.org/jira/browse/FLINK-3328 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine

Stephan Ewen created FLINK-3347: --- Summary: TaskManager ActorSystems need to restart themselves in case they notice quarantine Key: FLINK-3347 URL: https://issues.apache.org/jira/browse/FLINK-3347 Projec

[jira] [Created] (FLINK-3350) Increase timeouts on Travis Builds

Stephan Ewen created FLINK-3350: --- Summary: Increase timeouts on Travis Builds Key: FLINK-3350 URL: https://issues.apache.org/jira/browse/FLINK-3350 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-3357) Drop JobId.toShortString()

Stephan Ewen created FLINK-3357: --- Summary: Drop JobId.toShortString() Key: FLINK-3357 URL: https://issues.apache.org/jira/browse/FLINK-3357 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens

Stephan Ewen created FLINK-3358: --- Summary: Create constructors for FsStateBackend in RocksDBBackens Key: FLINK-3358 URL: https://issues.apache.org/jira/browse/FLINK-3358 Project: Flink Issue Ty

[jira] [Created] (FLINK-3359) Make RocksDB file copies asynchronous

Stephan Ewen created FLINK-3359: --- Summary: Make RocksDB file copies asynchronous Key: FLINK-3359 URL: https://issues.apache.org/jira/browse/FLINK-3359 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values

Stephan Ewen created FLINK-3361: --- Summary: Wrong error messages for execution retry delay and akka ask pause config values Key: FLINK-3361 URL: https://issues.apache.org/jira/browse/FLINK-3361 Project:

[jira] [Created] (FLINK-3363) JobManager does not shut down dedicated executor properly

Stephan Ewen created FLINK-3363: --- Summary: JobManager does not shut down dedicated executor properly Key: FLINK-3363 URL: https://issues.apache.org/jira/browse/FLINK-3363 Project: Flink Issue T

[jira] [Created] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread

Stephan Ewen created FLINK-3365: --- Summary: BlobLibraryCacheManager does not shutdown Timer thread Key: FLINK-3365 URL: https://issues.apache.org/jira/browse/FLINK-3365 Project: Flink Issue Type

[jira] [Created] (FLINK-3370) Add an aligned version of the window operator

Stephan Ewen created FLINK-3370: --- Summary: Add an aligned version of the window operator Key: FLINK-3370 URL: https://issues.apache.org/jira/browse/FLINK-3370 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes

Stephan Ewen created FLINK-3371: --- Summary: Move TriggerCotext and TriggerResult to their own classes Key: FLINK-3371 URL: https://issues.apache.org/jira/browse/FLINK-3371 Project: Flink Issue T

[jira] [Created] (FLINK-3375) Allow Watermark Generation in the Kafka Source

Stephan Ewen created FLINK-3375: --- Summary: Allow Watermark Generation in the Kafka Source Key: FLINK-3375 URL: https://issues.apache.org/jira/browse/FLINK-3375 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docsq

Stephan Ewen created FLINK-3376: --- Summary: Add an illustration of Event Time and Watermarks to the docsq Key: FLINK-3376 URL: https://issues.apache.org/jira/browse/FLINK-3376 Project: Flink Is

[jira] [Created] (FLINK-3379) Refactor TimestampExtractor

Stephan Ewen created FLINK-3379: --- Summary: Refactor TimestampExtractor Key: FLINK-3379 URL: https://issues.apache.org/jira/browse/FLINK-3379 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-3384) Create atomic closable queue for communication between Kafka Threads

Stephan Ewen created FLINK-3384: --- Summary: Create atomic closable queue for communication between Kafka Threads Key: FLINK-3384 URL: https://issues.apache.org/jira/browse/FLINK-3384 Project: Flink

[jira] [Created] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

Stephan Ewen created FLINK-3387: --- Summary: Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer Key: FLINK-3387 URL: https://issues.apache.org/jira/browse/FLINK-3387

[jira] [Created] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend

Stephan Ewen created FLINK-3389: --- Summary: Add Pre-defined Options settings for RocksDB State backend Key: FLINK-3389 URL: https://issues.apache.org/jira/browse/FLINK-3389 Project: Flink Issue

[jira] [Created] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation

Stephan Ewen created FLINK-3401: --- Summary: AscendingTimestampExtractor should not fail on order violation Key: FLINK-3401 URL: https://issues.apache.org/jira/browse/FLINK-3401 Project: Flink I

[jira] [Created] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream

Stephan Ewen created FLINK-3412: --- Summary: Remove implicit conversions JavaStream / ScalaStream Key: FLINK-3412 URL: https://issues.apache.org/jira/browse/FLINK-3412 Project: Flink Issue Type:

[jira] [Created] (FLINK-3413) Remove implicit Seq to DataStream conversion

Stephan Ewen created FLINK-3413: --- Summary: Remove implicit Seq to DataStream conversion Key: FLINK-3413 URL: https://issues.apache.org/jira/browse/FLINK-3413 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-3415) TimestampExctractor accepts negative watermarks

Stephan Ewen created FLINK-3415: --- Summary: TimestampExctractor accepts negative watermarks Key: FLINK-3415 URL: https://issues.apache.org/jira/browse/FLINK-3415 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

Stephan Ewen created FLINK-3420: --- Summary: Remove "ReadTextFileWithValue" from StreamExecutionEnvironment Key: FLINK-3420 URL: https://issues.apache.org/jira/browse/FLINK-3420 Project: Flink I

[jira] [Created] (FLINK-3421) Remove all unused ClassTag context bounds in the Streaming Scala API

Stephan Ewen created FLINK-3421: --- Summary: Remove all unused ClassTag context bounds in the Streaming Scala API Key: FLINK-3421 URL: https://issues.apache.org/jira/browse/FLINK-3421 Project: Flink

[jira] [Created] (FLINK-3422) Scramble HashPartitioner hashes

Stephan Ewen created FLINK-3422: --- Summary: Scramble HashPartitioner hashes Key: FLINK-3422 URL: https://issues.apache.org/jira/browse/FLINK-3422 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3435) Change interplay of Ingestion Time and Event Time

Stephan Ewen created FLINK-3435: --- Summary: Change interplay of Ingestion Time and Event Time Key: FLINK-3435 URL: https://issues.apache.org/jira/browse/FLINK-3435 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved

Stephan Ewen created FLINK-3440: --- Summary: Kafka should also checkpoint partitions where no initial offset was retrieved Key: FLINK-3440 URL: https://issues.apache.org/jira/browse/FLINK-3440 Project: Fl

[jira] [Created] (FLINK-3456) Backpressure Monitoring does not work for Kafka Sources

Stephan Ewen created FLINK-3456: --- Summary: Backpressure Monitoring does not work for Kafka Sources Key: FLINK-3456 URL: https://issues.apache.org/jira/browse/FLINK-3456 Project: Flink Issue Typ

[jira] [Created] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps

Stephan Ewen created FLINK-3468: --- Summary: Change Timestamp Extractors to not support negative timestamps Key: FLINK-3468 URL: https://issues.apache.org/jira/browse/FLINK-3468 Project: Flink I

[jira] [Created] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps

Stephan Ewen created FLINK-3470: --- Summary: EventTime WindowAssigners should error on negative timestamps Key: FLINK-3470 URL: https://issues.apache.org/jira/browse/FLINK-3470 Project: Flink Is

[jira] [Created] (FLINK-3514) Add support for slowly changing streaming broadcast variables

Stephan Ewen created FLINK-3514: --- Summary: Add support for slowly changing streaming broadcast variables Key: FLINK-3514 URL: https://issues.apache.org/jira/browse/FLINK-3514 Project: Flink Is

[jira] [Created] (FLINK-3515) Make the "file monitoring source" exactly-once

Stephan Ewen created FLINK-3515: --- Summary: Make the "file monitoring source" exactly-once Key: FLINK-3515 URL: https://issues.apache.org/jira/browse/FLINK-3515 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-3520) Periodic watermark operator should emit current watermark in close()

Stephan Ewen created FLINK-3520: --- Summary: Periodic watermark operator should emit current watermark in close() Key: FLINK-3520 URL: https://issues.apache.org/jira/browse/FLINK-3520 Project: Flink

[jira] [Created] (FLINK-3522) Storm examples "PrintSampleStream" throws an error if called without arguments

Stephan Ewen created FLINK-3522: --- Summary: Storm examples "PrintSampleStream" throws an error if called without arguments Key: FLINK-3522 URL: https://issues.apache.org/jira/browse/FLINK-3522 Project: F

[jira] [Created] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

Stephan Ewen created FLINK-3523: --- Summary: Storm SpoutSplitExample fails with a ClassCastException Key: FLINK-3523 URL: https://issues.apache.org/jira/browse/FLINK-3523 Project: Flink Issue Typ

[jira] [Created] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken

Stephan Ewen created FLINK-3526: --- Summary: ProcessingTime Window Assigner and Trigger are broken Key: FLINK-3526 URL: https://issues.apache.org/jira/browse/FLINK-3526 Project: Flink Issue Type:

[jira] [Created] (FLINK-3549) Make streaming examples more streaming

Stephan Ewen created FLINK-3549: --- Summary: Make streaming examples more streaming Key: FLINK-3549 URL: https://issues.apache.org/jira/browse/FLINK-3549 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3550) Rework stream join example

Stephan Ewen created FLINK-3550: --- Summary: Rework stream join example Key: FLINK-3550 URL: https://issues.apache.org/jira/browse/FLINK-3550 Project: Flink Issue Type: Sub-task Compone

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

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

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

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

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

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 I

[jira] [Created] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

Stephan Ewen created FLINK-3578: --- Summary: Scala DataStream API does not support Rich Window Functions Key: FLINK-3578 URL: https://issues.apache.org/jira/browse/FLINK-3578 Project: Flink Issu

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

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-3602) Recursive Types are not supported / crash TypeExtractor

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 Typ

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

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

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

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-3752) Add Per-Kafka-Partition Watermark Generation to the docs

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 Ty

[jira] [Created] (FLINK-3895) Remove Focs for Program Packaging via Plans

Stephan Ewen created FLINK-3895: --- Summary: Remove Focs for Program Packaging via Plans Key: FLINK-3895 URL: https://issues.apache.org/jira/browse/FLINK-3895 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3894) Remove Program Packaging via Plans

Stephan Ewen created FLINK-3894: --- Summary: Remove Program Packaging via Plans Key: FLINK-3894 URL: https://issues.apache.org/jira/browse/FLINK-3894 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

Stephan Ewen created FLINK-3933: --- Summary: Add an auto-type-extracting DeserializationSchema Key: FLINK-3933 URL: https://issues.apache.org/jira/browse/FLINK-3933 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3949) Collect Metrics in Runtime Operators

Stephan Ewen created FLINK-3949: --- Summary: Collect Metrics in Runtime Operators Key: FLINK-3949 URL: https://issues.apache.org/jira/browse/FLINK-3949 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3950) Add Meter Metric Type

Stephan Ewen created FLINK-3950: --- Summary: Add Meter Metric Type Key: FLINK-3950 URL: https://issues.apache.org/jira/browse/FLINK-3950 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-3951) Add Histogram Metric Type

Stephan Ewen created FLINK-3951: --- Summary: Add Histogram Metric Type Key: FLINK-3951 URL: https://issues.apache.org/jira/browse/FLINK-3951 Project: Flink Issue Type: Sub-task Componen

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

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-3990) ZooKeeperLeaderElectionTest kills the JVM

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-3995) Properly Structure Test Utils and Dependencies

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-4052) Unstable test

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 Aff

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

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-4233) Simplify leader election / leader session ID assignment

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 Typ

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

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

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

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 Re

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

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 Component

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

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 Compon

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

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 Com

<    1   2   3   4   5   6   7   8   9   >