Commits

Branch selector

 master

User selector

kl0u

Datepicker

All time

Commit History

Commits on Sep 23, 2016

• [FLINK-4494] Expose the TimeServiceProvider from the Task to each Operator.

  

  kl0u

  authored and

  aljoscha

  committed
  ffff299

  Copy full SHA for ffff299

• [FLINK-4496] Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

  

  kl0u

  authored and

  aljoscha

  committed
  4779c7e

  Copy full SHA for 4779c7e

Commits on Sep 1, 2016

• [hotfix] Fixes unstable ContinuousFileMonitoringTest.

  Show description for 4a100fa
  

  kl0u

  authored and

  aljoscha

  committed
  4a100fa

  Copy full SHA for 4a100fa

Commits on Aug 18, 2016

• [hotfix] Fix Redis Sink to fail at opening if Redis is not initialized.

  Show description for e9a0672
  

  kl0u

  authored and

  rmetzger

  committed
  e9a0672

  Copy full SHA for e9a0672

Commits on Jul 26, 2016

• [FLINK-4207] WindowOperator becomes very slow with allowed lateness

  kl0u

  committed
  12bf7c1

  Copy full SHA for 12bf7c1

Commits on Jul 20, 2016

• [FLINK-3956] Make FileInputFormats independent from Configuration

  Show description for 25b6f22
  

  kl0u

  authored and

  aljoscha

  committed
  25b6f22

  Copy full SHA for 25b6f22

• [hotfix] Fixes broken TopSpeedWindowing scala example

  Show description for 2391683
  

  kl0u

  authored and

  tillrohrmann

  committed
  2391683

  Copy full SHA for 2391683

Commits on Jul 7, 2016

• [FLINK-3648] Introduce Trigger Test Harness

  

  kl0u

  authored and

  aljoscha

  committed
  7fb9417

  Copy full SHA for 7fb9417

Commits on Jul 5, 2016

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

  Show description for 0c80928
  

  kl0u

  authored and

  rmetzger

  committed
  0c80928

  Copy full SHA for 0c80928

Commits on Jun 30, 2016

• [FLINK-4075] Fix unstable ContinuousFileProcessingCheckpointITCase

  

  kl0u

  authored and

  aljoscha

  committed
  bd273a8

  Copy full SHA for bd273a8

Commits on Jun 27, 2016

• Fixing typos in the javadocs.

  

  kl0u

  authored and

  aljoscha

  committed
  8803d15

  Copy full SHA for 8803d15

• [FLINK-3647] Change StreamSource to use Processing-Time Clock Service

  

  kl0u

  authored and

  aljoscha

  committed
  819fb27

  Copy full SHA for 819fb27

• [FLINK-3464] Use Processing-Time Clock in Window Assigners/Triggers

  Show description for 4b5a789
  

  kl0u

  authored and

  aljoscha

  committed
  4b5a789

  Copy full SHA for 4b5a789

Commits on Jun 22, 2016

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

  Show description for 7ec6d7b
  

  kl0u

  authored and

  rmetzger

  committed
  7ec6d7b

  Copy full SHA for 7ec6d7b

Commits on Jun 21, 2016

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

  Show description for 34a8b03
  

  kl0u

  authored and

  aljoscha

  committed
  34a8b03

  Copy full SHA for 34a8b03

Commits on Jun 17, 2016

• [FLINK-4075] ContinuousFileProcessingCheckpointITCase failed on Travis

  

  kl0u

  authored and

  aljoscha

  committed
  fc4abd7

  Copy full SHA for fc4abd7

Commits on Jun 15, 2016

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

  Show description for fe0eb60
  

  kl0u

  authored and

  fhueske

  committed
  fe0eb60

  Copy full SHA for fe0eb60

Commits on Jun 14, 2016

• [FLINK-2314] Make Streaming File Sources Persistent

  Show description for d353895
  

  kl0u

  authored and

  aljoscha

  committed
  d353895

  Copy full SHA for d353895

• [FLINK-3896] Allow a StreamTask to be Externally Cancelled

  Show description for bc19486
  

  kl0u

  authored and

  aljoscha

  committed
  bc19486

  Copy full SHA for bc19486

Commits on May 24, 2016

• [FLINK-3963] Removed shaded import

  Show description for cbee4ef
  

  kl0u

  authored and

  mxm

  committed
  cbee4ef

  Copy full SHA for cbee4ef

Commits on May 17, 2016

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

  Show description for 91a845d
  

  kl0u

  authored and

  StephanEwen

  committed
  91a845d

  Copy full SHA for 91a845d

Commits on Apr 28, 2016

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

  Show description for 6225aa6
  

  kl0u

  authored and

  rmetzger

  committed
  6225aa6

  Copy full SHA for 6225aa6

Commits on Apr 12, 2016

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

  Show description for 0ac1549
  

  kl0u

  authored and

  StephanEwen

  committed
  0ac1549

  Copy full SHA for 0ac1549

Commits on Apr 4, 2016

• [hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs

  Show description for 6593e48
  

  kl0u

  authored and

  StephanEwen

  committed
  6593e48

  Copy full SHA for 6593e48

Commits on Mar 14, 2016

• [FLINK-2523] Make the task cancellation interval configurable

  Show description for 4f11b40
  

  kl0u

  authored and

  zentol

  committed
  4f11b40

  Copy full SHA for 4f11b40

Commits on Mar 11, 2016

• [FLINK-3327] ExecutionConfig to JobGraph

  Show description for 0f8d76c
  

  kl0u

  authored and

  zentol

  committed
  0f8d76c

  Copy full SHA for 0f8d76c

Commits on Feb 23, 2016

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

  Show description for de21630
  

  kl0u

  authored and

  rmetzger

  committed
  de21630

  Copy full SHA for de21630

Commits on Feb 16, 2016

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

  Show description for 76d3a63
  

  kl0u

  authored and

  rmetzger

  committed
  76d3a63

  Copy full SHA for 76d3a63

• [FLINK-3304] Making the Avro Schema serializable.

  Show description for c658763
  

  kl0u

  authored and

  rmetzger

  committed
  c658763

  Copy full SHA for c658763

Commits on Feb 3, 2016

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

  Show description for aabb268
  

  kl0u

  authored and

  fhueske

  committed
  aabb268

  Copy full SHA for aabb268

Commits on Jan 26, 2016

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

  Show description for 902d420
  

  kl0u

  authored and

  fhueske

  committed
  902d420

  Copy full SHA for 902d420

Commits on Oct 6, 2015

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

  

  kl0u

  authored and

  aljoscha

  committed
  af1e03e

  Copy full SHA for af1e03e