Commits

Commits on Jul 26, 2016

[FLINK-4207] WindowOperator becomes very slow with allowed lateness
kl0u
committedJul 26, 2016

Commits on Jul 20, 2016

[FLINK-3956] Make FileInputFormats independent from Configuration

kl0u
authored and
aljoscha
committedJul 20, 2016
[hotfix] Fixes broken TopSpeedWindowing scala example

kl0u
authored and
tillrohrmann
committedJul 20, 2016

Commits on Jul 7, 2016

[FLINK-3648] Introduce Trigger Test Harness

kl0u
authored and
aljoscha
committedJul 7, 2016

Commits on Jul 5, 2016

[FLINK-4133] Reflect streaming file source changes in documentation

kl0u
authored and
rmetzger
committedJul 5, 2016

Commits on Jun 30, 2016

[FLINK-4075] Fix unstable ContinuousFileProcessingCheckpointITCase

kl0u
authored and
aljoscha
committedJun 30, 2016

Commits on Jun 27, 2016

Fixing typos in the javadocs.

kl0u
authored and
aljoscha
committedJun 27, 2016
[FLINK-3647] Change StreamSource to use Processing-Time Clock Service

kl0u
authored and
aljoscha
committedJun 27, 2016
[FLINK-3464] Use Processing-Time Clock in Window Assigners/Triggers

kl0u
authored and
aljoscha
committedJun 27, 2016

Commits on Jun 22, 2016

[FLINK-3752] Add Per-Kafka-Partition Watermark Generation to the docs

kl0u
authored and
rmetzger
committedJun 22, 2016

Commits on Jun 21, 2016

[FLINK-3714] Add Support for "Allowed Lateness"

kl0u
authored and
aljoscha
committedJun 21, 2016

Commits on Jun 17, 2016

[FLINK-4075] ContinuousFileProcessingCheckpointITCase failed on Travis

kl0u
authored and
aljoscha
committedJun 17, 2016

Commits on Jun 15, 2016

[FLINK-4024] [streaming] Fix InputFormat lifecycle in FileSourceFunction.

kl0u
authored and
fhueske
committedJun 15, 2016

Commits on Jun 14, 2016

[FLINK-2314] Make Streaming File Sources Persistent

kl0u
authored and
aljoscha
committedJun 14, 2016
[FLINK-3896] Allow a StreamTask to be Externally Cancelled

kl0u
authored and
aljoscha
committedJun 14, 2016

Commits on May 24, 2016

[FLINK-3963] Removed shaded import

kl0u
authored and
mxm
committedMay 24, 2016

Commits on May 17, 2016

[FLINK-3826] [tests] Fix test condition in StreamCheckpointingITCase

kl0u
authored and
StephanEwen
committedMay 17, 2016

Commits on Apr 28, 2016

[FLINK-3428] Adds a fixed time trailing watermark extractor.

kl0u
authored and
rmetzger
committedApr 28, 2016

Commits on Apr 12, 2016

[FLINK-3375] [kafka connector] Add per-Kafka-partition watermark generation to the FlinkKafkaConsumer

kl0u
authored and
StephanEwen
committedApr 12, 2016

Commits on Apr 4, 2016

[hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs

kl0u
authored and
StephanEwen
committedApr 4, 2016

Commits on Mar 14, 2016

[FLINK-2523] Make the task cancellation interval configurable

kl0u
authored and
zentol
committedMar 14, 2016

Commits on Mar 11, 2016

[FLINK-3327] ExecutionConfig to JobGraph

kl0u
authored and
zentol
committedMar 11, 2016

Commits on Feb 23, 2016

FLINK-2213: Makes the number of vcores per YARN container configurable.

kl0u
authored and
rmetzger
committedFeb 23, 2016

Commits on Feb 16, 2016

FLINK-2380: allow the specification of a default filesystem scheme in the flink configuration file.

kl0u
authored and
rmetzger
committedFeb 16, 2016
[FLINK-3304] Making the Avro Schema serializable.

kl0u
authored and
rmetzger
committedFeb 16, 2016

Commits on Feb 3, 2016

[FLINK-3254] [dataSet] Adding functionality to support the CombineFunction contract.

kl0u
authored and
fhueske
committedFeb 3, 2016

Commits on Jan 26, 2016

[FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping.

kl0u
authored and
fhueske
committedJan 26, 2016

Commits on Oct 6, 2015

Create a deep-copy of the record when changing timestamps.

kl0u
authored and
aljoscha
committedOct 6, 2015