Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 17, 2016

• [FLINK-3430] Remove "no POJO" warning in TypeAnalyzer

  Show description for cee135a
  

  aljoscha

  authored and

  StephanEwen

  committed
  cee135a

  Copy full SHA for cee135a

Commits on Feb 15, 2016

• [FLINK-3187] [restart] Introduce RestartStrategy to ExecutionGraph

  Show description for 5eae47f
  tillrohrmann

  committed
  5eae47f

  Copy full SHA for 5eae47f

Commits on Feb 14, 2016

• [FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala

  fhueske

  committed
  e5f33b6

  Copy full SHA for e5f33b6

Commits on Feb 10, 2016

• [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation.

  Show description for 0a63797
  

  chiwanpark

  authored and

  fhueske

  committed
  0a63797

  Copy full SHA for 0a63797

• [FLINK-3366] Rename @experimental annotation to @PublicEvolving

  Show description for 572855d
  fhueske

  committed
  572855d

  Copy full SHA for 572855d

Commits on Feb 5, 2016

• [FLINK-3093] Introduce annotations for interface stability in remaining modules

  Show description for b54499b
  rmetzger

  committed
  b54499b

  Copy full SHA for b54499b

Commits on Feb 2, 2016

• [FLINK-3303] [core] Move all type utilities to flink-core

  StephanEwen

  committed
  21a7158

  Copy full SHA for 21a7158

Commits on Jan 28, 2016

• [FLINK-3140] [table] NULL value data layout in Row Serializer/Comparator

  Show description for 440137c
  twalthr

  committed
  440137c

  Copy full SHA for 440137c

Commits on Jan 27, 2016

• [FLINK-2933][maven] add suffix to Scala dependent modules

  Show description for 2c4e4d1
  mxm

  committed
  2c4e4d1

  Copy full SHA for 2c4e4d1

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

• [FLINK-1045][dataSet] Remove Combinable annotation.

  Show description for 5914e9a
  fhueske

  committed
  5914e9a

  Copy full SHA for 5914e9a

• [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

  Show description for af029e7
  fhueske

  committed
  af029e7

  Copy full SHA for af029e7

• [cleanup] Remove spark repl detection code from closure cleaner

  Show description for 9840136
  

  sksamuel

  authored and

  tillrohrmann

  committed
  9840136

  Copy full SHA for 9840136

Commits on Jan 25, 2016

• [hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code.

  Show description for 2ad1d5e
  

  sksamuel

  authored and

  fhueske

  committed
  2ad1d5e

  Copy full SHA for 2ad1d5e

Commits on Jan 15, 2016

• [FLINK-2716] [gelly] [apis] New checksum method on DataSet and Graph

  Show description for a8be52a
  

  greghogan

  authored and

  StephanEwen

  committed
  a8be52a

  Copy full SHA for a8be52a

• [FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a single operator

  

  greghogan

  authored and

  StephanEwen

  committed
  e9a5358

  Copy full SHA for e9a5358

Commits on Dec 21, 2015

• [FLINK-7] Add range partitioning with automatic sampling of key distribution

  Show description for f5957ce
  

  chengxiang li

  authored and

  fhueske

  committed
  f5957ce

  Copy full SHA for f5957ce

Commits on Dec 9, 2015

• [FLINK-3143] update Closure Cleaner's ASM references to ASM5

  Show description for e28b62e
  mxm

  committed
  e28b62e

  Copy full SHA for e28b62e

• [FLINK-3136] Fix shaded imports in ClosureCleaner.scala

  aljoscha

  committed
  718a17b

  Copy full SHA for 718a17b

Commits on Nov 30, 2015

• [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.

  Show description for cd899f3
  fhueske

  committed
  cd899f3

  Copy full SHA for cd899f3

Commits on Nov 25, 2015

• [FLINK-3059] Improve JavaDocs for DataSet.writeAsText()

  Show description for e03e60d
  

  jaoki

  authored and

  fhueske

  committed
  e03e60d

  Copy full SHA for e03e60d

Commits on Nov 18, 2015

• [FLINK-2692] Untangle CsvInputFormat

  Show description for bd61f2d
  zentol

  committed
  bd61f2d

  Copy full SHA for bd61f2d

Commits on Nov 17, 2015

• [hotfix] [utils] Change the parameter 'numSample' in DataSetUtils.sampleWithSize() to 'numSamples', remove redundant Java 6 code

  Show description for e692a10
  

  smarthi

  authored and

  StephanEwen

  committed
  e692a10

  Copy full SHA for e692a10

Commits on Nov 3, 2015

• [FLINK-2918] [api-extending] Add methods to read Hadoop SequenceFiles.

  Show description for 30a832e
  

  smarthi

  authored and

  fhueske

  committed
  30a832e

  Copy full SHA for 30a832e

• [FLINK-2930] Respect ExecutionConfig execution retry delay

  Show description for aa1c145
  

  uce

  authored and

  mxm

  committed
  aa1c145

  Copy full SHA for aa1c145

Commits on Nov 2, 2015

• [FLINK-2953] fix chaining of sortPartition() calls in Scala DataSet API

  Show description for 5e40c6d
  

  fhueske

  authored and

  mxm

  committed
  5e40c6d

  Copy full SHA for 5e40c6d

Commits on Oct 23, 2015

• [release] update version to 1.0-SNAPSHOT

  Show description for 0c03e9a
  mxm

  committed
  0c03e9a

  Copy full SHA for 0c03e9a

Commits on Oct 19, 2015

• [FLINK-2107] Add hash-based strategies for left and right outer joins.

  Show description for 5671c77
  fhueske

  committed
  5671c77

  Copy full SHA for 5671c77

• [FLINK-2809] [scala-api] Added UnitTypeInfo and UnitSerializer.

  Show description for 6491559
  

  ggevay

  authored and

  fhueske

  committed
  6491559

  Copy full SHA for 6491559

Commits on Oct 9, 2015

• [FLINK-2818] [docs] Correct javadocs of *ReduceDriver classes and some methods in the API.

  Show description for 48f614c
  

  ggevay

  authored and

  chiwanpark

  committed
  48f614c

  Copy full SHA for 48f614c

• [FLINK-2576] [javaAPI] [scalaAPI] Restored binary compatibility for DataSet (inner) join.

  fhueske

  committed
  1272cd5

  Copy full SHA for 1272cd5

• [FLINK-2576] [javaAPI] [scalaAPI] [optimizer] Add outerJoin to DataSet API (Java, Scala) and optimizer.

  Show description for b00c1d7
  

  jkovacs

  authored and

  fhueske

  committed
  b00c1d7

  Copy full SHA for b00c1d7

Commits on Oct 7, 2015

• [FLINK-2806] [scala-api] Add a TypeInformation[Nothing]

  Show description for 6e42f9f
  

  ggevay

  authored and

  chiwanpark

  committed
  6e42f9f

  Copy full SHA for 6e42f9f

• [FLINK-2066][core] Add configuration of delay between execution retries at job level

  Show description for a437a2b
  

  WangCHX

  authored and

  fhueske

  committed
  a437a2b

  Copy full SHA for a437a2b

Commits on Oct 1, 2015

• [FLINK-2783] Remove "degreeOfParallelism" API calls

  Show description for f2ea4e4
  

  supermegaciaccount

  authored and

  StephanEwen

  committed
  f2ea4e4

  Copy full SHA for f2ea4e4

Pagination

Previous

Next