Commits

Branch selector

 master

User selector

gyfora

Datepicker

All time

Commit History

Commits on Jun 10, 2015

• [streaming] Allow force-enabling checkpoints for iterative jobs

  gyfora

  committed
  4fe2e18

  Copy full SHA for 4fe2e18

Commits on Jun 9, 2015

• [streaming] Optional iteration feedback partitioning added

  Show description for 1481647
  gyfora

  committed
  1481647

  Copy full SHA for 1481647

Commits on Jun 1, 2015

• [streaming] Test added for iteration sink-source CoLocation + non-chained windowing

  gyfora

  committed
  ac43a69

  Copy full SHA for ac43a69

Commits on May 27, 2015

• [streaming] Fix streamrecordwriter behaviour with buffer timeout set to 0

  gyfora

  committed
  f5f1a03

  Copy full SHA for f5f1a03

Commits on May 26, 2015

• [streaming] Fix iteration colocation + enable chaining for iterative jobs

  gyfora

  committed
  4de2353

  Copy full SHA for 4de2353

Commits on May 25, 2015

• [streaming] Fix bug with iteration sink/source syncing

  gyfora

  committed
  fdac963

  Copy full SHA for fdac963

• [FLINK-2082] [streaming] Create own context for chained streaming operators

  gyfora

  committed
  0cfa43d

  Copy full SHA for 0cfa43d

Commits on May 22, 2015

• [streaming] Minor bugfix in the BarrierBuffer input finishing logic

  gyfora

  committed
  36c2026

  Copy full SHA for 36c2026

Commits on May 19, 2015

• [streaming] State backend configurable from flink-conf.yaml

  Show description for 1479973
  gyfora

  committed
  1479973

  Copy full SHA for 1479973

• [FLINK-1986] [streaming] Iterative stream creation bugfix

  gyfora

  committed
  2d3e69a

  Copy full SHA for 2d3e69a

• [streaming] Added HDFS test for FileStateHandle

  gyfora

  committed
  6edf31a

  Copy full SHA for 6edf31a

• [streaming] StateHandleProvider added for configurable state backend

  gyfora

  committed
  197cd6c

  Copy full SHA for 197cd6c

• [streaming] Discard method added to state handle

  gyfora

  committed
  59bee4a

  Copy full SHA for 59bee4a

• [streaming] ByteStream and File state handle added

  gyfora

  committed
  48a2720

  Copy full SHA for 48a2720

Commits on May 12, 2015

• [streaming] StreamTask updated to handle chained states

  

  gyfora

  authored and

  StephanEwen

  committed
  c8de656

  Copy full SHA for c8de656

• [streaming] Discretizer reuse bugfixes

  gyfora

  committed
  ff750e6

  Copy full SHA for ff750e6

Commits on Apr 29, 2015

• [FLINK-1948] [streaming] Manual task slot sharing settings added for stream operators

  Show description for ca82b0c
  

  gyfora

  authored and

  mbalassi

  committed
  ca82b0c

  Copy full SHA for ca82b0c

Commits on Apr 26, 2015

• [streaming] Timestamp comparison bugfix

  gyfora

  committed
  8791d4f

  Copy full SHA for 8791d4f

Commits on Apr 22, 2015

• [streaming] FullStream window helper added + partitioner bugfix

  Show description for 56cb793
  gyfora

  committed
  56cb793

  Copy full SHA for 56cb793

• [FLINK-1909] [streaming] Type handling refactor for sources + scala api

  gyfora

  committed
  6df1dd2

  Copy full SHA for 6df1dd2

Commits on Apr 20, 2015

• [streaming] Parallel time reduce logic refactor to force prereducers

  gyfora

  committed
  a0900e7

  Copy full SHA for a0900e7

Commits on Apr 15, 2015

• [streaming] Major internal renaming and restructure

  Show description for 4754a97
  gyfora

  committed
  4754a97

  Copy full SHA for 4754a97

• [FLINK-1876] [streaming] StreamGraph refactor

  gyfora

  committed
  f1b445b

  Copy full SHA for f1b445b

Commits on Apr 14, 2015

• [FLINK-1866] [streaming] StreamConfig key bugfix

  

  gyfora

  authored and

  mbalassi

  committed
  54d5662

  Copy full SHA for 54d5662

Commits on Apr 10, 2015

• [streaming] Removed unnecessary BatchIterator class

  gyfora

  committed
  46573a6

  Copy full SHA for 46573a6

• [FLINK-1838] [doc] Streaming programming guide update

  gyfora

  committed
  e01894c

  Copy full SHA for e01894c

Commits on Apr 8, 2015

• [FLINK-1793] [streaming] Fix file source isRunning check for proper cancelling

  gyfora

  committed
  62c465c

  Copy full SHA for 62c465c

• [FLINK-1813] Avoid illegalstate exception when trying to broadcast on finished operators

  Show description for e8faff7
  gyfora

  committed
  e8faff7

  Copy full SHA for e8faff7

Commits on Apr 5, 2015

• [FLINK-1824] [streaming] Support added for missing types in DataStream api

  Show description for 1cf49e9
  

  gyfora

  authored and

  mbalassi

  committed
  1cf49e9

  Copy full SHA for 1cf49e9

Commits on Apr 3, 2015

• [FLINK-1803] [streaming] returns(..) method added to Stream operators

  Show description for 189001d
  

  gyfora

  authored and

  mbalassi

  committed
  189001d

  Copy full SHA for 189001d

Commits on Apr 1, 2015

• [streaming] Streaming program cancellation bugfix

  gyfora

  committed
  5691f26

  Copy full SHA for 5691f26

Commits on Mar 26, 2015

• [FLINK-1775] BarrierBuffer fix to avoid end of stream deadlock

  Show description for 83db1db
  gyfora

  committed
  83db1db

  Copy full SHA for 83db1db

• [FLINK-1773] [streaming] Introduced CentralActiveTrigger with GroupedActiveDiscretizer

  Show description for 7ed95d9
  gyfora

  committed
  7ed95d9

  Copy full SHA for 7ed95d9

Commits on Mar 22, 2015

• [FLINK-1763] [streaming] Remove cancel from SinkFunction

  Show description for 35f3416
  

  gyfora

  authored and

  mbalassi

  committed
  35f3416

  Copy full SHA for 35f3416

Commits on Mar 20, 2015

• [streaming] ChainableInvokable refactor

  gyfora

  committed
  ff60ecf

  Copy full SHA for ff60ecf

Pagination

Previous

Next