Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 15, 2015

• [FLINK-2224] Log error cause in JobStatusChange

  uce

  committed
  b14ec17

  Copy full SHA for b14ec17

Commits on Jun 10, 2015

• [hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync

  aljoscha

  committed
  b5b71e1

  Copy full SHA for b5b71e1

• Fixed a few trivial issues:

  Show description for c04a575
  

  ggevay

  authored and

  mbalassi

  committed
  c04a575

  Copy full SHA for c04a575

Commits on May 27, 2015

• [examples] Add toString() method to accumulator

  rmetzger

  committed
  63edeca

  Copy full SHA for 63edeca

Commits on May 26, 2015

• [FLINK-2043] Change the KMeansDataGenerator to allow passing a custom path

  Show description for 3586ced
  

  pp86

  authored and

  fhueske

  committed
  3586ced

  Copy full SHA for 3586ced

Commits on May 22, 2015

• [FLINK-2050] [ml] Ports existing ML algorithms to new pipeline mechanism

  Show description for 1e57475
  tillrohrmann

  committed
  1e57475

  Copy full SHA for 1e57475

• [FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to wrap the algorithm logic

  Show description for fde0341
  tillrohrmann

  committed
  fde0341

  Copy full SHA for fde0341

Commits on May 21, 2015

• [examples] Fix remaining examples to properly handle eager print() execution.

  StephanEwen

  committed
  b92ff12

  Copy full SHA for b92ff12

• [FLINK-1418] [apis] Fix eager print() and adjust all tests and examples to not fail due to "eager" print method

  Show description for 78d954b
  

  nikste

  authored and

  StephanEwen

  committed
  78d954b

  Copy full SHA for 78d954b

Commits on Apr 16, 2015

• [FLINK-1753] Extend KafkaITCase with large messages test + rework PersistentKafkaSource.

  Show description for 354922b
  rmetzger

  committed
  354922b

  Copy full SHA for 354922b

Commits on Apr 10, 2015

• [FLINK-1535] [core] Rework accumulators

  Show description for 6774054
  StephanEwen

  committed
  6774054

  Copy full SHA for 6774054

Commits on Apr 2, 2015

• Added support for Apache Tez as an execution environment

  Show description for 2cbbd32
  

  ktzoumas

  authored and

  rmetzger

  committed
  2cbbd32

  Copy full SHA for 2cbbd32

Commits on Mar 31, 2015

• [FLINK-1771] Add support for submitting single jobs to a detached YARN session

  Show description for 6b0d407
  rmetzger

  committed
  6b0d407

  Copy full SHA for 6b0d407

Commits on Mar 17, 2015

• [FLINK-1696] [ml] Adds batch gradient descent linear regression with l2 norm

  Show description for 0c24262
  tillrohrmann

  committed
  0c24262

  Copy full SHA for 0c24262

Commits on Mar 9, 2015

• [FLINK-1637] Reduce number of files in uberjar for java 6

  Show description for 5242e96
  rmetzger

  committed
  5242e96

  Copy full SHA for 5242e96

Commits on Feb 18, 2015

• [FLINK-1417] Automatically register types with Kryo

  rmetzger

  committed
  354efec

  Copy full SHA for 354efec

Commits on Feb 6, 2015

• [docs] Updated legacy references containing 'incubator' substring

  Show description for 6ce241e
  mbalassi

  committed
  6ce241e

  Copy full SHA for 6ce241e

Commits on Feb 5, 2015

• [FLINK-1415] [runtime] Akka cleanups

  Show description for 4046819
  tillrohrmann

  committed
  4046819

  Copy full SHA for 4046819

Commits on Feb 3, 2015

• [FLINK-1165] [java-api] Rename "createCollectionEnvironment" to not break existing APIs.

  StephanEwen

  committed
  aeec128

  Copy full SHA for aeec128

• [FLINK-1165] [java-api] Add createCollectionsEnvironment to Java API

  Show description for 36039b6
  

  Ajay Bhat

  authored and

  StephanEwen

  committed
  36039b6

  Copy full SHA for 36039b6

Commits on Jan 30, 2015

• [FLINK-1460] fix typos

  Show description for f7e84c1
  

  coderxiang

  authored and

  hsaputra

  committed
  f7e84c1

  Copy full SHA for f7e84c1

Commits on Jan 28, 2015

• [FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions.

  Show description for de8e066
  fhueske

  committed
  de8e066

  Copy full SHA for de8e066

• [FLINK-1328] Integrated forwarded Fields into the optimizer (incomplete)

  Show description for 78f41e9
  

  skunert

  authored and

  fhueske

  committed
  78f41e9

  Copy full SHA for 78f41e9

Commits on Jan 26, 2015

• [FLINK-1168] Add support for multi-char field delimiters in CSVInputFormats.

  Show description for 0548a93
  fhueske

  committed
  0548a93

  Copy full SHA for 0548a93

Commits on Jan 19, 2015

• FLINK-1420 Small cleanup on code after branch for 0.8 release

  Show description for 58e1e44
  hsaputra

  committed
  58e1e44

  Copy full SHA for 58e1e44

Commits on Jan 12, 2015

• [FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results

  Show description for d908ca1
  uce

  committed
  d908ca1

  Copy full SHA for d908ca1

Commits on Jan 4, 2015

• [streaming] [scala] Restructured streaming scala project and examples

  Show description for 8183c8c
  mbalassi

  committed
  8183c8c

  Copy full SHA for 8183c8c

Commits on Jan 3, 2015

• [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams

  Show description for b9d0241
  

  senorcarbone

  authored and

  gyfora

  committed
  b9d0241

  Copy full SHA for b9d0241

• [scala] [streaming] added group windowing example with different policy types

  Show description for a761cdc
  senorcarbone

  committed
  a761cdc

  Copy full SHA for a761cdc

Commits on Jan 2, 2015

• [streaming] Streaming API grouping rework to use batch api Keys

  gyfora

  committed
  8bf9416

  Copy full SHA for 8bf9416

• [scala] [streaming] WindowJoin scala example added

  gyfora

  committed
  1d019b9

  Copy full SHA for 1d019b9

Commits on Dec 20, 2014

• [FLINK-1338] Updates necessary due to Apache graduation

  Show description for 561eaf0
  mbalassi

  committed
  561eaf0

  Copy full SHA for 561eaf0

Commits on Dec 18, 2014

• Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use Forkable…

  Show description for c175ebe
  tillrohrmann

  committed
  c175ebe

  Copy full SHA for c175ebe

• Added AKKA_LOG_LEVEL config constant.

  tillrohrmann

  committed
  f96bca0

  Copy full SHA for f96bca0

• Replaced the JobClient by an actor.

  tillrohrmann

  committed
  241c1ca

  Copy full SHA for 241c1ca

Pagination

Previous

Next