Commits

Commits on Jan 26, 2016

[FLINK-1045][dataSet] Remove Combinable annotation.
fhueske
committedJan 26, 2016
[FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.
fhueske
committedJan 26, 2016

Commits on Jan 19, 2016

[Refactor] [DataSet] Refactor key selector translation in DataSet API.
fhueske
committedJan 19, 2016

Commits on Dec 21, 2015

[FLINK-7] Prevent range partitioning inside iterations.
fhueske
committedDec 21, 2015

Commits on Dec 7, 2015

[FLINK-3113] Remove unused and unsupported global-order methods from GenericDataSinkBase
fhueske
committedDec 7, 2015
[FLINK-3112] Remove unused RecordModelPostPass and replace JavaPlan by Plan.
fhueske
committedDec 7, 2015

Commits on Nov 30, 2015

[FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.
fhueske
committedNov 30, 2015

Commits on Nov 24, 2015

Remove Record API dependencies from WordCount compiler test
fhueske
committedNov 24, 2015
Remove Record API dependencies from CC iteration tests
fhueske
committedNov 24, 2015
Move operator ITCases into correct package
fhueske
committedNov 24, 2015
Remove ITCases for Record API operators
fhueske
committedNov 24, 2015
Remove Record API program tests
fhueske
committedNov 24, 2015

Commits on Nov 2, 2015

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

fhueske
authored and
mxm
committedNov 2, 2015

Commits on Oct 29, 2015

[FLINK-2900] [hadoop-compat] Remove Record API code from Hadoop Compat module
fhueske
committedOct 29, 2015

Commits on Oct 23, 2015

[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests
fhueske
committedOct 23, 2015

Commits on Oct 22, 2015

[FLINK-2874] Fix recognition of Scala default setters
fhueske
committedOct 22, 2015
[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed jobs in new web dashboard
fhueske
committedOct 22, 2015

Commits on Oct 19, 2015

Commits on Oct 17, 2015

[hotfix] Fix DataSet API programming guide
fhueske
committedOct 17, 2015

Commits on Oct 15, 2015

[FLINK-2843] Add documentation for DataSet outer joins.
fhueske
committedOct 15, 2015

Commits on Oct 9, 2015

[FLINK-2784] Remove deprecated configuration keys and updated documentation

fhueske
authored and
vasia
committedOct 9, 2015
[FLINK-2576] [javaAPI] [scalaAPI] Restored binary compatibility for DataSet (inner) join.
fhueske
committedOct 9, 2015

Commits on Sep 29, 2015

[FLINK-2756] [scripts] Fix start/stop scripts for paths with spaces

fhueske
authored and
StephanEwen
committedSep 29, 2015

Commits on Sep 17, 2015

[FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups.
fhueske
committedSep 17, 2015

Commits on Sep 10, 2015

[FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats
fhueske
committedSep 10, 2015

Commits on Aug 26, 2015

[FLINK-2394] HadoopOutputFormats use correct OutputCommitters.

fhueske
authored and
uce
committedAug 26, 2015

Commits on Aug 4, 2015

[FLINK-2442] [fix] FieldPositionKeys support Pojo fields
fhueske
committedAug 4, 2015

Commits on Jul 30, 2015

[cascading] add getJobConf() to HadoopInputSplit

fhueske
authored and
mxm
committedJul 30, 2015

Commits on Jul 13, 2015

[FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers
fhueske
committedJul 13, 2015

Commits on Jul 9, 2015

[FLINK-2280] GenericTypeComparator.compare() respects ascending flag
fhueske
committedJul 9, 2015

Commits on Jun 16, 2015

[hotfix] Removed execute() that followed print() in quickstart wordcount jobs
fhueske
committedJun 16, 2015

Commits on Jun 12, 2015

Commits on Jun 11, 2015

[FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel.
fhueske
committedJun 11, 2015