[jira] [Created] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

2015-03-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1720: --- Summary: Integrate ScalaDoc in Scala sources into overall JavaDoc Key: FLINK-1720 URL: https://issues.apache.org/jira/browse/FLINK-1720 Project: Flink

[jira] [Created] (FLINK-1623) Rename Expression API and Operation Representation

2015-03-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1623: --- Summary: Rename Expression API and Operation Representation Key: FLINK-1623 URL: https://issues.apache.org/jira/browse/FLINK-1623 Project: Flink Issue

[jira] [Created] (FLINK-1622) Add ReducePartial and GroupReducePartial Operators

2015-03-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1622: --- Summary: Add ReducePartial and GroupReducePartial Operators Key: FLINK-1622 URL: https://issues.apache.org/jira/browse/FLINK-1622 Project: Flink Issue

[jira] [Created] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

2015-04-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1936: --- Summary: Normalize keys and default values in ConfigConstants.java Key: FLINK-1936 URL: https://issues.apache.org/jira/browse/FLINK-1936 Project: Flink

[jira] [Created] (FLINK-1971) Add user function type to StreamOperator

2015-05-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1971: --- Summary: Add user function type to StreamOperator Key: FLINK-1971 URL: https://issues.apache.org/jira/browse/FLINK-1971 Project: Flink Issue Type:

[jira] [Created] (FLINK-1977) Rework Stream Operators to always be push based

2015-05-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1977: --- Summary: Rework Stream Operators to always be push based Key: FLINK-1977 URL: https://issues.apache.org/jira/browse/FLINK-1977 Project: Flink Issue

[jira] [Created] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1985: --- Summary: Streaming does not correctly forward ExecutionConfig to runtime Key: FLINK-1985 URL: https://issues.apache.org/jira/browse/FLINK-1985 Project: Flink

[jira] [Created] (FLINK-2000) Add SQL-style aggregations for Table API

2015-05-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2000: --- Summary: Add SQL-style aggregations for Table API Key: FLINK-2000 URL: https://issues.apache.org/jira/browse/FLINK-2000 Project: Flink Issue Type:

[jira] [Created] (FLINK-2009) Time-Based Windows fail with Chaining Disabled

2015-05-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2009: --- Summary: Time-Based Windows fail with Chaining Disabled Key: FLINK-2009 URL: https://issues.apache.org/jira/browse/FLINK-2009 Project: Flink Issue

[jira] [Created] (FLINK-1903) Joins where one side uses a field more than once don't work

2015-04-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1903: --- Summary: Joins where one side uses a field more than once don't work Key: FLINK-1903 URL: https://issues.apache.org/jira/browse/FLINK-1903 Project: Flink

[jira] [Created] (FLINK-1904) Add cross() to Table API

2015-04-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1904: --- Summary: Add cross() to Table API Key: FLINK-1904 URL: https://issues.apache.org/jira/browse/FLINK-1904 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1880) TaskManagerTest fails spuriously

2015-04-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1880: --- Summary: TaskManagerTest fails spuriously Key: FLINK-1880 URL: https://issues.apache.org/jira/browse/FLINK-1880 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1851) Java Table API does not support Casting

2015-04-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1851: --- Summary: Java Table API does not support Casting Key: FLINK-1851 URL: https://issues.apache.org/jira/browse/FLINK-1851 Project: Flink Issue Type:

[jira] [Created] (FLINK-2182) Add stateful Streaming Sequence Source

2015-06-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2182: --- Summary: Add stateful Streaming Sequence Source Key: FLINK-2182 URL: https://issues.apache.org/jira/browse/FLINK-2182 Project: Flink Issue Type:

[jira] [Created] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis

2015-06-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2163: --- Summary: VertexCentricConfigurationITCase sometimes fails on Travis Key: FLINK-2163 URL: https://issues.apache.org/jira/browse/FLINK-2163 Project: Flink

[jira] [Created] (FLINK-2160) Change Streaming Source Interface to run(Context)/cancel()

2015-06-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2160: --- Summary: Change Streaming Source Interface to run(Context)/cancel() Key: FLINK-2160 URL: https://issues.apache.org/jira/browse/FLINK-2160 Project: Flink

[jira] [Created] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2191: --- Summary: Inconsistent use of Closure Cleaner in Streaming API Key: FLINK-2191 URL: https://issues.apache.org/jira/browse/FLINK-2191 Project: Flink

[jira] [Created] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged

2015-06-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2277: --- Summary: In Scala API delta Iterations can not be set to unmanaged Key: FLINK-2277 URL: https://issues.apache.org/jira/browse/FLINK-2277 Project: Flink

[jira] [Created] (FLINK-2221) Checkpoints to file:// are not cleaned up

2015-06-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2221: --- Summary: Checkpoints to file:// are not cleaned up Key: FLINK-2221 URL: https://issues.apache.org/jira/browse/FLINK-2221 Project: Flink Issue Type:

[jira] [Created] (FLINK-2234) CoStreamWindow is Dependent on Input Ordering

2015-06-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2234: --- Summary: CoStreamWindow is Dependent on Input Ordering Key: FLINK-2234 URL: https://issues.apache.org/jira/browse/FLINK-2234 Project: Flink Issue

[jira] [Created] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values

2015-06-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2236: --- Summary: RowSerializer and CaseClassComparator are not in sync regarding Null-Values Key: FLINK-2236 URL: https://issues.apache.org/jira/browse/FLINK-2236

[jira] [Created] (FLINK-2203) Add Support for Null-Values in RowSerializer

2015-06-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2203: --- Summary: Add Support for Null-Values in RowSerializer Key: FLINK-2203 URL: https://issues.apache.org/jira/browse/FLINK-2203 Project: Flink Issue Type:

[jira] [Created] (FLINK-2122) Make all internal streaming operators Checkpointable

2015-06-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2122: --- Summary: Make all internal streaming operators Checkpointable Key: FLINK-2122 URL: https://issues.apache.org/jira/browse/FLINK-2122 Project: Flink

[jira] [Created] (FLINK-2124) FromElementsFunction is not really Serializable

2015-06-01 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2124: --- Summary: FromElementsFunction is not really Serializable Key: FLINK-2124 URL: https://issues.apache.org/jira/browse/FLINK-2124 Project: Flink Issue

[jira] [Created] (FLINK-2103) Expose partitionBy to the user in Stream API

2015-05-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2103: --- Summary: Expose partitionBy to the user in Stream API Key: FLINK-2103 URL: https://issues.apache.org/jira/browse/FLINK-2103 Project: Flink Issue Type:

[jira] [Created] (FLINK-2290) CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive

2015-06-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2290: --- Summary: CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive Key: FLINK-2290 URL: https://issues.apache.org/jira/browse/FLINK-2290

[jira] [Created] (FLINK-2317) Stream Jobs with Windows Leave Lingering State

2015-07-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2317: --- Summary: Stream Jobs with Windows Leave Lingering State Key: FLINK-2317 URL: https://issues.apache.org/jira/browse/FLINK-2317 Project: Flink Issue

[jira] [Created] (FLINK-2294) Keyed State does not work with DOP=1

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2294: --- Summary: Keyed State does not work with DOP=1 Key: FLINK-2294 URL: https://issues.apache.org/jira/browse/FLINK-2294 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2074: --- Summary: Sliding Window Keeps Emitting Elements After Source Stops Producing Key: FLINK-2074 URL: https://issues.apache.org/jira/browse/FLINK-2074 Project:

[jira] [Created] (FLINK-2081) Change order of restore state and open for Streaming Operators

2015-05-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2081: --- Summary: Change order of restore state and open for Streaming Operators Key: FLINK-2081 URL: https://issues.apache.org/jira/browse/FLINK-2081 Project: Flink

[jira] [Created] (FLINK-2558) Add Streaming Connector for Elasticsearch

2015-08-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2558: --- Summary: Add Streaming Connector for Elasticsearch Key: FLINK-2558 URL: https://issues.apache.org/jira/browse/FLINK-2558 Project: Flink Issue Type:

[jira] [Created] (FLINK-2559) Fix Javadoc Code Examples

2015-08-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2559: --- Summary: Fix Javadoc Code Examples Key: FLINK-2559 URL: https://issues.apache.org/jira/browse/FLINK-2559 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2551) Fix Several Bugs in Input/Output Formats

2015-08-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2551: --- Summary: Fix Several Bugs in Input/Output Formats Key: FLINK-2551 URL: https://issues.apache.org/jira/browse/FLINK-2551 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2550) Rework DataStream API

2015-08-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2550: --- Summary: Rework DataStream API Key: FLINK-2550 URL: https://issues.apache.org/jira/browse/FLINK-2550 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2295: --- Summary: TwoInput Task do not react to/forward checkpoint barriers Key: FLINK-2295 URL: https://issues.apache.org/jira/browse/FLINK-2295 Project: Flink

[jira] [Created] (FLINK-2470) Stream Iteration can Hang after some Data

2015-08-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2470: --- Summary: Stream Iteration can Hang after some Data Key: FLINK-2470 URL: https://issues.apache.org/jira/browse/FLINK-2470 Project: Flink Issue Type:

[jira] [Created] (FLINK-2398) Decouple StreamGraph Building from the API

2015-07-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2398: --- Summary: Decouple StreamGraph Building from the API Key: FLINK-2398 URL: https://issues.apache.org/jira/browse/FLINK-2398 Project: Flink Issue Type:

[jira] [Created] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks

2015-07-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2382: --- Summary: Live Metric Reporting Does Not Work for Two-Input StreamTasks Key: FLINK-2382 URL: https://issues.apache.org/jira/browse/FLINK-2382 Project: Flink

[jira] [Created] (FLINK-2383) Add new Window Operator that can use Timestamps/Watermarks

2015-07-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2383: --- Summary: Add new Window Operator that can use Timestamps/Watermarks Key: FLINK-2383 URL: https://issues.apache.org/jira/browse/FLINK-2383 Project: Flink

[jira] [Created] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation

2015-10-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2891: --- Summary: Key for Keyed State is not set upon Window Evaluation Key: FLINK-2891 URL: https://issues.apache.org/jira/browse/FLINK-2891 Project: Flink

[jira] [Created] (FLINK-2922) Add Queryable Window Operator

2015-10-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2922: --- Summary: Add Queryable Window Operator Key: FLINK-2922 URL: https://issues.apache.org/jira/browse/FLINK-2922 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

2015-10-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2870: --- Summary: Add support for accumulating/discarding for Event-Time Windows Key: FLINK-2870 URL: https://issues.apache.org/jira/browse/FLINK-2870 Project: Flink

[jira] [Created] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant

2015-10-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2864: --- Summary: Make State of General-Purpose Window Operators Fault-Tolerant Key: FLINK-2864 URL: https://issues.apache.org/jira/browse/FLINK-2864 Project: Flink

[jira] [Created] (FLINK-2877) Move Streaming API out of Staging

2015-10-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2877: --- Summary: Move Streaming API out of Staging Key: FLINK-2877 URL: https://issues.apache.org/jira/browse/FLINK-2877 Project: Flink Issue Type:

[jira] [Created] (FLINK-2830) Add Fold Window Operation for new Windowing API

2015-10-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2830: --- Summary: Add Fold Window Operation for new Windowing API Key: FLINK-2830 URL: https://issues.apache.org/jira/browse/FLINK-2830 Project: Flink Issue

[jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE

2015-11-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3024: --- Summary: TimestampExtractor Does not Work When returning Long.MIN_VALUE Key: FLINK-3024 URL: https://issues.apache.org/jira/browse/FLINK-3024 Project: Flink

[jira] [Created] (FLINK-2577) Watermarks Stall When a Source Finishes Prematurely

2015-08-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2577: --- Summary: Watermarks Stall When a Source Finishes Prematurely Key: FLINK-2577 URL: https://issues.apache.org/jira/browse/FLINK-2577 Project: Flink

[jira] [Created] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0

2015-09-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2643: --- Summary: Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0 Key: FLINK-2643 URL: https://issues.apache.org/jira/browse/FLINK-2643

[jira] [Created] (FLINK-2780) Remove Old Windowing Logic and API

2015-09-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2780: --- Summary: Remove Old Windowing Logic and API Key: FLINK-2780 URL: https://issues.apache.org/jira/browse/FLINK-2780 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union

2015-10-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2819: --- Summary: Add Windowed Join/CoGroup Operator Based on Tagged Union Key: FLINK-2819 URL: https://issues.apache.org/jira/browse/FLINK-2819 Project: Flink

[jira] [Created] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2015-09-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2747: --- Summary: TypeExtractor does not correctly analyze Scala Immutables (AnyVal) Key: FLINK-2747 URL: https://issues.apache.org/jira/browse/FLINK-2747 Project:

[jira] [Created] (FLINK-3178) Make Closing Behavior of Window Operators Configurable

2015-12-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3178: --- Summary: Make Closing Behavior of Window Operators Configurable Key: FLINK-3178 URL: https://issues.apache.org/jira/browse/FLINK-3178 Project: Flink

[jira] [Created] (FLINK-3174) Add merging WindowAssigner

2015-12-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3174: --- Summary: Add merging WindowAssigner Key: FLINK-3174 URL: https://issues.apache.org/jira/browse/FLINK-3174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements

2015-12-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3177: --- Summary: Add Stream Operator that Discards Late Elements Key: FLINK-3177 URL: https://issues.apache.org/jira/browse/FLINK-3177 Project: Flink Issue

[jira] [Created] (FLINK-3201) Enhance Partitioned State Interface with State Types

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3201: --- Summary: Enhance Partitioned State Interface with State Types Key: FLINK-3201 URL: https://issues.apache.org/jira/browse/FLINK-3201 Project: Flink

[jira] [Created] (FLINK-3200) Use Partitioned State Abstraction in WindowOperator

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3200: --- Summary: Use Partitioned State Abstraction in WindowOperator Key: FLINK-3200 URL: https://issues.apache.org/jira/browse/FLINK-3200 Project: Flink

[jira] [Created] (FLINK-3202) Make Timer/Trigger Service Scoped to Key/Namespace

2016-01-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3202: --- Summary: Make Timer/Trigger Service Scoped to Key/Namespace Key: FLINK-3202 URL: https://issues.apache.org/jira/browse/FLINK-3202 Project: Flink Issue

[jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow

2016-06-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4028: --- Summary: AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow Key: FLINK-4028 URL: https://issues.apache.org/jira/browse/FLINK-4028 Project:

[jira] [Created] (FLINK-4062) Update Window Documentation

2016-06-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4062: --- Summary: Update Window Documentation Key: FLINK-4062 URL: https://issues.apache.org/jira/browse/FLINK-4062 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4063) Add Metrics Support for Triggers

2016-06-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4063: --- Summary: Add Metrics Support for Triggers Key: FLINK-4063 URL: https://issues.apache.org/jira/browse/FLINK-4063 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

2016-05-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3977: --- Summary: Subclasses of InternalWindowFunction must support OutputTypeConfigurable Key: FLINK-3977 URL: https://issues.apache.org/jira/browse/FLINK-3977

[jira] [Created] (FLINK-4082) Add Setting for LargeRecordHandler

2016-06-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4082: --- Summary: Add Setting for LargeRecordHandler Key: FLINK-4082 URL: https://issues.apache.org/jira/browse/FLINK-4082 Project: Flink Issue Type:

[jira] [Created] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

2016-01-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3242: --- Summary: User-specified StateBackend is not Respected if Checkpointing is Disabled Key: FLINK-3242 URL: https://issues.apache.org/jira/browse/FLINK-3242

[jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

2016-01-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3243: --- Summary: Fix Interplay of TimeCharacteristic and Time Windows Key: FLINK-3243 URL: https://issues.apache.org/jira/browse/FLINK-3243 Project: Flink

[jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

2016-02-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3336: --- Summary: Add Semi-Rebalance Data Shipping for DataStream Key: FLINK-3336 URL: https://issues.apache.org/jira/browse/FLINK-3336 Project: Flink Issue

[jira] [Created] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3528: --- Summary: Add Incremental Fold for Non-Keyed Window Operator Key: FLINK-3528 URL: https://issues.apache.org/jira/browse/FLINK-3528 Project: Flink Issue

[jira] [Created] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator

2016-02-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3548: --- Summary: Remove unnecessary generic parameter from SingleOutputStreamOperator Key: FLINK-3548 URL: https://issues.apache.org/jira/browse/FLINK-3548 Project:

[jira] [Created] (FLINK-3521) Make Iterable part of method signature for WindowFunction

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3521: --- Summary: Make Iterable part of method signature for WindowFunction Key: FLINK-3521 URL: https://issues.apache.org/jira/browse/FLINK-3521 Project: Flink

[jira] [Created] (FLINK-3527) Scala DataStream has no transform method

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3527: --- Summary: Scala DataStream has no transform method Key: FLINK-3527 URL: https://issues.apache.org/jira/browse/FLINK-3527 Project: Flink Issue Type:

[jira] [Created] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3513: --- Summary: Fix interplay of automatic Operator UID and Changing name of WindowOperator Key: FLINK-3513 URL: https://issues.apache.org/jira/browse/FLINK-3513

[jira] [Created] (FLINK-3278) Add Partitioned State Backend Based on RocksDB

2016-01-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3278: --- Summary: Add Partitioned State Backend Based on RocksDB Key: FLINK-3278 URL: https://issues.apache.org/jira/browse/FLINK-3278 Project: Flink Issue

[jira] [Created] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder

2016-02-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3400: --- Summary: RocksDB Backend does not work when not in Flink lib folder Key: FLINK-3400 URL: https://issues.apache.org/jira/browse/FLINK-3400 Project: Flink

[jira] [Created] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config

2016-02-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3417: --- Summary: Add RocksDB StateBackendFactory and integrate with Flink Config Key: FLINK-3417 URL: https://issues.apache.org/jira/browse/FLINK-3417 Project: Flink

[jira] [Created] (FLINK-3419) Drop partitionByHash from DataStream

2016-02-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3419: --- Summary: Drop partitionByHash from DataStream Key: FLINK-3419 URL: https://issues.apache.org/jira/browse/FLINK-3419 Project: Flink Issue Type:

[jira] [Created] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer

2016-02-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3430: --- Summary: Remove "no POJO" warning in TypeAnalyzer Key: FLINK-3430 URL: https://issues.apache.org/jira/browse/FLINK-3430 Project: Flink Issue Type:

[jira] [Created] (FLINK-3436) Remove ComplexIntegrationITCase

2016-02-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3436: --- Summary: Remove ComplexIntegrationITCase Key: FLINK-3436 URL: https://issues.apache.org/jira/browse/FLINK-3436 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource

2016-02-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3439: --- Summary: Remove final Long.MAX_VALUE Watermark in StreamSource Key: FLINK-3439 URL: https://issues.apache.org/jira/browse/FLINK-3439 Project: Flink

[jira] [Created] (FLINK-3614) Remove Non-Keyed Window Operator

2016-03-15 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3614: --- Summary: Remove Non-Keyed Window Operator Key: FLINK-3614 URL: https://issues.apache.org/jira/browse/FLINK-3614 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3714) Add Support for "Allowed Lateness"

2016-04-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3714: --- Summary: Add Support for "Allowed Lateness" Key: FLINK-3714 URL: https://issues.apache.org/jira/browse/FLINK-3714 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

2016-04-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3715: --- Summary: Move Accumulating/Discarding from Trigger to WindowOperator Key: FLINK-3715 URL: https://issues.apache.org/jira/browse/FLINK-3715 Project: Flink

[jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

2016-04-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3706: --- Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable Key: FLINK-3706 URL: https://issues.apache.org/jira/browse/FLINK-3706 Project: Flink

[jira] [Created] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer

2016-04-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3747: --- Summary: Consolidate TimestampAssigner Methods in Kafka Consumer Key: FLINK-3747 URL: https://issues.apache.org/jira/browse/FLINK-3747 Project: Flink

[jira] [Created] (FLINK-3730) Fix RocksDB Local Directory Initialization

2016-04-11 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3730: --- Summary: Fix RocksDB Local Directory Initialization Key: FLINK-3730 URL: https://issues.apache.org/jira/browse/FLINK-3730 Project: Flink Issue Type:

[jira] [Created] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers

2016-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3646: --- Summary: Use Processing-Time Clock in Window Assigners/Triggers Key: FLINK-3646 URL: https://issues.apache.org/jira/browse/FLINK-3646 Project: Flink

[jira] [Created] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service

2016-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3647: --- Summary: Change StreamSource to use Processing-Time Clock Service Key: FLINK-3647 URL: https://issues.apache.org/jira/browse/FLINK-3647 Project: Flink

[jira] [Created] (FLINK-3648) Introduce Trigger Test Harness

2016-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3648: --- Summary: Introduce Trigger Test Harness Key: FLINK-3648 URL: https://issues.apache.org/jira/browse/FLINK-3648 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State

2016-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3654: --- Summary: Disable Write-Ahead-Log in RocksDB State Key: FLINK-3654 URL: https://issues.apache.org/jira/browse/FLINK-3654 Project: Flink Issue Type:

[jira] [Created] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side

2016-03-23 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3659: --- Summary: Allow ConnectedStreams to Be Keyed on Only One Side Key: FLINK-3659 URL: https://issues.apache.org/jira/browse/FLINK-3659 Project: Flink

[jira] [Created] (FLINK-3643) Improve Window Triggers

2016-03-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3643: --- Summary: Improve Window Triggers Key: FLINK-3643 URL: https://issues.apache.org/jira/browse/FLINK-3643 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3669) WindowOperator registers a log of timers at StreamTask

2016-03-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3669: --- Summary: WindowOperator registers a log of timers at StreamTask Key: FLINK-3669 URL: https://issues.apache.org/jira/browse/FLINK-3669 Project: Flink

[jira] [Created] (FLINK-3591) Replace Quickstart K-Means Example by Streaming Example

2016-03-08 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3591: --- Summary: Replace Quickstart K-Means Example by Streaming Example Key: FLINK-3591 URL: https://issues.apache.org/jira/browse/FLINK-3591 Project: Flink

[jira] [Created] (FLINK-3581) Add Non-Keyed Window Trigger

2016-03-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3581: --- Summary: Add Non-Keyed Window Trigger Key: FLINK-3581 URL: https://issues.apache.org/jira/browse/FLINK-3581 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

2016-03-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3582: --- Summary: Add Iterator over State for All Keys in Partitioned State Key: FLINK-3582 URL: https://issues.apache.org/jira/browse/FLINK-3582 Project: Flink

[jira] [Created] (FLINK-3575) Update Working With State Section in Doc

2016-03-03 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3575: --- Summary: Update Working With State Section in Doc Key: FLINK-3575 URL: https://issues.apache.org/jira/browse/FLINK-3575 Project: Flink Issue Type:

[jira] [Created] (FLINK-3651) Fix faulty RollingSink Restore

2016-03-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3651: --- Summary: Fix faulty RollingSink Restore Key: FLINK-3651 URL: https://issues.apache.org/jira/browse/FLINK-3651 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3760) Fix StateDescriptor.readObject

2016-04-14 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3760: --- Summary: Fix StateDescriptor.readObject Key: FLINK-3760 URL: https://issues.apache.org/jira/browse/FLINK-3760 Project: Flink Issue Type: Bug

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

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

  1   2   3   4   5   >