Commits

Branch selector

 1cc887e

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 13, 2016

• [FLINK-5145] WebInterface only polls selected metrics

  Show description for 1cc887e
  zentol

  committed
  1cc887e

• [FLINK-5328] [logging] Add Thread name to FileSystem disposeFileSystemCloseableRegistryForTask

  Show description for fc62723
  uce

  committed
  fc62723

• [FLINK-5163] Port the StatefulSequenceSource to the new state abstractions.

  

  kl0u

  authored and

  aljoscha

  committed
  81d8fe1

• [FLINK-5163] Port the MessageAcknowledgingSourceBase to the new state abstractions.

  

  kl0u

  authored and

  aljoscha

  committed
  956ffa6

• [FLINK-5163] Port the FromElementsFunction to the new state abstractions.

  

  kl0u

  authored and

  aljoscha

  committed
  d24833d

• [FLINK-5163] Port the ContinuousFileMonitoringFunction to the new state abstractions.

  

  kl0u

  authored and

  aljoscha

  committed
  685c4f8

• [docs] Add docs about externalized checkpoints

  uce

  committed
  3698379

• [FLINK-5326] [network] Check release flag of parent in reader

  Show description for d965d5a
  uce

  committed
  d965d5a

• [FLINK-5007] [checkpointing] Retain externalized checkpoint on suspension

  Show description for 38ab716
  uce

  committed
  38ab716

Commits on Dec 12, 2016

• [hotfix] [tests] Add re-tries to the result verification via files.

  StephanEwen

  committed
  57f7747

• [FLINK-5310] [RocksDB] Harden the JNI library loading

  StephanEwen

  committed
  609c046

• [FLINK-5114] [network] Handle partition producer state check for unregistered executions

  Show description for a078666
  uce

  committed
  a078666

• [FLINK-5147] Prevent NPE in LocalFS#delete()

  Show description for 47db9cb
  zentol

  committed
  47db9cb

• [FLINK-4906] [metrics] Introduce constants for IO metrics

  Show description for dc5dd51
  zentol

  committed
  dc5dd51

• [FLINK-5206] [py] Use random file names in tests

  Show description for 4befbb8
  zentol

  committed
  4befbb8

• [FLINK-5211] [metrics] [docs] Include example reporter configuration

  Show description for 36bf993
  zentol

  committed
  36bf993

Commits on Dec 9, 2016

• [FLINK-4646] [gelly] Add BipartiateGraph

  Show description for 365cd98
  

  mushketyk

  authored and

  greghogan

  committed
  365cd98

• [hotfix] properly encapsulate the original exception in JobClient

  Show description for 9ab494a
  

  Nico Kruber

  authored and

  rmetzger

  committed
  9ab494a

• [FLINK-5158] [ckPtCoord] Handle exceptions from CompletedCheckpointStore in CheckpointCoordinator

  Show description for 0c42d25
  tillrohrmann

  committed
  0c42d25

• [FLINK-5193] [jm] Harden job recovery in case of recovery failures

  Show description for add3765
  tillrohrmann

  committed
  add3765

• [FLINK-5278] Improve task and checkpoint related logging

  Show description for ea70807
  tillrohrmann

  committed
  ea70807

• [FLINK-5285] Abort checkpoint only once in BarrierTracker

  Show description for d3f19a5
  tillrohrmann

  committed
  d3f19a5

Commits on Dec 8, 2016

• [FLINK-3921] Add support to set encoding in CsvReader and StringParser.

  Show description for 41d5875
  

  greghogan

  authored and

  fhueske

  committed
  41d5875

• [FLINK-3921] Add support to set encoding in CsvReader and StringParser.

  Show description for f2186af
  

  rekhajoshm

  authored and

  fhueske

  committed
  f2186af

• [FLINK-5039] Bump Avro version to 1.7.7.

  Show description for 2d8f03e
  

  rmetzger

  authored and

  fhueske

  committed
  2d8f03e

• [FLINK-5226] [table] Use correct DataSetCostFactory and improve DataSetCalc costs.

  Show description for 677d0d9
  fhueske

  committed
  677d0d9

• [FLINK-5169] [network] Fix String formats in spillable partition

  Show description for 55d6061
  

  Boris Osipov

  authored and

  uce

  committed
  55d6061

• [FLINK-5020] Make the GenericWriteAheadSink rescalable.

  Show description for 4eb7192
  

  kl0u

  authored and

  zentol

  committed
  4eb7192

• [FLINK-4563] [metrics] scope caching not adjusted for multiple reporters

  Show description for 86f784a
  

  Anton Mushin

  authored and

  zentol

  committed
  86f784a

• [FLINK-5164] Disable some Hadoop-compat tests on Windows

  Show description for fe843e1
  zentol

  committed
  fe843e1

Commits on Dec 7, 2016

• [FLINK-4554] [table] Add support for array types

  Show description for 4414008
  twalthr

  committed
  4414008

• [FLINK-4631] Prevent NPE in TwoInputStreamTask

  Show description for 13150a4
  tillrohrmann

  committed
  13150a4

• [FLINK-5275] [execgraph] Give more detailed error message if InputChannel deployment fails

  uce

  committed
  4410c04

• [FLINK-5274] [network] Handle reader release in LocalInputChannel

  uce

  committed
  555a687

• [FLINK-4469] [table] Minor improvements

  Show description for 684defb
  twalthr

  committed
  684defb

Pagination

PreviousNext