Commits

Breadcrumbs

History for

on294c082

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 30, 2017

• [FLINK-5628] [webfrontend] Fix serializability of checkpoint stats tracker

  Show description for dcfa3fb
  uce

  committed
  dcfa3fb

  Copy full SHA for dcfa3fb

Commits on Jan 29, 2017

• [FLINK-5663] [runtime] Prevent leaking SafetyNetCloseableRegistry through InheritableThreadLocal

  Show description for 50b6656
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  50b6656

  Copy full SHA for 50b6656

Commits on Jan 27, 2017

• [FLINK-5660] [state] Fix state cleanup of PendingCheckpoint

  Show description for 009da6f
  tillrohrmann

  committed
  009da6f

  Copy full SHA for 009da6f

• [FLINK-5666] [tests] Add blob server clean up tests

  Show description for 24db045
  

  Nico Kruber

  authored and

  uce

  committed
  24db045

  Copy full SHA for 24db045

Commits on Jan 25, 2017

• [FLINK-5602] Introduce artifical namespace serializer for migration

  Show description for b9ea4cf
  

  StefanRRichter

  authored and

  uce

  committed
  b9ea4cf

  Copy full SHA for b9ea4cf

• [FLINK-5626] Improved resource deallocation in RocksDBKeyedStateBackend

  

  StefanRRichter

  authored and

  uce

  committed
  cd9115f

  Copy full SHA for cd9115f

• [FLINK-5643] Fix NPE in StateUtil

  Show description for cf9f4c7
  tillrohrmann

  committed
  cf9f4c7

  Copy full SHA for cf9f4c7

• [FLINK-5492] Fix TaskManager log entry

  rmetzger

  committed
  cf6b3fb

  Copy full SHA for cf6b3fb

Commits on Jan 24, 2017

• [hotfix] [streaming api] Improve JavaDocs of the user-fcing checkpointing and state interfaces

  StephanEwen

  committed
  c69f366

  Copy full SHA for c69f366

• [FLINK-5473] Limit max parallelism to 1 for non-parallel operators

  Show description for acfeeaf
  

  StefanRRichter

  authored and

  tillrohrmann

  committed
  acfeeaf

  Copy full SHA for acfeeaf

• [FLINK-4552] Refactor WindowOperator/Trigger Tests

  Show description for d1475ee
  aljoscha

  committed
  d1475ee

  Copy full SHA for d1475ee

Commits on Jan 23, 2017

• [FLINK-5464] [metrics] Improve MetricDumpSerialization exception handling

  Show description for a8e85a2
  zentol

  committed
  a8e85a2

  Copy full SHA for a8e85a2

• [FLINK-5464] [metrics] Ignore metrics that are null

  zentol

  committed
  7704724

  Copy full SHA for 7704724

• [hotfix] Remove unused variable in MetricDumpSerializerTest

  zentol

  committed
  02d7e4a

  Copy full SHA for 02d7e4a

• [FLINK-5298] TM checks that log file exists

  Show description for b8fa8c6
  zentol

  committed
  b8fa8c6

  Copy full SHA for b8fa8c6

• [FLINK-5229] [state] Cleanup of operator snapshots if subsequent operator snapshots fail

  Show description for cfb95b9
  tillrohrmann

  committed
  cfb95b9

  Copy full SHA for cfb95b9

• [FLINK-5214] Clean up checkpoint data in case of a failing checkpoint operation

  Show description for e458975
  tillrohrmann

  committed
  e458975

  Copy full SHA for e458975

• [FLINK-5118] [metrics] Fix inconsistent numBytesIn/Out metrics for network channels

  Show description for 3a258f7
  

  zentol

  authored and

  StephanEwen

  committed
  3a258f7

  Copy full SHA for 3a258f7

• [FLINK-5492] [log] Log unresolved address when starting an ActorSystem

  Show description for 3b32d1b
  tillrohrmann

  committed
  3b32d1b

  Copy full SHA for 3b32d1b

• [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFactory to create ZooKeeper utility classes

  Show description for df3f119
  tillrohrmann

  committed
  df3f119

  Copy full SHA for df3f119

• [FLINK-5496] [mesos] Relocate Mesos Protobuf dependency to avoid version conflicts

  Show description for 04f4ecc
  tillrohrmann

  committed
  04f4ecc

  Copy full SHA for 04f4ecc

Commits on Jan 22, 2017

• [FLINK-5582] [streaming] Add 'AggregateFunction' and 'AggregatingState'.

  Show description for 09380e4
  StephanEwen

  committed
  09380e4

  Copy full SHA for 09380e4

• [hotfix] [runtime] Various code cleanups and reductions of warnings in heap state restoring code

  StephanEwen

  committed
  b8a784e

  Copy full SHA for b8a784e

• [FLINK-5590] [runtime] Add proper internal state hierarchy

  Show description for 3b97128
  StephanEwen

  committed
  3b97128

  Copy full SHA for 3b97128

• [hotfix] Remove no longer used Generic State classes

  StephanEwen

  committed
  254a700

  Copy full SHA for 254a700

• [hotfix] Cleanups of the AbstractKeyedStateBackend

  StephanEwen

  committed
  51c02ee

  Copy full SHA for 51c02ee

• [FLINK-5559] [queryable state] Throw proper IOException deserializeKeyAndNamespace

  Show description for 21742b2
  

  Nico Kruber

  authored and

  uce

  committed
  21742b2

  Copy full SHA for 21742b2

• [FLINK-5576] [queryable state] Add tests to for KvStateRequestSerializerTest

  Show description for 563c3a4
  

  Nico Kruber

  authored and

  uce

  committed
  563c3a4

  Copy full SHA for 563c3a4

• [FLINK-5576] [queryable state] Improve failure message deserializeList

  Show description for 3fe2cf5
  

  Nico Kruber

  authored and

  uce

  committed
  3fe2cf5

  Copy full SHA for 3fe2cf5

• [FLINK-5576] [queryable state] Check unconsumed bytes in deserializeValue

  Show description for c1c6ef1
  

  Nico Kruber

  authored and

  uce

  committed
  c1c6ef1

  Copy full SHA for c1c6ef1

• [FLINK-5530] [queryable state] Fix race condition in AbstractRocksDBState#getSerializedValue

  Show description for d16552d
  

  Nico Kruber

  authored and

  uce

  committed
  d16552d

  Copy full SHA for d16552d

Commits on Jan 20, 2017

• [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators

  StephanEwen

  committed
  24ff9eb

  Copy full SHA for 24ff9eb

• [FLINK-5468] [savepoints] Improve error message for migrating semi async RocksDB snapshot

  Show description for 988729e
  

  StefanRRichter

  authored and

  uce

  committed
  988729e

  Copy full SHA for 988729e

• [FLINK-5561] [runtime] Fix DataInputDeserializer#available()

  Show description for 6c4644d
  

  Nico Kruber

  authored and

  uce

  committed
  6c4644d

  Copy full SHA for 6c4644d

• [FLINK-5515] [queryable state] Remove unused getSerializedValue call

  Show description for ddd7c36
  

  Nico Kruber

  authored and

  uce

  committed
  ddd7c36

  Copy full SHA for ddd7c36

Pagination

Previous

Next