Commits

Branch selector

 master

User selector

StephanEwen

Datepicker

All time

Commit History

Commits on Nov 5, 2015

• [FLINK-2938] [docs] Update docs for key/value state

  StephanEwen

  committed
  b32c97a

  Copy full SHA for b32c97a

Commits on Oct 25, 2015

• [FLINK-2891] [streaming] Set keys for key/value state in window evaluation of fast-path windows.

  StephanEwen

  committed
  3dc7423

  Copy full SHA for 3dc7423

• [FLINK-2888] [streaming] State backends return copies of the default values

  StephanEwen

  committed
  6424ce5

  Copy full SHA for 6424ce5

Commits on Oct 21, 2015

• [FLINK-2880] [streaming] Allow DeserializationSchema to forward exceptions.

  Show description for 7a959bc
  

  StephanEwen

  authored and

  fhueske

  committed
  7a959bc

  Copy full SHA for 7a959bc

Commits on Oct 17, 2015

• [FLINK-2863] [kafka connector] Kafka connector propagates async producer exceptions

  StephanEwen

  committed
  a8eeb3b

  Copy full SHA for a8eeb3b

Commits on Oct 16, 2015

• [hotfix] [storm compatibility] Deactivate tests for split stream field grouping, which do not work in teh runtime and are now caught earlier

  StephanEwen

  committed
  34c232e

  Copy full SHA for 34c232e

• [hotfix] [streaming] Remove obsolete internal state handle classes

  StephanEwen

  committed
  d68c8b1

  Copy full SHA for d68c8b1

• [FLINK-2550] [streaming] Allow multiple key/value states per operator on top of the new state backend

  StephanEwen

  committed
  7c20543

  Copy full SHA for 7c20543

• [hotfix] [streaming scala] Expose key type information for key selectors on connected data streams

  StephanEwen

  committed
  bb1f5fd

  Copy full SHA for bb1f5fd

• [hotfix] [tests] Make StreamTaskTimerTest more robust

  StephanEwen

  committed
  4ee5b4c

  Copy full SHA for 4ee5b4c

• [FLINK-2550] [tests] Add an end-to-end failure/recovery test for fast path processing time windows

  StephanEwen

  committed
  3b7fb63

  Copy full SHA for 3b7fb63

• [FLINK-2846] [streaming] Emit downstream checkpoint barriers at beginning of the checkpoint scope

  StephanEwen

  committed
  da159ef

  Copy full SHA for da159ef

• [hotfix] Proper exception chaining in key/value state access of StreamingRuntimeContext

  StephanEwen

  committed
  ca8c73d

  Copy full SHA for ca8c73d

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

• [hotfix] StreamTask and OperatorChain properly clean up partially initialized resources upon failures during initialization

  StephanEwen

  committed
  d5a016c

  Copy full SHA for d5a016c

• [hotfix] [streaming] Initialize StreamingRuntimeContext to rich functions early

  StephanEwen

  committed
  f2d5038

  Copy full SHA for f2d5038

• [FLINK-2550] [streaming] Rework JoinStreams and CoGroupStreams to properly implement operator builder syntax

  StephanEwen

  committed
  69dfc40

  Copy full SHA for 69dfc40

• [FLINK-2550] [streaming] Make fast-path processing time windows fault tolerant

  StephanEwen

  committed
  c24dca5

  Copy full SHA for c24dca5

• [FLINK-2808] [streaming] Refactor and extend state backend abstraction

  StephanEwen

  committed
  479bec0

  Copy full SHA for 479bec0

• [hotfix] Remove remaning classes for old window triggers

  StephanEwen

  committed
  5ac2872

  Copy full SHA for 5ac2872

• [hotfix] Correct name of HDFS tests from 'org.apache.flink.tachyon' to 'org.apache.flink.hdfstests'

  StephanEwen

  committed
  eec2d15

  Copy full SHA for eec2d15

Commits on Oct 2, 2015

• [hotfix] [streaming] Handle rich functions properly in aligned time windows

  StephanEwen

  committed
  6e0e67d

  Copy full SHA for 6e0e67d

• [hotfix] [streaming] Apply closure cleaner to KeyedWindowFunction

  StephanEwen

  committed
  7390201

  Copy full SHA for 7390201

• [FLINK-2727] [streaming] Add a base class for Message Queue Sources that acknowledge messages by ID.

  Show description for daeab84
  StephanEwen

  committed
  daeab84

  Copy full SHA for daeab84

Commits on Oct 1, 2015

• [hotfix] [tests] Run IPv6HostnamesITCase with parallel data exchange and less verbose output

  StephanEwen

  committed
  846ad70

  Copy full SHA for 846ad70

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

• [FLINK-2766] [core] Add proper handling of IPv6 address literals in URLs

  StephanEwen

  committed
  bfde1b7

  Copy full SHA for bfde1b7

• [FLINK-2781] [core] Cleanup NetUtils.

  Show description for a3c0b44
  StephanEwen

  committed
  a3c0b44

  Copy full SHA for a3c0b44

Commits on Sep 29, 2015

• [FLINK-2763] [runtime] Fix hash table spilling partition selection.

  StephanEwen

  committed
  af47756

  Copy full SHA for af47756

Commits on Sep 28, 2015

• [FLINK-2753] [streaming] [api breaking] Add first parts of new window API for key grouped windows

  Show description for 7e20299
  

  StephanEwen

  authored and

  aljoscha

  committed
  7e20299

  Copy full SHA for 7e20299

Commits on Sep 23, 2015

• [hotfix] [streaming] Improve error message for key operations on non-composite types

  Show description for 5b46cbe
  StephanEwen

  committed
  5b46cbe

  Copy full SHA for 5b46cbe

• [FLINK-2734] [streaming] Fix ArrayKeySelector

  Show description for 8b40bb7
  StephanEwen

  committed
  8b40bb7

  Copy full SHA for 8b40bb7

• [tests] Improve Kafka concurrent produce/consumer test by allowing retries when connecting to non-leader broker.

  StephanEwen

  committed
  ea3b5ef

  Copy full SHA for ea3b5ef

Pagination

Previous

Next