- 31 3月, 2017 9 次提交
-
-
由 Greg Hogan 提交于
Provide compact and efficiently serializable and comparable array implementations for Flink mutable Value types and Java primitives. This cloeses #3382
-
由 Greg Hogan 提交于
WorksetIterationNode#instantiate loops over all solution and work set candidates. Since the solution set reference is modified in place when the predecessor node can be used in its place, swith this variable to the inner loop. This closes #3563
-
由 WangTaoTheTonic 提交于
This closes #3408.
-
由 shaoxuan-wang 提交于
This closes #3647.
-
由 kl0u 提交于
With this, the CEP library assumes correctness of the watermark and considers as late, events that arrive having a timestamp smaller than that of the last seen watermark. Late events are not silently dropped, but the user can specify to send them to a side output.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3458.
-
由 Tony Wei 提交于
[FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer This closes #3651.
-
由 Stefano Bortoli 提交于
This closes #3653. This closes #3574.
-
由 hongyuhong 00223286 提交于
This closes #3649.
-
- 30 3月, 2017 4 次提交
-
-
由 Dawid Wysakowicz 提交于
Allows looping states (oneOrMore, zeroOrMore, times) to specify if they want their elements to be consecutive or allow non-matching elements in-between.
-
由 金竹 提交于
This closes #3629.
-
由 Stephan Ewen 提交于
Replace the method via identical method 'getTaskNameWithSubtaskIndex'.
-
由 Stephan Ewen 提交于
-
- 29 3月, 2017 8 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
ExecutionGraph-based metrics should be in their own package 'org.apache.flink.runtime.executiongraph.metrics'. They are instantiated by whoever builds the execution graph, but not by the execution graph itself. This separates concerns more elegantly.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Tony Wei 提交于
This closes #3636. This closes #3637.
-
由 xiaogang.sxg 提交于
[FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams
-
由 Stefan Richter 提交于
-
- 28 3月, 2017 2 次提交
-
-
由 kl0u 提交于
-
由 kl0u 提交于
So far, the where clause only supported simple FilterFunction conditions. With this, we add support for conditions where an event is accepted not only based on its own properties, e.g. name, as it was before, but also based on some statistic computed over previously accepted events in the pattern, e.g. if the price is higher than the average of the prices of the previously accepted events.
-
- 27 3月, 2017 2 次提交
-
-
由 Greg Hogan 提交于
Create interface for parsing command-line parameters using ParameterTool and generic implementations for boolean, long, double, string, choice. This closes #3433
-
由 Patrick Lucas 提交于
This closes #3618.
-
- 25 3月, 2017 10 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Seth Wiesman 提交于
-
由 tonycox 提交于
This closes #3269.
-
由 Fabian Hueske 提交于
-
由 hongyuhong 00223286 提交于
This closes #3386.
-
由 金竹 提交于
This closes #3585.
-
由 hequn.chq 提交于
[FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. This closes #3564.
-
由 Fabian Hueske 提交于
-
由 jingzhang 提交于
This closes #3409.
-
由 DmytroShkvyra 提交于
Decrease the time to run TravisCI builds and reduce OOM by - increasing the heap size - switching to Java's serial garbage collector - removing the UseGCOverheadLimit option This closes #3571
-
- 24 3月, 2017 4 次提交
-
-
由 Greg Hogan 提交于
The initial fix for this ticket is not working on larger data sets. Reduce supports returning the left input, right input, a new object, or a locally reused object. The trouble with the initial fix was that the returned local object was reusing fields from the input tuples. The problem is with ReduceDriver#run managing two values (reuse1 and reuse2) and with a third, local value returned by GatherSumApplyIteration.SumUDF. After the first grouping value.f1 == reuse1.f1. Following UDF calls may swap value.f1 and reuse2.f1, which causes reuse1.f1 == reuse2.f1. With an odd number of swaps the next grouping will reduce with reuse1 and reuse2 sharing a field and deserialization will overwrite stored values. The simple fix is to only use and return the provided inputs. This closes #3515
-
由 Ufuk Celebi 提交于
This closes #3606.
-
由 Till Rohrmann 提交于
Currently, the TestingSerialRpcService does not play well together with the MainThreadValidatorUtil which assumes that rpc calls are dispatched to a mailbox from where they are picked up. In order to support the TestingSerialRpcService we will have to extend the MainThreadValidatorUtil to allow entering the main thread if the RpcEndpoint already runs in the context of the main thread.
-
由 Aljoscha Krettek 提交于
This commit also renames isCompatibleWith() to canRestoreFrom() to make the method asymetric because in the case of KryoSerializer we can restore from state that was stored using no registed types/serializers while the other way around is not possible. This closes #3534. This closes #3603.
-
- 23 3月, 2017 1 次提交
-
-
由 Aljoscha Krettek 提交于
This closes #3587.
-