Commits

History for

Commits on May 23, 2017

[FLINK-6656] [cep] Change element PriorityQueue to MapState.
kl0u
committedMay 23, 2017

Commits on May 22, 2017

[FLINK-6482] [core] Add nested serializers to config snapshots of composite serializers
tzulitai
committedMay 22, 2017

Commits on May 19, 2017

[hotfix][rat] Add exclusion for all test snapshots/savepoints
zentol
committedMay 19, 2017
[FLINK-6634] [cep] NFASerializer serializes ComputationState counter.
kl0u
committedMay 19, 2017

Commits on May 18, 2017

[FLINK-6624] [cep] Fix SharedBuffer#hashCode().
kl0u
committedMay 18, 2017

Commits on May 17, 2017

[FLINK-6609] [cep] Fix wrong version assignment with multiple TAKEs.

dawidwys
authored and
kl0u
committedMay 17, 2017
[FLINK-6604] [cep] Remove java serialization from the library.
kl0u
committedMay 17, 2017
[hotfix] [cep] Remove unused keySelector in operator.
kl0u
committedMay 17, 2017
[FLINK-6578] [cep] Fix self-loop handling in SharedBuffer.
kl0u
committedMay 17, 2017
[FLINK-6255] [cep] Remove PatternStream.getSideOutput().
kl0u
committedMay 17, 2017
[FLINK-6536] [cep] Improve error message in SharedBuffer::put().
kl0u
committedMay 17, 2017
[FLINK-6371] [cep] NFA return matched patterns as Map<String, List<T>>.
kl0u
committedMay 17, 2017

Commits on May 13, 2017

[FLINK-6554] [core] Make CompatibilityResult options more explicitly defined
tzulitai
committedMay 13, 2017

Commits on May 11, 2017

[FLINK-6414] [build] Use scala.binary.version in place of change-scala-version.sh

greghogan
authored and
StephanEwen
committedMay 11, 2017

Commits on May 8, 2017

Update Flink version to 1.4-SNAPSHOT
rmetzger
committedMay 8, 2017

Commits on May 7, 2017

[FLINK-6178] [core] Introduce TypeDeserializer interface for CompatibilityResult
tzulitai
committedMay 7, 2017
[FLINK-6178] [core] Allow serializer upgrades for managed state
tzulitai
committedMay 7, 2017

Commits on May 5, 2017

[FLINK-6463] [cep] Throw exception when NOT-NEXT is after OPTIONAL.
kl0u
committedMay 5, 2017
[FLINK-3320] Add NOT pattern support to CEP's pattern API

dawidwys
authored and
kl0u
committedMay 5, 2017

Commits on May 4, 2017

[FLINK-6445] [cep] Fix NPE in no-condition patterns.
kl0u
committedMay 4, 2017

Commits on May 3, 2017

[FLINK-5969] Add CEPFrom12MigrationTest
aljoscha
committedMay 3, 2017
[FLINK-5969] Remove watermark callback service
aljoscha
committedMay 3, 2017

Commits on May 2, 2017

[hotfix] [build] Remove unneeded logback-test.xml files
StephanEwen
committedMay 2, 2017

Commits on Apr 28, 2017

[FLINK-6208] [cep] Implement skip till next match strategy

dawidwys
authored and
kl0u
committedApr 28, 2017

Commits on Apr 26, 2017

[FLINK-6356] [cep] Make times() eager by default and allow allowCombinations().
kl0u
committedApr 26, 2017
[FLINK-6248] [cep] Make the optional() available to all offered patterns.
kl0u
committedApr 26, 2017

Commits on Apr 21, 2017

[FLINK-6290] [CEP] Fix SharedBuffer release when having multiple edges between entries

dawidwys
authored and
StephanEwen
committedApr 21, 2017

Commits on Apr 8, 2017

[FLINK-6282] Fix some spelling mistake

lingjinjiang
authored and
greghogan
committedApr 8, 2017

Commits on Apr 5, 2017

[FLINK-6265] [cep] Fix consecutive() for times()
kl0u
committedApr 5, 2017

Commits on Apr 4, 2017

[FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream
kl0u
committedApr 4, 2017

Commits on Mar 31, 2017

[FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output.
kl0u
committedMar 31, 2017

Commits on Mar 30, 2017

[FLINK-6165] [cep] Implement internal continuity for looping states.

dawidwys
authored and
kl0u
committedMar 30, 2017

Commits on Mar 28, 2017

[FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams

xiaogang.sxg
authored and
StefanRRichter
committedMar 28, 2017
comments
kl0u
committedMar 28, 2017

Commits on Mar 27, 2017

[FLINK-6197] [cep] Add support for iterative conditions.
kl0u
committedMar 27, 2017