Commits

Branch selector

 master

User selector

mbalassi

Datepicker

All time

Commit History

Commits on Oct 6, 2015

• [FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction

  Show description for e494c27
  mbalassi

  committed
  e494c27

  Copy full SHA for e494c27

• [FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and Reduce

  mbalassi

  committed
  c414ea9

  Copy full SHA for c414ea9

• [FLINK-2283] [streaming] Test for checkpointing in internal operators

  mbalassi

  committed
  a76d963

  Copy full SHA for a76d963

• [FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state

  mbalassi

  committed
  225704b

  Copy full SHA for 225704b

• [streaming] Removed unused StreamReduce

  Show description for 906bd6d
  mbalassi

  committed
  906bd6d

  Copy full SHA for 906bd6d

Commits on Sep 24, 2015

• [utils] Missing getters for ParameterTool

  Show description for 6b26e23
  mbalassi

  committed
  6b26e23

  Copy full SHA for 6b26e23

Commits on Aug 27, 2015

• [FLINK-2499] [scripts] Warning message for hosts starting multiple daemons

  Show description for 91069d1
  mbalassi

  committed
  91069d1

  Copy full SHA for 91069d1

Commits on Aug 18, 2015

• [FLINK-2286] [streaming] ITCase for ParallelMerge behavior

  Show description for 67087de
  mbalassi

  committed
  67087de

  Copy full SHA for 67087de

Commits on Aug 11, 2015

• [FLINK-2423] [streaming] ITCase for checkpoint notifications

  Show description for 10ce2e2
  mbalassi

  committed
  10ce2e2

  Copy full SHA for 10ce2e2

• [streaming] [tests] Checkpointing tests refactor & cleanup

  mbalassi

  committed
  4ca7df5

  Copy full SHA for 4ca7df5

Commits on Jul 3, 2015

• [streaming] Minor streaming code cleanups

  Show description for 9d8a348
  mbalassi

  committed
  9d8a348

  Copy full SHA for 9d8a348

• [FLINK-2285] [streaming] Removed duplicate call in close from GroupedActiveDiscretizer

  mbalassi

  committed
  6c21862

  Copy full SHA for 6c21862

Commits on Jun 25, 2015

• [FLINK-2257] [streaming] Properly forward rich window function calls to wrapped functions

  Show description for 658a078
  mbalassi

  committed
  658a078

  Copy full SHA for 658a078

Commits on Jun 18, 2015

• Version bumped to 0.10-SNAPSHOT

  Show description for 9ee4fa5
  mbalassi

  committed
  9ee4fa5

  Copy full SHA for 9ee4fa5

Commits on Jun 16, 2015

• [build] merge transitive notice files to shaded notices

  Show description for 5c1aa34
  

  mbalassi

  authored and

  mxm

  committed
  5c1aa34

  Copy full SHA for 5c1aa34

• [docs] Update obsolate cluster execution guide

  Show description for 20d7e5a
  mbalassi

  committed
  20d7e5a

  Copy full SHA for 20d7e5a

• [FLINK-2209] [docs] Document linking with jars not in the binary dist

  mbalassi

  committed
  be50795

  Copy full SHA for be50795

• [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup

  Show description for 21605d6
  mbalassi

  committed
  21605d6

  Copy full SHA for 21605d6

Commits on Jun 15, 2015

• [contrib] Added log properties files to contrib & minor clean ups

  mbalassi

  committed
  3fe6d19

  Copy full SHA for 3fe6d19

Commits on Jun 14, 2015

• [storm-compat] Moved Storm-compatibility to flink-contrib and split flink-contrib into small sub-projects

  Show description for 12b13f9
  mbalassi

  committed
  12b13f9

  Copy full SHA for 12b13f9

Commits on Jun 12, 2015

• [streaming] [api-breaking] Minor DataStream cleanups

  Show description for 32ddc9e
  mbalassi

  committed
  32ddc9e

  Copy full SHA for 32ddc9e

• [build] [streaming] Streaming parents dependencies pushed to children

  Show description for 9d6290e
  mbalassi

  committed
  9d6290e

  Copy full SHA for 9d6290e

• [streaming] Logging update for checkpointed streaming topologies

  Show description for 078e6ef
  mbalassi

  committed
  078e6ef

  Copy full SHA for 078e6ef

Commits on Jun 10, 2015

• [streaming] Fixed streaming example jars packaging and termination

  Show description for 7f3108d
  mbalassi

  committed
  7f3108d

  Copy full SHA for 7f3108d

Commits on Jun 8, 2015

• [docs] [streaming] Added states and fold to the streaming docs

  mbalassi

  committed
  ee7c417

  Copy full SHA for ee7c417

• [FLINK-2153] Exclude Hbase annotations

  Show description for 1484e00
  mbalassi

  committed
  1484e00

  Copy full SHA for 1484e00

Commits on Jun 6, 2015

• [streaming] Socket Client Sink propagates exceptions

  Show description for e3402c0
  mbalassi

  committed
  e3402c0

  Copy full SHA for e3402c0

• [FLINK-2139] [streaming] Streaming outputformat tests

  mbalassi

  committed
  f72e5c8

  Copy full SHA for f72e5c8

Commits on Jun 5, 2015

• [FLINK-2002] [streaming] Test for iterations being gracefully shut down

  Show description for 3e6b6be
  mbalassi

  committed
  3e6b6be

  Copy full SHA for 3e6b6be

Commits on Jun 4, 2015

• [streaming] Removed StockPrices example

  Show description for 39010dc
  mbalassi

  committed
  39010dc

  Copy full SHA for 39010dc

• [streaming] [scala] ITCases for streaming scala examples

  mbalassi

  committed
  23a3646

  Copy full SHA for 23a3646

Commits on Jun 3, 2015

• [FLINK-2130] [streaming] RMQ Source properly propagates exceptions

  Show description for 39ec54f
  mbalassi

  committed
  39ec54f

  Copy full SHA for 39ec54f

• [streaming] [api-breaking] Consolidate DataStream method names

  Show description for 3527f40
  mbalassi

  committed
  3527f40

  Copy full SHA for 3527f40

• [FLINK-2103] [streaming] [api-extending] PartitionBy for connected streams, scala & docs

  mbalassi

  committed
  6b28bdf

  Copy full SHA for 6b28bdf

Commits on Jun 2, 2015

• [FLINK-1430] [streaming] Scala API completeness for streaming

  Show description for 7571959
  mbalassi

  committed
  7571959

  Copy full SHA for 7571959

Pagination

Previous

Next