- 02 2月, 2016 6 次提交
-
-
由 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 提交于
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
[hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers.
-
- 01 2月, 2016 9 次提交
-
-
由 Maximilian Michels 提交于
The methods snapshotState and notifyCheckpointComplete are always mutually exclusive. The RMQSource relies on this but the test makes a false assumption when it calls those two methods at the same time. This closes #1569.
-
由 Maximilian Michels 提交于
This reverts commit 6b01a890. The introduced locks are not necessary. The checkpointing test case only needs to be adapted to the checkpointing runtime behavior.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
The auto-magic for Joda Time was limited to very few classes. It was intransparent what cases would be handled.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
Adds message passing between Hadoop's async resource manager client and the YarnJobManager actor. This closes #1561.
-
- 30 1月, 2016 1 次提交
-
-
由 Márton Balassi 提交于
This is needed for streaming library features, is identical to the batch API. Closes #1480
-
- 29 1月, 2016 1 次提交
-
-
由 Till Rohrmann 提交于
Henceforth, we shall only use the term lower in the context of timestamps to denote that an event has occurred before another event.
-
- 28 1月, 2016 10 次提交
-
-
由 Robert Metzger 提交于
This closes #1534
-
由 Subhobrata Dey 提交于
This closes #1551
-
由 Aljoscha Krettek 提交于
Before, the user-specified StateBackedn would not be set when generating the JobGraph if checkpointing was disabled. This closes #1516
-
由 smarthi 提交于
This closes #1552
-
由 Aljoscha Krettek 提交于
This closes #1542
-
由 Stephan Ewen 提交于
This keeps the log cleaner in case of failed timers while canceling tasks.
-
由 Stephan Ewen 提交于
-
由 Greg Hogan 提交于
Several packages had been updated locally by users when compiling the templates without changing the version in bower.json. The following packages have been explicitly updated. jquery 2.1.4 → 2.2.0 angular 1.3.15 → 1.4.8 angular-moment 0.9.2 → 0.10.3 angular-ui-router 0.2.13 → 0.2.15 bootstrap 3.3.5 → 3.3.6 d3 3.5.5 → 3.5.12 dagre-d3 0.4.10 → 0.4.11 font-awesome 4.3.0 → 4.5.0 This closes #1525
-
由 zentol 提交于
-parallelism is stored Value object within the OperationInfo, so it can be passed as a reference to multiple operations (in cases where a set is internally executed as multiple operations) -setParallelism is called for every DataSet with either a user-set value or env.getParallelism -added a DataSink set, providing access to name() and setParallelism() for sinks
-
由 twalthr 提交于
This closes #1465.
-
- 27 1月, 2016 10 次提交
-
-
由 zentol 提交于
-identifier saved in java OpInfo -changed default values to prevent null exceptions -all operations use the same routine to transfer parameters -PyPlRcv can handle Tuple0 -labeled py OpInfo fields as transferred/internal -fixed broadcast OpInfo not having correct identifier -removed unused projection code
-
由 Ufuk Celebi 提交于
[FLINK-3258] [runtime, streaming-java, tests] Move registerInputOutput code to invoke and remove registerInputOutput This closes #1538
-
由 Ufuk Celebi 提交于
-
由 Aljoscha Krettek 提交于
Before, it could happen that a Task is canceled during snapshotting. Some State Backends would silently swallow exceptions resulting from this and the Task would get stuck until the cleanup logic gets to it. Now, we rethrow a CancelTaskException if isRunning is false in StreamTask after performing snapshots. This also moves the logic that swallows exceptions in case a task is not running anymore from StreamTask to the async caller in Task.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
- add suffixes - adapt change-scala-version script This closes #1529.
-
由 chengxiang li 提交于
this commit support full outer join includes: 1. left outer join with REPARTITION_HASH_FIRST. 2. right outer join with REPARTITION_HASH_SECOND. 3. fullouter join with REPARTITION_HASH_FIRST and REPARTITION_HASH_SECOND. this close #1469
-
- 26 1月, 2016 3 次提交
-
-
由 smarthi 提交于
This closes #1539.
-
由 Stefano Baghino 提交于
This closes #1550
-
由 Kostas Kloudas 提交于
This closes #1548
-