[jira] [Created] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

2017-08-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7477: --- Summary: Use "hadoop classpath" to augment classpath when available Key: FLINK-7477 URL: https://issues.apache.org/jira/browse/FLINK-7477 Project: Flink

[jira] [Created] (FLINK-7442) Add option for using a child-first classloader for loading user code

2017-08-14 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7442: --- Summary: Add option for using a child-first classloader for loading user code Key: FLINK-7442 URL: https://issues.apache.org/jira/browse/FLINK-7442 Project:

[jira] [Created] (FLINK-7414) Hardcode scala.version to 2.11 in flink-quickstart-scala

2017-08-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7414: --- Summary: Hardcode scala.version to 2.11 in flink-quickstart-scala Key: FLINK-7414 URL: https://issues.apache.org/jira/browse/FLINK-7414 Project: Flink

[jira] [Created] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x

2017-08-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7413: --- Summary: Release Hadoop 2.8.x convenience binaries for 1.3.x Key: FLINK-7413 URL: https://issues.apache.org/jira/browse/FLINK-7413 Project: Flink

[jira] [Created] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7398: --- Summary: Table API operators/UDFs must not store Logger Key: FLINK-7398 URL: https://issues.apache.org/jira/browse/FLINK-7398 Project: Flink Issue

[jira] [Created] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh

2017-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7396: --- Summary: Don't put multiple directories in HADOOP_CONF_DIR in config.sh Key: FLINK-7396 URL: https://issues.apache.org/jira/browse/FLINK-7396 Project: Flink

[jira] [Created] (FLINK-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled

2017-08-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7362: --- Summary: CheckpointProperties are not correctly set when restoring savepoint with HA enabled Key: FLINK-7362 URL: https://issues.apache.org/jira/browse/FLINK-7362

[jira] [Created] (FLINK-7290) Make release scripts modular

2017-07-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7290: --- Summary: Make release scripts modular Key: FLINK-7290 URL: https://issues.apache.org/jira/browse/FLINK-7290 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7281) Fix various issues in (Maven) release infrastructure

2017-07-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7281: --- Summary: Fix various issues in (Maven) release infrastructure Key: FLINK-7281 URL: https://issues.apache.org/jira/browse/FLINK-7281 Project: Flink

[jira] [Created] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles

2017-07-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7268: --- Summary: Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles Key: FLINK-7268 URL:

[jira] [Created] (FLINK-7241) Fix YARN high availability documentation

2017-07-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7241: --- Summary: Fix YARN high availability documentation Key: FLINK-7241 URL: https://issues.apache.org/jira/browse/FLINK-7241 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7164) Extend integration tests for (externalised) checkpoints, checkpoint store

2017-07-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7164: --- Summary: Extend integration tests for (externalised) checkpoints, checkpoint store Key: FLINK-7164 URL: https://issues.apache.org/jira/browse/FLINK-7164

[jira] [Created] (FLINK-7133) Fix Elasticsearch version interference

2017-07-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7133: --- Summary: Fix Elasticsearch version interference Key: FLINK-7133 URL: https://issues.apache.org/jira/browse/FLINK-7133 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7041) Deserialize StateBackend from JobCheckpointingSettings with user classloader

2017-06-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7041: --- Summary: Deserialize StateBackend from JobCheckpointingSettings with user classloader Key: FLINK-7041 URL: https://issues.apache.org/jira/browse/FLINK-7041

[jira] [Created] (FLINK-6539) Add automated end-to-end tests

2017-05-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6539: --- Summary: Add automated end-to-end tests Key: FLINK-6539 URL: https://issues.apache.org/jira/browse/FLINK-6539 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6515: --- Summary: KafkaConsumer checkpointing fails because of ClassLoader issues Key: FLINK-6515 URL: https://issues.apache.org/jira/browse/FLINK-6515 Project: Flink

[jira] [Created] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6514: --- Summary: Cannot start Flink Cluster in standalone mode Key: FLINK-6514 URL: https://issues.apache.org/jira/browse/FLINK-6514 Project: Flink Issue

[jira] [Created] (FLINK-6427) BucketingSink does not sync file length in case of cancel

2017-05-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6427: --- Summary: BucketingSink does not sync file length in case of cancel Key: FLINK-6427 URL: https://issues.apache.org/jira/browse/FLINK-6427 Project: Flink

[jira] [Created] (FLINK-6413) Add stream operator callback to notify about consumed network buffer

2017-04-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6413: --- Summary: Add stream operator callback to notify about consumed network buffer Key: FLINK-6413 URL: https://issues.apache.org/jira/browse/FLINK-6413 Project:

[jira] [Created] (FLINK-6383) Add versioning for AbstractStreamOperator state

2017-04-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6383: --- Summary: Add versioning for AbstractStreamOperator state Key: FLINK-6383 URL: https://issues.apache.org/jira/browse/FLINK-6383 Project: Flink Issue

[jira] [Created] (FLINK-6354) Add documentation for migration away from Checkpointed interface

2017-04-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6354: --- Summary: Add documentation for migration away from Checkpointed interface Key: FLINK-6354 URL: https://issues.apache.org/jira/browse/FLINK-6354 Project: Flink

[jira] [Created] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2

2017-04-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6353: --- Summary: Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 Key: FLINK-6353 URL: https://issues.apache.org/jira/browse/FLINK-6353 Project:

[jira] [Created] (FLINK-6323) Add new Sink interface with access to more meta data

2017-04-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6323: --- Summary: Add new Sink interface with access to more meta data Key: FLINK-6323 URL: https://issues.apache.org/jira/browse/FLINK-6323 Project: Flink

[jira] [Created] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-04-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6318: --- Summary: NFA serialisation doesn't work with TypeSerializers that load classes Key: FLINK-6318 URL: https://issues.apache.org/jira/browse/FLINK-6318 Project:

[jira] [Created] (FLINK-6255) Remove PatternStream.getSideOutput()

2017-04-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6255: --- Summary: Remove PatternStream.getSideOutput() Key: FLINK-6255 URL: https://issues.apache.org/jira/browse/FLINK-6255 Project: Flink Issue Type:

[jira] [Created] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

2017-04-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6254: --- Summary: Consolidate late data methods on PatternStream and WindowedStream Key: FLINK-6254 URL: https://issues.apache.org/jira/browse/FLINK-6254 Project: Flink

[jira] [Created] (FLINK-6246) Fix generic type of OutputTag in operator Output

2017-04-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6246: --- Summary: Fix generic type of OutputTag in operator Output Key: FLINK-6246 URL: https://issues.apache.org/jira/browse/FLINK-6246 Project: Flink Issue

[jira] [Created] (FLINK-6188) Some setParallelism() method can't cope with default parallelism

2017-03-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6188: --- Summary: Some setParallelism() method can't cope with default parallelism Key: FLINK-6188 URL: https://issues.apache.org/jira/browse/FLINK-6188 Project: Flink

[jira] [Created] (FLINK-6164) Make ProcessWindowFunction a RichFunction

2017-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6164: --- Summary: Make ProcessWindowFunction a RichFunction Key: FLINK-6164 URL: https://issues.apache.org/jira/browse/FLINK-6164 Project: Flink Issue Type:

[jira] [Created] (FLINK-6163) Document per-window state in ProcessWindowFunction

2017-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6163: --- Summary: Document per-window state in ProcessWindowFunction Key: FLINK-6163 URL: https://issues.apache.org/jira/browse/FLINK-6163 Project: Flink Issue

[jira] [Created] (FLINK-6135) Allowing adding inputs to StreamOperator

2017-03-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6135: --- Summary: Allowing adding inputs to StreamOperator Key: FLINK-6135 URL: https://issues.apache.org/jira/browse/FLINK-6135 Project: Flink Issue Type:

[jira] [Created] (FLINK-6131) Add side inputs for DataStream API

2017-03-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6131: --- Summary: Add side inputs for DataStream API Key: FLINK-6131 URL: https://issues.apache.org/jira/browse/FLINK-6131 Project: Flink Issue Type:

[jira] [Created] (FLINK-6118) Chained operators forward watermark without checking

2017-03-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6118: --- Summary: Chained operators forward watermark without checking Key: FLINK-6118 URL: https://issues.apache.org/jira/browse/FLINK-6118 Project: Flink

[jira] [Created] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-03-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6116: --- Summary: Watermarks don't work when unioning with same DataStream Key: FLINK-6116 URL: https://issues.apache.org/jira/browse/FLINK-6116 Project: Flink

[jira] [Created] (FLINK-6107) Add custom checkstyle for flink-streaming-java

2017-03-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6107: --- Summary: Add custom checkstyle for flink-streaming-java Key: FLINK-6107 URL: https://issues.apache.org/jira/browse/FLINK-6107 Project: Flink Issue

[jira] [Created] (FLINK-5972) Don't allow shrinking merging windows

2017-03-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5972: --- Summary: Don't allow shrinking merging windows Key: FLINK-5972 URL: https://issues.apache.org/jira/browse/FLINK-5972 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5969) Add savepoint backwards compatibility tests from 1.2 to 1.3

2017-03-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5969: --- Summary: Add savepoint backwards compatibility tests from 1.2 to 1.3 Key: FLINK-5969 URL: https://issues.apache.org/jira/browse/FLINK-5969 Project: Flink

[jira] [Created] (FLINK-5968) Document WindowedStream.aggregate()

2017-03-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5968: --- Summary: Document WindowedStream.aggregate() Key: FLINK-5968 URL: https://issues.apache.org/jira/browse/FLINK-5968 Project: Flink Issue Type:

[jira] [Created] (FLINK-5967) Document AggregatingState

2017-03-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5967: --- Summary: Document AggregatingState Key: FLINK-5967 URL: https://issues.apache.org/jira/browse/FLINK-5967 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5933) Allow Evictor for merging windows

2017-02-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5933: --- Summary: Allow Evictor for merging windows Key: FLINK-5933 URL: https://issues.apache.org/jira/browse/FLINK-5933 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

2017-02-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5929: --- Summary: Allow Access to Per-Window State in ProcessWindowFunction Key: FLINK-5929 URL: https://issues.apache.org/jira/browse/FLINK-5929 Project: Flink

[jira] [Created] (FLINK-5917) Remove MapState.size()

2017-02-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5917: --- Summary: Remove MapState.size() Key: FLINK-5917 URL: https://issues.apache.org/jira/browse/FLINK-5917 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5880) Add documentation for object reuse for DataStream API

2017-02-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5880: --- Summary: Add documentation for object reuse for DataStream API Key: FLINK-5880 URL: https://issues.apache.org/jira/browse/FLINK-5880 Project: Flink

[jira] [Created] (FLINK-5774) ContinuousFileProcessingTest has test instability

2017-02-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5774: --- Summary: ContinuousFileProcessingTest has test instability Key: FLINK-5774 URL: https://issues.apache.org/jira/browse/FLINK-5774 Project: Flink Issue

[jira] [Created] (FLINK-5743) Mark WindowedStream.aggregate* methods as PublicEvolving

2017-02-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5743: --- Summary: Mark WindowedStream.aggregate* methods as PublicEvolving Key: FLINK-5743 URL: https://issues.apache.org/jira/browse/FLINK-5743 Project: Flink

[jira] [Created] (FLINK-5741) Add tests for window function wrappers with RichFunctions

2017-02-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5741: --- Summary: Add tests for window function wrappers with RichFunctions Key: FLINK-5741 URL: https://issues.apache.org/jira/browse/FLINK-5741 Project: Flink

[jira] [Created] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

2017-02-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5740: --- Summary: Make WrappingFunction an interface and move to flink-core Key: FLINK-5740 URL: https://issues.apache.org/jira/browse/FLINK-5740 Project: Flink

[jira] [Created] (FLINK-5721) Add FoldingState to State Documentation

2017-02-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5721: --- Summary: Add FoldingState to State Documentation Key: FLINK-5721 URL: https://issues.apache.org/jira/browse/FLINK-5721 Project: Flink Issue Type:

[jira] [Created] (FLINK-5720) Deprecate "Folding" in all of DataStream API

2017-02-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5720: --- Summary: Deprecate "Folding" in all of DataStream API Key: FLINK-5720 URL: https://issues.apache.org/jira/browse/FLINK-5720 Project: Flink Issue Type:

[jira] [Created] (FLINK-5713) Protect against NPE in WindowOperator window cleanup

2017-02-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5713: --- Summary: Protect against NPE in WindowOperator window cleanup Key: FLINK-5713 URL: https://issues.apache.org/jira/browse/FLINK-5713 Project: Flink

[jira] [Created] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc

2017-02-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5709: --- Summary: Add Max Parallelism to Parallel Execution Doc Key: FLINK-5709 URL: https://issues.apache.org/jira/browse/FLINK-5709 Project: Flink Issue

[jira] [Created] (FLINK-5647) Fix RocksDB Backend Cleanup

2017-01-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5647: --- Summary: Fix RocksDB Backend Cleanup Key: FLINK-5647 URL: https://issues.apache.org/jira/browse/FLINK-5647 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-01-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5616: --- Summary: YarnPreConfiguredMasterHaServicesTest fails sometimes Key: FLINK-5616 URL: https://issues.apache.org/jira/browse/FLINK-5616 Project: Flink

[jira] [Created] (FLINK-5374) Extend Unit Tests for RegisteredBackendStateMetaInfo

2016-12-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5374: --- Summary: Extend Unit Tests for RegisteredBackendStateMetaInfo Key: FLINK-5374 URL: https://issues.apache.org/jira/browse/FLINK-5374 Project: Flink

[jira] [Created] (FLINK-5373) Extend Unit Tests for StateAssignmentOperation

2016-12-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5373: --- Summary: Extend Unit Tests for StateAssignmentOperation Key: FLINK-5373 URL: https://issues.apache.org/jira/browse/FLINK-5373 Project: Flink Issue

[jira] [Created] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2016-12-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5372: --- Summary: Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() Key: FLINK-5372 URL: https://issues.apache.org/jira/browse/FLINK-5372 Project: Flink

[jira] [Created] (FLINK-5366) Add end-to-end tests for Savepoint Backwards Compatibility

2016-12-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5366: --- Summary: Add end-to-end tests for Savepoint Backwards Compatibility Key: FLINK-5366 URL: https://issues.apache.org/jira/browse/FLINK-5366 Project: Flink

[jira] [Created] (FLINK-5363) Fire timers when window state is currently empty

2016-12-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5363: --- Summary: Fire timers when window state is currently empty Key: FLINK-5363 URL: https://issues.apache.org/jira/browse/FLINK-5363 Project: Flink Issue

[jira] [Created] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction

2016-12-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5250: --- Summary: Make AbstractUdfStreamOperator aware of WrappingFunction Key: FLINK-5250 URL: https://issues.apache.org/jira/browse/FLINK-5250 Project: Flink

[jira] [Created] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5240: --- Summary: Properly Close StateBackend in StreamTask when closing/canceling Key: FLINK-5240 URL: https://issues.apache.org/jira/browse/FLINK-5240 Project: Flink

[jira] [Created] (FLINK-5237) Consolidate and harmonize Window Translation Tests

2016-12-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5237: --- Summary: Consolidate and harmonize Window Translation Tests Key: FLINK-5237 URL: https://issues.apache.org/jira/browse/FLINK-5237 Project: Flink Issue

[jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

2016-11-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5155: --- Summary: Deprecate ValueStateDescriptor constructors with default value Key: FLINK-5155 URL: https://issues.apache.org/jira/browse/FLINK-5155 Project: Flink

[jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot

2016-11-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5154: --- Summary: Duplicate TypeSerializer when writing RocksDB Snapshot Key: FLINK-5154 URL: https://issues.apache.org/jira/browse/FLINK-5154 Project: Flink

[jira] [Created] (FLINK-5130) Remove Deprecated Methods from WindowedStream

2016-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5130: --- Summary: Remove Deprecated Methods from WindowedStream Key: FLINK-5130 URL: https://issues.apache.org/jira/browse/FLINK-5130 Project: Flink Issue

[jira] [Created] (FLINK-5126) Remove Checked Exceptions from State Interfaces

2016-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5126: --- Summary: Remove Checked Exceptions from State Interfaces Key: FLINK-5126 URL: https://issues.apache.org/jira/browse/FLINK-5126 Project: Flink Issue

[jira] [Created] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2016-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5125: --- Summary: ContinuousFileProcessingCheckpointITCase is Flaky Key: FLINK-5125 URL: https://issues.apache.org/jira/browse/FLINK-5125 Project: Flink Issue

[jira] [Created] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest

2016-11-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5037: --- Summary: Instability in AbstractUdfStreamOperatorLifecycleTest Key: FLINK-5037 URL: https://issues.apache.org/jira/browse/FLINK-5037 Project: Flink

[jira] [Created] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot

2016-11-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5035: --- Summary: Don't Write TypeSerializer to Heap State Snapshot Key: FLINK-5035 URL: https://issues.apache.org/jira/browse/FLINK-5035 Project: Flink Issue

[jira] [Created] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot

2016-11-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5034: --- Summary: Don't Write StateDescriptor to RocksDB Snapshot Key: FLINK-5034 URL: https://issues.apache.org/jira/browse/FLINK-5034 Project: Flink Issue

[jira] [Created] (FLINK-5026) Rename TimelyFlatMap to Process

2016-11-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5026: --- Summary: Rename TimelyFlatMap to Process Key: FLINK-5026 URL: https://issues.apache.org/jira/browse/FLINK-5026 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

2016-11-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5015: --- Summary: Add Tests/ITCase for Kafka Per-Partition Watermarks Key: FLINK-5015 URL: https://issues.apache.org/jira/browse/FLINK-5015 Project: Flink

[jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction

2016-11-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5012: --- Summary: Provide Timestamp in TimelyFlatMapFunction Key: FLINK-5012 URL: https://issues.apache.org/jira/browse/FLINK-5012 Project: Flink Issue Type:

[jira] [Created] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context

2016-11-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5003: --- Summary: Provide Access to State Stores in Operator Snapshot Context Key: FLINK-5003 URL: https://issues.apache.org/jira/browse/FLINK-5003 Project: Flink

[jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5000: --- Summary: Rename Methods in ManagedInitializationContext Key: FLINK-5000 URL: https://issues.apache.org/jira/browse/FLINK-5000 Project: Flink Issue

[jira] [Created] (FLINK-4994) Don't Clear Trigger State and Merging Window Set When Purging

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4994: --- Summary: Don't Clear Trigger State and Merging Window Set When Purging Key: FLINK-4994 URL: https://issues.apache.org/jira/browse/FLINK-4994 Project: Flink

[jira] [Created] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4993: --- Summary: Don't Allow Trigger.onMerge() to return TriggerResult Key: FLINK-4993 URL: https://issues.apache.org/jira/browse/FLINK-4993 Project: Flink

[jira] [Created] (FLINK-4959) Write Documentation for Timely FlatMap Functions

2016-10-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4959: --- Summary: Write Documentation for Timely FlatMap Functions Key: FLINK-4959 URL: https://issues.apache.org/jira/browse/FLINK-4959 Project: Flink Issue

[jira] [Created] (FLINK-4957) Provide API for TimelyCoFlatMapFunction

2016-10-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4957: --- Summary: Provide API for TimelyCoFlatMapFunction Key: FLINK-4957 URL: https://issues.apache.org/jira/browse/FLINK-4957 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-4955) Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction)

2016-10-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4955: --- Summary: Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction) Key: FLINK-4955 URL: https://issues.apache.org/jira/browse/FLINK-4955 Project:

[jira] [Created] (FLINK-4940) Add Support for Broadcast/Global State

2016-10-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4940: --- Summary: Add Support for Broadcast/Global State Key: FLINK-4940 URL: https://issues.apache.org/jira/browse/FLINK-4940 Project: Flink Issue Type:

[jira] [Created] (FLINK-4907) Add Test for Timers/State Provided by AbstractStreamOperator

2016-10-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4907: --- Summary: Add Test for Timers/State Provided by AbstractStreamOperator Key: FLINK-4907 URL: https://issues.apache.org/jira/browse/FLINK-4907 Project: Flink

[jira] [Created] (FLINK-4892) Snapshot TimerService using Key-Grouped State

2016-10-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4892: --- Summary: Snapshot TimerService using Key-Grouped State Key: FLINK-4892 URL: https://issues.apache.org/jira/browse/FLINK-4892 Project: Flink Issue

[jira] [Created] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator

2016-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4884: --- Summary: Eagerly Store MergingWindowSet in State in WindowOperator Key: FLINK-4884 URL: https://issues.apache.org/jira/browse/FLINK-4884 Project: Flink

[jira] [Created] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

2016-10-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4866: --- Summary: Make Trigger.clear() Abstract to Enforce Implementation Key: FLINK-4866 URL: https://issues.apache.org/jira/browse/FLINK-4866 Project: Flink

[jira] [Created] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

2016-10-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4859: --- Summary: Clearly Separate Responsibilities of StreamOperator and StreamTask Key: FLINK-4859 URL: https://issues.apache.org/jira/browse/FLINK-4859 Project:

[jira] [Created] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-10-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4858: --- Summary: Remove Legacy Checkpointing Interfaces Key: FLINK-4858 URL: https://issues.apache.org/jira/browse/FLINK-4858 Project: Flink Issue Type:

[jira] [Created] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

2016-09-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4675: --- Summary: Remove Parameter from WindowAssigner.getDefaultTrigger() Key: FLINK-4675 URL: https://issues.apache.org/jira/browse/FLINK-4675 Project: Flink

[jira] [Created] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4589: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4589 URL: https://issues.apache.org/jira/browse/FLINK-4589 Project: Flink Issue

[jira] [Created] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4588: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4588 URL: https://issues.apache.org/jira/browse/FLINK-4588 Project: Flink Issue

[jira] [Created] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4579: --- Summary: Add StateBackendFactory for RocksDB Backend Key: FLINK-4579 URL: https://issues.apache.org/jira/browse/FLINK-4579 Project: Flink Issue Type:

[jira] [Created] (FLINK-4556) Make Queryable State Key-Group Aware

2016-09-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4556: --- Summary: Make Queryable State Key-Group Aware Key: FLINK-4556 URL: https://issues.apache.org/jira/browse/FLINK-4556 Project: Flink Issue Type:

[jira] [Created] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-09-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4552: --- Summary: Refactor WindowOperator/Trigger Tests Key: FLINK-4552 URL: https://issues.apache.org/jira/browse/FLINK-4552 Project: Flink Issue Type:

[jira] [Created] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch

2016-09-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4548: --- Summary: Refactor ContinuousFileMonitoringTest to use OneShotLatch Key: FLINK-4548 URL: https://issues.apache.org/jira/browse/FLINK-4548 Project: Flink

[jira] [Created] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup()

2016-08-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4415: --- Summary: Enhance Trigger Interface with onFire() and onCleanup() Key: FLINK-4415 URL: https://issues.apache.org/jira/browse/FLINK-4415 Project: Flink

[jira] [Created] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends

2016-08-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4381: --- Summary: Refactor State to Prepare For Key-Group State Backends Key: FLINK-4381 URL: https://issues.apache.org/jira/browse/FLINK-4381 Project: Flink

[jira] [Created] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter

2016-08-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4380: --- Summary: Introduce KeyGroupAssigner and Max-Parallelism Parameter Key: FLINK-4380 URL: https://issues.apache.org/jira/browse/FLINK-4380 Project: Flink

[jira] [Created] (FLINK-4369) Evictingwindowoperator Must Actually Evict Elements

2016-08-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4369: --- Summary: Evictingwindowoperator Must Actually Evict Elements Key: FLINK-4369 URL: https://issues.apache.org/jira/browse/FLINK-4369 Project: Flink

[jira] [Created] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode

2016-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4340: --- Summary: Remove RocksDB Semi-Async Checkpoint Mode Key: FLINK-4340 URL: https://issues.apache.org/jira/browse/FLINK-4340 Project: Flink Issue Type:

[jira] [Created] (FLINK-4329) Streaming File Source Must Correctly Handle Timestamps/Watermarks

2016-08-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4329: --- Summary: Streaming File Source Must Correctly Handle Timestamps/Watermarks Key: FLINK-4329 URL: https://issues.apache.org/jira/browse/FLINK-4329 Project: Flink

[jira] [Created] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-07-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4282: --- Summary: Add Offset Parameter to WindowAssigners Key: FLINK-4282 URL: https://issues.apache.org/jira/browse/FLINK-4282 Project: Flink Issue Type:

<    1   2   3   4   5   >