Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 16, 2016

• [FLINK-2821] use custom Akka build to listen on all interfaces

  Show description for 27ebdf7
  mxm

  committed
  27ebdf7

• [docker] improve Dockerfile host configuration

  Show description for 6e1e139
  mxm

  committed
  6e1e139

Commits on Dec 14, 2016

• [FLINK-5051] Add Serde Proxies for Serializers and State Backend Data

  

  StefanRRichter

  authored and

  aljoscha

  committed
  21d1d8b

• [FLINK-5041] Savepoint Backwards Compatibility 1.1 -> 1.2

  

  StefanRRichter

  authored and

  aljoscha

  committed
  e95fe56

• [FLINK-5283] Fix closing streams when restoring old savepoint in keyed backends

  

  StefanRRichter

  authored and

  aljoscha

  committed
  35f4ea7

Commits on Dec 12, 2016

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

  StephanEwen

  committed
  609c046

Commits on Dec 7, 2016

• [FLINK-5041] Savepoint backwards compatibility 1.1 -> 1.2

  Show description for af3bf83
  

  StefanRRichter

  authored and

  uce

  committed
  af3bf83

Commits on Dec 2, 2016

• [FLINK-5146] Improved resource cleanup in RocksDB keyed state backend

  

  StefanRRichter

  authored and

  aljoscha

  committed
  e4f802d

• [FLINK-5173] Upgrade RocksDB dependency

  

  StefanRRichter

  authored and

  aljoscha

  committed
  6e98a93

Commits on Nov 8, 2016

• [hotfix] [tests] Clean up (mostly redundant) PowerMock runners, preparations, and exclusions

  StephanEwen

  committed
  6a6eeb9

• [hotfix] [RocksDB backend] Minor cleanups to constructors and comments in RocksDBStateBackend

  StephanEwen

  committed
  d9ddcb4

• [FLINK-5014] [RocksDB backend] Add toString for RocksDBStateBackend

  Show description for d450bee
  

  melentye

  authored and

  StephanEwen

  committed
  d450bee

Commits on Nov 4, 2016

• [hotfix] [tests] Simplify mocking of the ResultPartitionWriter

  StephanEwen

  committed
  67c2868

• [hotfix] Don't Swallow Exception in RocksDBAsyncSnapshotTest

  aljoscha

  committed
  cd610a9

Commits on Oct 27, 2016

• [FLINK-4579] [RocksDB backend] Add StateBackendFactory and config shortcut for the RocksDB Backend

  Show description for fc730bb
  

  wuchong

  authored and

  StephanEwen

  committed
  fc730bb

Commits on Oct 26, 2016

• [FLINK-4892] Snapshot TimerService using Key-Grouped State

  Show description for c0192ec
  

  kl0u

  authored and

  aljoscha

  committed
  c0192ec

Commits on Oct 24, 2016

• [FLINK-4891] Remove flink-contrib/flink-operator-stats module

  uce

  committed
  d5b97b0

Commits on Oct 21, 2016

• [FLINK-3674] Add an interface for Time aware User Functions

  Show description for 81b19e5
  aljoscha

  committed
  81b19e5

• [FLINK-4852] Remove Non-Multiplexing StreamRecordSerializer

  Show description for 71d2e3e
  aljoscha

  committed
  71d2e3e

• [FLINK-4881][docker] remove shared volume for configuration

  Show description for 58a16c1
  

  sedgewickmm18

  authored and

  mxm

  committed
  58a16c1

• [FLINK-4833] properly log exceptions in CountMinHeavyHitter

  Show description for a27451d
  mxm

  committed
  a27451d

Commits on Oct 20, 2016

• [FLINK-4844] Partitionable Raw Keyed/Operator State

  

  StefanRRichter

  authored and

  aljoscha

  committed
  cab9cd4

Commits on Oct 17, 2016

• [FLINK-3931] Implement Transport Encryption (SSL/TLS)

  Show description for 069de27
  

  skrishnappa

  authored and

  mxm

  committed
  069de27

Commits on Oct 14, 2016

• [FLINK-3660] Measure latency and exposes them via a metric

  Show description for a612b99
  rmetzger

  committed
  a612b99

Commits on Oct 6, 2016

• [FLINK-4730] Introducing CheckpointMetaData

  Show description for 0dac7ad
  

  StefanRRichter

  authored and

  uce

  committed
  0dac7ad

• [hotfix] Make KeyGroupsStateHandle implement StreamStateHandle

  

  StefanRRichter

  authored and

  uce

  committed
  fee1430

Commits on Oct 5, 2016

• [FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling

  Show description for 8ff451b
  

  kl0u

  authored and

  StephanEwen

  committed
  8ff451b

Commits on Sep 30, 2016

• [FLINK-4379] [checkpoints] Introduce rescalable operator state

  Show description for 53ed6ad
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  53ed6ad

Commits on Sep 27, 2016

• [FLINK-4685] [checkpoints] Gather sync/async duration and alignment information for task checkpoints

  Show description for b1642e3
  StephanEwen

  committed
  b1642e3

Commits on Sep 22, 2016

• [FLINK-4603] [checkpoints] Fix user code classloading in KeyedStateBackend

  Show description for 3b8fe95
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  3b8fe95

Commits on Sep 8, 2016

• [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster

  Show description for 02b852e
  tillrohrmann

  committed
  02b852e

Commits on Aug 31, 2016

• [FLINK-3755] Fix variety of test problems cause by Keyed-State Refactoring

  

  StefanRRichter

  authored and

  aljoscha

  committed
  f44b57c

• [FLINK-4380] Remove KeyGroupAssigner in favor of static method/Have default max. parallelism at 128

  

  StefanRRichter

  authored and

  aljoscha

  committed
  6d43061

• [FLINK-3761] Refactor RocksDB Backend/Make Key-Group Aware

  Show description for addd084
  

  StefanRRichter

  authored and

  aljoscha

  committed
  addd084

• [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

  Show description for 4809f53
  aljoscha

  committed
  4809f53

Pagination

PreviousNext