- 05 2月, 2016 5 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Stefano Baghino 提交于
This closes #1592.
-
由 Aljoscha Krettek 提交于
-
由 Márton Balassi 提交于
This closes #1574
-
由 Márton Balassi 提交于
-
- 04 2月, 2016 16 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
This closes #1584
-
由 Kostas Kloudas 提交于
This closes #1568
-
由 Greg Hogan 提交于
Parallelizes cluster start-up and tear-down when pdsh is available This closes #1523
-
由 Johannes 提交于
Added a method to set a default application name for the Flink Yarn session CLI. Switched the order, such that this name can now be overwritten by the command line. This closes #1558
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This changes window operator to use the new partitioned state abstraction for keeping window contents instead of custom internal state and the checkpointed interface. For now, timers are still kept as custom checkpointed state, however. WindowOperator now expects a StateIdentifier for MergingState, this can either be for ReducingState or ListState but WindowOperator is agnostic to the type of State. Also the signature of WindowFunction is changed to include the type of intermediate input. For example, if a ReducingState is used the input of the WindowFunction is T (where T is the input type). If using a ListState the input of the WindowFunction would be of type Iterable[T].
-
由 Aljoscha Krettek 提交于
Add new state types ValueState, ListState and ReducingState, where ListState and ReducingState derive from interface MergingState. ValueState behaves exactly the same as OperatorState. MergingState is a stateful list to which elements can be added and for which the elements that it contains can be obtained. If using a ListState the list of elements is actually kept, for a ReducingState a reduce function is used to combine all added elements into one. To create a ValueState the user passes a ValueStateIdentifier to StreamingRuntimeContext.getPartitionedState() while they would pass a ListStateIdentifier or ReducingStateIdentifier for the other state types. This change is necessary to give the system more information about the nature of the operator state. We want this to be able to do incremental snapshots. This would not be possible, for example, if the user had a List as a state. Inside OperatorState this list would be opaque and Flink could not create good incremental snapshots. This also refactors the StateBackend. Before, the logic for partitioned state was spread out over StreamingRuntimeContext, AbstractStreamOperator and StateBackend. Now it is consolidated in StateBackend. This also adds support for partitioned state in two-input operators.
-
由 Ufuk Celebi 提交于
This closes #1582, #1576.
-
由 Ufuk Celebi 提交于
Old guides are redirected to the new pages.
-
- 03 2月, 2016 8 次提交
-
-
由 Till Rohrmann 提交于
-
由 Maximilian Michels 提交于
-
由 Till Rohrmann 提交于
The LegacyFetcher used the given KeyedDeserializationSchema across multiple threads even though it is not thread-safe. This commit fixes the problem by cloning the KeyedDeserializationSchema before giving it to the SimpleConsumerThread. Add clone method for Java serializable objects to InstantiationUtil This closes #1577.
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
[FLINK-3314] [streaming] Fix case where early cancel messages do not properly cancel a stream operator.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
- Clean up generics - Clean and safe disposal of initialized resources - Add names to asynchronous materialization threads - Fix concurrent modification of materialization threads set
-
- 02 2月, 2016 11 次提交
-
-
由 Stephan Ewen 提交于
This deactivates the validation of results, which is not reliably possible under the current model (timeout on feedback). This test for now only checks that the job executes properly. Also adds proper logging property files for the examples projects.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
This closes #1573
-
由 Robert Metzger 提交于
-
由 Till Rohrmann 提交于
Implements NFA using the SharedBuffer Implements NFACompiler to compile a Pattern into a NFA Add CEP operator Makes NFA and SharedBuffer serializable Add serializability support to SharedBuffer and NFA Add keyed cep pattern operator Adds CEP documentation Adds online documentation for the CEP library Copies sequence events before giving them to the UDF Fix correct scala type suffixes This closes #1557.
-
由 Robert Metzger 提交于
-
由 vasia 提交于
This closes #1514
-
由 chengxiang li 提交于
-