Commits

Commits on Feb 28, 2017

[FLINK-5501] [runtime] Followups and improvements to RunningJobsRegistry
StephanEwen
committedFeb 28, 2017
[FLINK-5501] [runtime] Extend RunningJobRegistry to job status created/running/done

tiemsn
authored and
StephanEwen
committedFeb 28, 2017
[hotfix] [runtime] Reduce the gazillion deprecation warnings from the backwards-compatible savepoint path
StephanEwen
committedFeb 28, 2017
[FLINK-5420] [cep] Make the CEP operators rescalable
kl0u
committedFeb 28, 2017
[FLINK-5157] [streaming] Introduce ProcessAllWindowFunction

VenturaDelMonte
authored and
aljoscha
committedFeb 28, 2017
[FLINK-3903] [docs] Add Homebrew installation docs

p16i
authored and
uce
committedFeb 28, 2017
[FLINK-5871] [cep] Enforce uniqueness of pattern names in CEP.
kl0u
committedFeb 28, 2017

Commits on Feb 27, 2017

Commits on Feb 26, 2017

[FLINK-5896][docs] improve readability of event time docs

David Anderson
authored and
uce
committedFeb 26, 2017

Commits on Feb 24, 2017

[FLINK-5899] [table] Fix translation of batch event-time tumbling windows with non-partial aggregation functions.

shaoxuan-wang
authored and
fhueske
committedFeb 24, 2017
[FLINK-5710] [table] Add proctime() function to indicate processing time in Stream SQL.

Haohui Mai
authored and
fhueske
committedFeb 24, 2017
[hotfix] [core] Changing PublicEvolving anntoation of Archiveable to Internal.
fhueske
committedFeb 24, 2017
[FLINK-5487] [elasticsearch] At-least-once Elasticsearch Sink
tzulitai
committedFeb 24, 2017
[FLINK-5353] [elasticsearch] User-provided failure handler for ElasticsearchSink
tzulitai
committedFeb 24, 2017
[FLINK-5122] [elasticsearch] Retry temporary Elasticsearch request errors.

static-max
authored and
tzulitai
committedFeb 24, 2017
[FLINK-5799] [rpc] Let RpcService.scheduleRunnable return a ScheduledFuture
tillrohrmann
committedFeb 24, 2017
[FLINK-5798] [rpc] Let the RpcService provide a ScheduledExecutorService
tillrohrmann
committedFeb 24, 2017
[FLINK-5743] Mark WindowedStream.aggregate() methods as PublicEvolving
aljoscha
committedFeb 24, 2017
[FLINK-5885] [docs] Fix Cassandra Scala snippet

Andrea Sella
authored and
StephanEwen
committedFeb 24, 2017
[FLINK-5854] [core] Add base Flink Exception classes
StephanEwen
committedFeb 24, 2017
[hotfix] [tests] Remove sysout logging in KvStateLocationTest
StephanEwen
committedFeb 24, 2017
[FLINK-5895] [runtime] Decrease logging aggressiveness of FileSystemSafetyNet
StephanEwen
committedFeb 24, 2017
[FLINK-5845] [cep] Unify keyed and non-keyed operators.
kl0u
committedFeb 24, 2017
[FLINK-5767] [table] Add interface for user-defined aggregate functions and built-in aggregate functions.

shaoxuan-wang
authored and
fhueske
committedFeb 24, 2017

Commits on Feb 23, 2017

[hotfix] [checkpoints] Remove equals()/hashCode() from CompletedCheckpoint as semantic equality is not well defined.
StephanEwen
committedFeb 23, 2017
[FLINK-5887] [checkpointing] Make CheckpointBarrier type immutable.
StephanEwen
committedFeb 23, 2017
[FLINK-5763] [checkpoints] Followup on adding CheckpointOptions
StephanEwen
committedFeb 23, 2017
[FLINK-5763] [checkpoints] Add CheckpointOptions

uce
authored and
StephanEwen
committedFeb 23, 2017
[hotfix] [docs] Fix JavaDoc errors in 'flink-streaming-java'
StephanEwen
committedFeb 23, 2017
[FLINK-4856] Add MapState for keyed state

xiaogang.sxg
authored and
aljoscha
committedFeb 23, 2017
[hotfix] [kafka] Indent Kafka010FetcherTest with tabs instead of spaces
tzulitai
committedFeb 23, 2017