Commits

Branch selector

 87195a8

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 21, 2016

• [FLINK-3714] Extend comments in WindowOperatorTest

  Show description for 87195a8
  aljoscha

  committed
  87195a8

  Copy full SHA for 87195a8

• [FLINK-3714] Rename getCleanupTimeForWindow to cleanupTime in WindowOperator

  aljoscha

  committed
  62c5a3c

  Copy full SHA for 62c5a3c

• [FLINK-3714] Remove Unneccesary Timer in EventTimeTrigger

  Show description for 0104a92
  aljoscha

  committed
  0104a92

  Copy full SHA for 0104a92

• [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 20, 2016

• [FLINK-4090] Close of OutputStream should be in finally clause

  Show description for f2e9c52
  

  biaoma-ty

  authored and

  mxm

  committed
  f2e9c52

  Copy full SHA for f2e9c52

• [FLINK-4089][yarn] fix null check in Yarn client

  mxm

  committed
  e6320a4

  Copy full SHA for e6320a4

• [FLINK-4078] [dataSet] Introduce closure cleaning in CoGroup.where() and equaltTo()

  Show description for 78d3c61
  

  StefanRRichter

  authored and

  uce

  committed
  78d3c61

  Copy full SHA for 78d3c61

• [FLINK-4083] [dataSet] Introduce closure cleaning in Join.where() and equaltTo()

  Show description for 6a1144e
  

  StefanRRichter

  authored and

  uce

  committed
  6a1144e

  Copy full SHA for 6a1144e

Commits on Jun 18, 2016

• [FLINK-3641] Add documentation for DataSet distributed cache.

  Show description for ba62df1
  fhueske

  committed
  ba62df1

  Copy full SHA for ba62df1

• [FLINK-3949] [metrics] Add numSplitsProcessed counter metric.

  Show description for 5a0c268
  

  zentol

  authored and

  fhueske

  committed
  5a0c268

  Copy full SHA for 5a0c268

• [FLINK-3977] [dataStream] InternalWindowFunctions implement OutputTypeConfigurable.

  Show description for 18744b2
  fhueske

  committed
  18744b2

  Copy full SHA for 18744b2

Commits on Jun 17, 2016

• [FLINK-2259] [ml] Add Splitter for train, validation and test data set generation

  Show description for bce3550
  

  rawkintrevo

  authored and

  tillrohrmann

  committed
  bce3550

  Copy full SHA for bce3550

• [FLINK-2733] [tests] Harden ZooKeeperLeaderElectionTest

  Show description for 1a6bab3
  tillrohrmann

  committed
  1a6bab3

  Copy full SHA for 1a6bab3

• [FLINK-4009][tests] fix Scala Shell external library tests for IntelliJ

  mxm

  committed
  4d8cbec

  Copy full SHA for 4d8cbec

• [FLINK-4056] [tests] Harden SavepointITCase

  Show description for 07a7b73
  uce

  committed
  07a7b73

  Copy full SHA for 07a7b73

• [FLINK-4075] ContinuousFileProcessingCheckpointITCase failed on Travis

  

  kl0u

  authored and

  aljoscha

  committed
  fc4abd7

  Copy full SHA for fc4abd7

• [FLINK-4079] YARN properties file used for per-job cluster

  mxm

  committed
  ec6d975

  Copy full SHA for ec6d975

• [FLINK-3937] programmatic resuming of clusters

  Show description for f4ac852
  mxm

  committed
  f4ac852

  Copy full SHA for f4ac852

• [FLINK-3937] implement -yid option to Flink CLI

  Show description for 875d4d2
  

  rg-sebastian-k

  authored and

  mxm

  committed
  875d4d2

  Copy full SHA for 875d4d2

• [FLINK-3863] Yarn Cluster shutdown may fail if leader changed recently

  mxm

  committed
  9e98424

  Copy full SHA for 9e98424

• [FLINK-3667] refactor client communication classes

  Show description for f9b52a3
  mxm

  committed
  f9b52a3

  Copy full SHA for f9b52a3

Commits on Jun 16, 2016

• [FLINK-4077] [tableAPI] Register Pojo DataSet/DataStream as Table with field references.

  Show description for efc344a
  fhueske

  committed
  efc344a

  Copy full SHA for efc344a

• [FLINK-3649] [docs] Add documentation for DataSet minBy / maxBy.

  Show description for 298c009
  fhueske

  committed
  298c009

  Copy full SHA for 298c009

• [FLINK-3650] [dataSet] Add maxBy/minBy to Scala DataSet API

  Show description for 7cc6943
  

  Vasudevan

  authored and

  fhueske

  committed
  7cc6943

  Copy full SHA for 7cc6943

• [FLINK-3332] Address pull request review comments

  Show description for b63e19b
  

  zentol

  authored and

  rmetzger

  committed
  b63e19b

  Copy full SHA for b63e19b

• [FLINK-3311] Add At-Least-Once Cassandra connector

  

  Andrea Sella

  authored and

  rmetzger

  committed
  5930622

  Copy full SHA for 5930622

• [FLINK-3332] Add Exactly-Once Cassandra connector

  

  zentol

  authored and

  rmetzger

  committed
  a28a2d0

  Copy full SHA for a28a2d0

• [FLINK-3317] [cep] Introduce timeout handler to CEP operator

  Show description for 57ef6c3
  tillrohrmann

  committed
  57ef6c3

  Copy full SHA for 57ef6c3

• [FLINK-3949] Collect Metrics in Runtime Operators

  Show description for c78b3c4
  zentol

  committed
  c78b3c4

  Copy full SHA for c78b3c4

• [FLINK-4063] Add Metrics Support for Triggers

  aljoscha

  committed
  1049585

  Copy full SHA for 1049585

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

• [FLINK-3908] [core] Fix resetting of FieldParser error state.

  Show description for d874797
  

  fpompermaier

  authored and

  fhueske

  committed
  d874797

  Copy full SHA for d874797

• [FLINK-4028] Create correct TimeWindow in AbstractAlignedProcessingTimeWindowOperator

  aljoscha

  committed
  867be9b

  Copy full SHA for 867be9b

• [FLINK-4032] Replace all usage of Guava Preconditions

  Show description for c4bbed9
  zentol

  committed
  c4bbed9

  Copy full SHA for c4bbed9

• [FLINK-3969] Log Exceptions by Invokable

  Show description for 279777f
  zentol

  committed
  279777f

  Copy full SHA for 279777f

Pagination

Previous

Next