Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 7, 2017

• [FLINK-5916] [yarn] make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode

  Show description for e9a5c86
  

  WangTaoTheTonic

  authored and

  tillrohrmann

  committed
  e9a5c86

  Copy full SHA for e9a5c86

• [FLINK-5803] [table] Add support for procTime partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL.

  Show description for 53fb8f3
  

  sunjincheng121

  authored and

  fhueske

  committed
  53fb8f3

  Copy full SHA for 53fb8f3

• [FLINK-5956] [table] Add retract method for AggregateFunction.

  Show description for cd801aa
  

  shaoxuan-wang

  authored and

  fhueske

  committed
  cd801aa

  Copy full SHA for cd801aa

• [FLINK-5645] Store accumulators/metrics for canceled/failed tasks

  Show description for 821da81
  zentol

  committed
  821da81

  Copy full SHA for 821da81

Commits on Mar 6, 2017

• [FLINK-4460] Update doc: ProcessFunction now possible on DataStream

  aljoscha

  committed
  746c1ef

  Copy full SHA for 746c1ef

• [FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams

  Show description for 06740fb
  aljoscha

  committed
  06740fb

  Copy full SHA for 06740fb

• [FLINK-4460] Make CoProcessFunction abstract, add default onTime() method

  Show description for e12f320
  aljoscha

  committed
  e12f320

  Copy full SHA for e12f320

• [FLINK-4660] Allow ProcessFunction on DataStream

  Show description for 0228676
  aljoscha

  committed
  0228676

  Copy full SHA for 0228676

• [FLINK-4460] Make ProcessFunction abstract, add default onTime() method

  Show description for 82eddca
  aljoscha

  committed
  82eddca

  Copy full SHA for 82eddca

• [FLINK-5965] [docs] Fix minor typo on DropWizard wrappers

  Show description for 62517ca
  

  csokol

  authored and

  uce

  committed
  62517ca

  Copy full SHA for 62517ca

Commits on Mar 4, 2017

• [FLINK-5067] Java 8 build fixes

  Show description for dc00fb0
  

  Andrey Melentyev

  authored and

  rmetzger

  committed
  dc00fb0

  Copy full SHA for dc00fb0

• [FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode

  Show description for d5c320c
  KurtYoung

  committed
  d5c320c

  Copy full SHA for d5c320c

Commits on Mar 3, 2017

• [FLINK-5219] [table] Add non-grouped session windows for batch tables.

  Show description for 728c936
  

  sunjincheng121

  authored and

  fhueske

  committed
  728c936

  Copy full SHA for 728c936

• [FLINK-5927] [table] Remove old Aggregate interface, built-in functions, and tests.

  Show description for c31f95c
  

  shaoxuan-wang

  authored and

  fhueske

  committed
  c31f95c

  Copy full SHA for c31f95c

• [FLINK-5955] [table] Fix aggregations with ObjectReuse enabled by pairwise merging of accumulators.

  Show description for 14fab4c
  

  shaoxuan-wang

  authored and

  fhueske

  committed
  14fab4c

  Copy full SHA for 14fab4c

• [hotfix] [table] Fix initialization of accumulators for MIN and MAX aggregates.

  fhueske

  committed
  2d1721b

  Copy full SHA for 2d1721b

• [FLINK-5864] [cep] Fix duplicate output patterns problem

  Show description for 050f9a4
  

  dawidwys

  authored and

  kl0u

  committed
  050f9a4

  Copy full SHA for 050f9a4

• [FLINK-5917] [statebackends] Remove size() method from MapState

  Show description for f37507d
  

  xiaogang.sxg

  authored and

  StefanRRichter

  committed
  f37507d

  Copy full SHA for f37507d

• [FLINK-5937] [doc] Add documentation about the stream task lifecycle

  kl0u

  committed
  a2e6fb0

  Copy full SHA for a2e6fb0

Commits on Mar 2, 2017

• [FLINK-5597] [docs] Improve the LocalClusteringCoefficient documentation

  Show description for cb9e409
  greghogan

  committed
  cb9e409

  Copy full SHA for cb9e409

• [FLINK-4896] [gelly] PageRank algorithm for directed graphs

  Show description for ea14053
  greghogan

  committed
  ea14053

  Copy full SHA for ea14053

• [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface.

  Show description for 438276d
  

  shaoxuan-wang

  authored and

  fhueske

  committed
  438276d

  Copy full SHA for 438276d

• [FLINK-5941] Integrate Archiver pattern into handlers

  Show description for 7fe0eb4
  zentol

  committed
  7fe0eb4

  Copy full SHA for 7fe0eb4

• [FLINK-5945] [core] Close function in OuterJoinOperatorBase#executeOnCollections

  Show description for 243ef69
  greghogan

  committed
  243ef69

  Copy full SHA for 243ef69

• [FLINK-5827] [table] Exception when do filter after join a udtf which returns a POJO type

  Show description for ff552b4
  

  packbase

  authored and

  twalthr

  committed
  ff552b4

  Copy full SHA for ff552b4

• [FLINK-5524] [table] Support early out for code generated AND/OR conditions

  Show description for f6c9b32
  

  KurtYoung

  authored and

  twalthr

  committed
  f6c9b32

  Copy full SHA for f6c9b32

• [FLINK-5948] Fix error in Python zip_with_index documentation

  Show description for 82047f7
  

  GEOFBOT

  authored and

  zentol

  committed
  82047f7

  Copy full SHA for 82047f7

• [FLINK-5934] Set the Scheduler in the ExecutionGraph via its constructor

  Show description for 5c96856
  tillrohrmann

  committed
  5c96856

  Copy full SHA for 5c96856

• [FLINK-5938] Replace ExecutionContext by Executor in Scheduler

  Show description for cde3cdd
  tillrohrmann

  committed
  cde3cdd

  Copy full SHA for cde3cdd

• [FLINK-5852] Move handler JSON generation code into static methods

  Show description for a552d67
  zentol

  committed
  a552d67

  Copy full SHA for a552d67

• [FLINK-5870] Handlers define REST URLs

  Show description for 999bace
  zentol

  committed
  999bace

  Copy full SHA for 999bace

• [FLINK-4422] [kafka] Convert all time interval measurements to System.nanoTime()

  Show description for 51b7ede
  

  jinmingjian

  authored and

  tzulitai

  committed
  51b7ede

  Copy full SHA for 51b7ede

• [FLINK-5794] [doc] Update the documentation about “UDF/UDTF" support have parameters constructor.

  Show description for bf4eed1
  

  sunjincheng121

  authored and

  wuchong

  committed
  bf4eed1

  Copy full SHA for bf4eed1

Commits on Mar 1, 2017

• [FLINK-5402] [tests] Increase JUnit timeouts in AkkaRpcServiceTest

  Show description for 72f18dc
  uce

  committed
  72f18dc

  Copy full SHA for 72f18dc

• [FLINK-5389] [tests] Increate ask timeout in JobSubmitTest

  uce

  committed
  b59c14e

  Copy full SHA for b59c14e

Pagination

Previous

Next