Commits

Branch selector

 master

User selector

gyfora

Datepicker

All time

Commit History

Commits on Aug 24, 2016

• [FLINK-4441] Make RocksDB backend return null on empty state + add test for all backends

  Show description for c09ff03
  gyfora

  committed
  c09ff03

  Copy full SHA for c09ff03

Commits on Apr 21, 2016

• [hotfix] [FLINK-3798] Make RocksDB state classes also public

  gyfora

  committed
  7478cba

  Copy full SHA for 7478cba

• [FLINK-3790] [streaming] Use proper hadoop config in rolling sink

  Show description for d45cb69
  gyfora

  committed
  d45cb69

  Copy full SHA for d45cb69

• [FLINK-3798] [streaming] Clean up RocksDB backend field/method access

  Show description for d636bf7
  gyfora

  committed
  d636bf7

  Copy full SHA for d636bf7

Commits on Mar 16, 2016

• [FLINK-3620] [streaming] Remove DbStateBackend

  Show description for 33f4311
  gyfora

  committed
  33f4311

  Copy full SHA for 33f4311

Commits on Feb 15, 2016

• [FLINK-3354] Determine correct size for RocksDB snapshots

  Show description for b17632d
  gyfora

  committed
  b17632d

  Copy full SHA for b17632d

Commits on Nov 29, 2015

• [FLINK-3075] Change Either creation method names and expose Right/Left classes

  Show description for 3e9d33e
  gyfora

  committed
  3e9d33e

  Copy full SHA for 3e9d33e

Commits on Nov 25, 2015

• [FLINK-3072] [streaming] Ensure Derby server starts before running any tests

  Show description for 90c76ad
  gyfora

  committed
  90c76ad

  Copy full SHA for 90c76ad

Commits on Nov 24, 2015

• [FLINK-2924] [streaming] Execute compactions in background thread + keep connections alive on empty snapshots

  Show description for db2a964
  gyfora

  committed
  db2a964

  Copy full SHA for db2a964

• [FLINK-2924] [streaming] Use short job id for table names

  gyfora

  committed
  cd8be0b

  Copy full SHA for cd8be0b

• [FLINK-2924] [streaming] Improve compacting logic

  gyfora

  committed
  43b8e57

  Copy full SHA for 43b8e57

• [FLINK-2924] [streaming] Use timestamps to store checkpoints so it supports job shutdown/restart

  gyfora

  committed
  c254bda

  Copy full SHA for c254bda

• [FLINK-2924] [streaming] Improved sharding logic

  gyfora

  committed
  347e6f7

  Copy full SHA for 347e6f7

• [FLINK-2924] [streaming] Out-of-core state backend for JDBC databases

  gyfora

  committed
  75a7c4b

  Copy full SHA for 75a7c4b

• [FLINK-2916] [streaming] Expose operator and task information to StateBackend

  gyfora

  committed
  ad6f826

  Copy full SHA for ad6f826

Commits on Oct 6, 2015

• [FLINK-2822] [streaming] Remove scala.Serializable imports

  

  gyfora

  authored and

  mbalassi

  committed
  4c5d43b

  Copy full SHA for 4c5d43b

Commits on Oct 4, 2015

• [FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations

  Show description for 88a9776
  gyfora

  committed
  88a9776

  Copy full SHA for 88a9776

Commits on Sep 21, 2015

• [FLINK-2713] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead

  Show description for 63d9800
  gyfora

  committed
  63d9800

  Copy full SHA for 63d9800

Commits on Sep 18, 2015

• [FLINK-2707] [streaming] Set StateCheckpointer before default state value

  gyfora

  committed
  3e233a3

  Copy full SHA for 3e233a3

Commits on Sep 14, 2015

• [FLINK-2664] [streaming] Allow partitioned state removal

  Show description for 8a75025
  gyfora

  committed
  8a75025

  Copy full SHA for 8a75025

Commits on Aug 2, 2015

• [FLINK-2436] [streaming] Make ByteStreamStateHandles more robust

  Show description for 83102f0
  gyfora

  committed
  83102f0

  Copy full SHA for 83102f0

Commits on Jul 30, 2015

• [FLINK-2324] [streaming] Added test for different StateHandle wrappers

  Show description for 83e14cb
  gyfora

  committed
  83e14cb

  Copy full SHA for 83e14cb

• [FLINK-2324] [streaming] ITCase added for partitioned states

  gyfora

  committed
  58cd4ea

  Copy full SHA for 58cd4ea

• [FLINK-2324] [streaming] Partitioned state checkpointing rework + test update

  gyfora

  committed
  0558644

  Copy full SHA for 0558644

Commits on Jul 29, 2015

• [FLINK-2419] Add test for sinks after keyBy and groupBy

  Show description for 73af891
  gyfora

  committed
  73af891

  Copy full SHA for 73af891

Commits on Jul 28, 2015

• [FLINK-2419] [hotfix] addSink now uses transform + remove double checkpoint commit at head operator

  gyfora

  committed
  78fd214

  Copy full SHA for 78fd214

• [FLINK-2405] [streaming] Added stateful functions to Scala DataStreams

  gyfora

  committed
  042b2e8

  Copy full SHA for 042b2e8

Commits on Jul 24, 2015

• [streaming] Copy default state values for partitioned states

  gyfora

  committed
  acb6a93

  Copy full SHA for acb6a93

Commits on Jul 11, 2015

• [FLINK-2335] [streaming] Lazy iteration construction in StreamGraph

  Show description for 3b69b24
  gyfora

  committed
  3b69b24

  Copy full SHA for 3b69b24

Commits on Jul 7, 2015

• [FLINK-2323] [api-breaking] Rename OperatorState interface methods to value() and update(..)

  Show description for 0d2c490
  gyfora

  committed
  0d2c490

  Copy full SHA for 0d2c490

Commits on Jun 30, 2015

• [FLINK-2294] [streaming] Fix partitioned state next-input setting for copying chained collectors

  gyfora

  committed
  fef9f11

  Copy full SHA for fef9f11

Commits on Jun 27, 2015

• [streaming] Created scala GroupedDataStream

  Show description for b35aa20
  gyfora

  committed
  b35aa20

  Copy full SHA for b35aa20

Commits on Jun 26, 2015

• [FLINK-2261] [streaming] Remove reduce/fold/aggregations from DataStream

  gyfora

  committed
  3f3b17e

  Copy full SHA for 3f3b17e

• [FLINK-2279] [streaming] Add Connected Iteration

  Show description for 128d3bc
  gyfora

  committed
  128d3bc

  Copy full SHA for 128d3bc

Commits on Jun 25, 2015

• [streaming] Re-enable Checkpointed interface for drawing snapshots

  gyfora

  committed
  0ae1758

  Copy full SHA for 0ae1758

Pagination

Previous

Next