Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 23, 2015

• Add copy() to Tuple base class.

  aljoscha

  committed
  d056f11

  Copy full SHA for d056f11

• [release] update version to 1.0-SNAPSHOT

  Show description for 0c03e9a
  mxm

  committed
  0c03e9a

  Copy full SHA for 0c03e9a

Commits on Oct 22, 2015

• [FLINK-2874] Fix recognition of Scala default setters

  fhueske

  committed
  cd7ed8e

  Copy full SHA for cd7ed8e

• [FLINK-2874] Fix Avro getter/setter recognition

  Show description for 17e7b42
  

  Ulf Karlsson

  authored and

  fhueske

  committed
  17e7b42

  Copy full SHA for 17e7b42

• [FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended

  Show description for 32b0dfd
  

  supermegaciaccount

  authored and

  fhueske

  committed
  32b0dfd

  Copy full SHA for 32b0dfd

Commits on Oct 21, 2015

• [FLINK-2876] Minutiae

  Show description for 6666ea5
  

  greghogan

  authored and

  fhueske

  committed
  6666ea5

  Copy full SHA for 6666ea5

• [FLINK-2743] Add XORShfitRandom and use it in RandomSamplers.

  Show description for 5fb1c47
  

  chengxiang li

  authored and

  fhueske

  committed
  5fb1c47

  Copy full SHA for 5fb1c47

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-2725] Add Max/Min/Sum aggregation for mutable types.

  Show description for da248b1
  

  greghogan

  authored and

  fhueske

  committed
  da248b1

  Copy full SHA for da248b1

• [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 16, 2015

• [hotfix] [core] TypeExtractor correctly handles non-public types as generic types (rather than failing with an exception)

  StephanEwen

  committed
  b81598e

  Copy full SHA for b81598e

Commits on Oct 9, 2015

• Small update to Javadoc in IterativeDataset.closeWith to add missing param.

  hsaputra

  committed
  d38aeac

  Copy full SHA for d38aeac

• [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 8, 2015

• [FLINK-1789][core][runtime] Allow adding of URLs to the usercode class loader

  Show description for 0ee0c1f
  

  twalthr

  authored and

  mxm

  committed
  0ee0c1f

  Copy full SHA for 0ee0c1f

Commits on Oct 7, 2015

• [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

• [streaming] [storm] Clean up instantiation of mini clusters and test environments.

  StephanEwen

  committed
  82d6236

  Copy full SHA for 82d6236

• [FLINK-2787] [core] Prevent instantiation of RemoteEnvironment when running a program through the command line.

  Show description for 891db5e
  StephanEwen

  committed
  891db5e

  Copy full SHA for 891db5e

• [hotfix] [build] Add joda-convert as a non-optional dependency, to fix Scala interoperability

  StephanEwen

  committed
  c04a770

  Copy full SHA for c04a770

Commits on Sep 30, 2015

• [FLINK-2097] fix finalize() method of ExecutorReaper

  mxm

  committed
  28d36cc

  Copy full SHA for 28d36cc

Commits on Sep 29, 2015

• [FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

  Show description for 136347d
  hsaputra

  committed
  136347d

  Copy full SHA for 136347d

Commits on Sep 28, 2015

• [FLINK-2690] [api-breaking] [scala api] [java api] Adds functionality to the CsvInputFormat to find fields defined in a super class of a Pojo. Refactors CsvInputFormat to share code between this fo…

  Show description for 501a9b0
  tillrohrmann

  committed
  501a9b0

  Copy full SHA for 501a9b0

Commits on Sep 24, 2015

• [utils] Missing getters for ParameterTool

  Show description for 6b26e23
  mbalassi

  committed
  6b26e23

  Copy full SHA for 6b26e23

Commits on Sep 22, 2015

• [FLINK-2097] temporarily disable session management API

  mxm

  committed
  d58caa8

  Copy full SHA for d58caa8

• [FLINK-2097][core] implement a job session management

  Show description for 71bf2f5
  mxm

  committed
  71bf2f5

  Copy full SHA for 71bf2f5

Commits on Sep 18, 2015

• [FLINK-2557] [core] TypeExtractor properly returns MissingTypeInfo

  Show description for 3fe9145
  

  supermegaciaccount

  authored and

  StephanEwen

  committed
  3fe9145

  Copy full SHA for 3fe9145

Commits on Sep 17, 2015

• [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers

  Show description for 8ca853e
  

  tillrohrmann

  authored and

  fhueske

  committed
  8ca853e

  Copy full SHA for 8ca853e

Commits on Sep 15, 2015

• [FLINK-2665] [api] [runtime] Makes ExecutionConfig serializable by forcing Kryo serializers to be Serializable

  Show description for 2cc5d98
  

  tillrohrmann

  authored and

  fhueske

  committed
  2cc5d98

  Copy full SHA for 2cc5d98

• [FLINK-2533] [java-api] Gap based random sample optimization.

  Show description for c923fb3
  

  gallenvara

  authored and

  fhueske

  committed
  c923fb3

  Copy full SHA for c923fb3

• [FLINK-2373] Add configuration parameter to createRemoteEnvironment method

  Show description for e78b80c
  

  akunft

  authored and

  fhueske

  committed
  e78b80c

  Copy full SHA for e78b80c

Commits on Sep 11, 2015

• [FLINK-2654] Add JavaDoc to ParameterTool class

  Show description for b73fef2
  

  dbehrouz

  authored and

  fhueske

  committed
  b73fef2

  Copy full SHA for b73fef2

• [hotfix] [tests] Fix warnings and casts in AbstractGenericArraySerializerTest

  StephanEwen

  committed
  a492ed9

  Copy full SHA for a492ed9

Commits on Sep 10, 2015

• [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats

  Show description for 8754352
  fhueske

  committed
  8754352

  Copy full SHA for 8754352

Pagination

Previous

Next