Commits

Branch selector

 master

User selector

senorcarbone

All time

Commit History

Commits on Jan 25, 2016

• [FLINK-3256] Fix colocation group re-instantiation

  Show description for 4406188
  senorcarbone

  committed
  4406188

  Copy full SHA for 4406188

Commits on Jul 7, 2015

• [docs] small fix to the description of the checkpointing mechanism

  senorcarbone

  committed
  0e21941

  Copy full SHA for 0e21941

Commits on Jun 25, 2015

• [streaming] Add KeyedDataStream abstraction and integrate it with the rest of the refactoring

  Show description for cad8510
  

  senorcarbone

  authored and

  gyfora

  committed
  cad8510

  Copy full SHA for cad8510

• [streaming] fix for null state in ConfirmCheckpoint messages

  

  senorcarbone

  authored and

  gyfora

  committed
  0ecab82

  Copy full SHA for 0ecab82

• [streaming] Add stateHandle to checkpointed message

  

  senorcarbone

  authored and

  gyfora

  committed
  f27c3f1

  Copy full SHA for f27c3f1

Commits on Apr 5, 2015

• [FLINK-1808] [streaming] Send barrier requests only when the execution graph is running

  Show description for 1da4b64
  

  senorcarbone

  authored and

  mbalassi

  committed
  1da4b64

  Copy full SHA for 1da4b64

Commits on Mar 26, 2015

• [FLINK-1686] [streaming] add parallel iteration test

  

  senorcarbone

  authored and

  gyfora

  committed
  1f726e4

  Copy full SHA for 1f726e4

• [FLINK-1686] [streaming] Use different slot identifier per iteration

  

  senorcarbone

  authored and

  gyfora

  committed
  0b48e52

  Copy full SHA for 0b48e52

Commits on Mar 20, 2015

• [streaming] [FLINK-1740] Pass config param for numberOfExecutionRetries to the JobGraph for streaming jobs

  Show description for a6da9f2
  

  senorcarbone

  authored and

  gyfora

  committed
  a6da9f2

  Copy full SHA for a6da9f2

• test refactoring fix

  

  senorcarbone

  authored and

  gyfora

  committed
  b6f183a

  Copy full SHA for b6f183a

Commits on Mar 10, 2015

• [FLINK-1638] [streaming] Add StateHandle and include javadoc

  Show description for f2b5c21
  

  senorcarbone

  authored and

  StephanEwen

  committed
  f2b5c21

  Copy full SHA for f2b5c21

• [FLINK-1638] [streaming] At-Least once monitoring semantics added and bug fixes

  Show description for 37390d6
  

  senorcarbone

  authored and

  StephanEwen

  committed
  37390d6

  Copy full SHA for 37390d6

• [FLINK-1638] [streaming] Operator state checkpointing and injection prototype

  

  senorcarbone

  authored and

  StephanEwen

  committed
  452c39a

  Copy full SHA for 452c39a

• [FLINK-1638] [streaming] Fault tolerance logic in JM and TM

  

  senorcarbone

  authored and

  StephanEwen

  committed
  a34869c

  Copy full SHA for a34869c

Commits on Feb 28, 2015

• [streaming] Add a clean in WindowedDataStream

  

  senorcarbone

  authored and

  gyfora

  committed
  b7b547d

  Copy full SHA for b7b547d

• [FLINK-1586] [streaming] Add support for iterative streaming graphs on JSON generation

  Show description for e91c1da
  

  senorcarbone

  authored and

  gyfora

  committed
  e91c1da

  Copy full SHA for e91c1da

Commits on Jan 28, 2015

• [FLINK-1344] [streaming] [scala] Added implicits from scala seq to datastream and static StreamExecutionEnvironment initialization

  

  senorcarbone

  authored and

  gyfora

  committed
  ad45bf1

  Copy full SHA for ad45bf1

Commits on Jan 6, 2015

• [scala] [streaming] added scala streams as sources in streaming-api scala examples

  

  senorcarbone

  authored and

  mbalassi

  committed
  baf81c6

  Copy full SHA for baf81c6

Commits on Jan 3, 2015

• [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams

  Show description for b9d0241
  

  senorcarbone

  authored and

  gyfora

  committed
  b9d0241

  Copy full SHA for b9d0241

• [scala] [streaming] added initial ConnectedDataStream support (no windowing,batching) for the scala api

  senorcarbone

  committed
  55ef795

  Copy full SHA for 55ef795

• [scala] [streaming] added group windowing example with different policy types

  Show description for a761cdc
  senorcarbone

  committed
  a761cdc

  Copy full SHA for a761cdc