Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 5, 2017

• [FLINK-7068][blob] Introduce permanent and transient BLOB keys

  Show description for 84a07a3
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  84a07a3

• [FLINK-7261][blob] extend BlobStore#get/put with boolean return values

  Show description for b57330d
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  b57330d

• [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs

  Show description for 071e27f
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  071e27f

• [FLINK-7057][tests][hotfix] fix test instability of JobManagerCleanupITCase#testBlobServerCleanupCancelledJob

  Show description for 98f6dea
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  98f6dea

• [FLINK-7483][blob] prevent cleanup of re-registered jobs

  Show description for 40ef908
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  40ef908

• [FLINK-7754] [rpc] Complete termination future after actor has been stopped

  Show description for 4947ee6
  tillrohrmann

  committed
  4947ee6

Commits on Oct 4, 2017

• [FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field.

  Show description for dae21da
  fhueske

  committed
  dae21da

• [hotfix] [core] Prevent potential null pointer in MemorySize.equals(...)

  StephanEwen

  committed
  5f1ec4a

• [hotfix] Fix testing log level in flink-runtime

  StephanEwen

  committed
  472ae47

• [hotfix] [hbase] Set root log level to OFF for flink-hbase tests.

  Show description for 3a89ab2
  

  fhueske

  authored and

  StephanEwen

  committed
  3a89ab2

• [FLINK-7752] [flip-6] RedirectHandler should execute on the IO thread

  Show description for 818cccd
  

  Wright, Eron

  authored and

  tillrohrmann

  committed
  818cccd

• [FLINK-7412][network] optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

  Show description for 98ddbfd
  

  Nico Kruber

  authored and

  tillrohrmann

  committed
  98ddbfd

Commits on Oct 2, 2017

• [hotfix] [dispatcher] Remove leftover javadoc from DispatcherGateway

  zentol

  committed
  82f27f5

• [FLINK-7710] [flip6] Add CheckpointStatisticsHandler for the new REST endpoint

  Show description for ac82bec
  tillrohrmann

  committed
  ac82bec

• [FLINK-7708] [flip6] Add CheckpointConfigHandler for new REST endpoint

  Show description for b41f5a6
  tillrohrmann

  committed
  b41f5a6

• [FLINK-7695] [flip6] Add JobConfigHandler for new RestServerEndpoint

  Show description for 172a64c
  tillrohrmann

  committed
  172a64c

• [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph based REST handlers

  Show description for aae417f
  tillrohrmann

  committed
  aae417f

• [FLINK-7721] Verify StatusWatermarkValve only emits WM iff it has aligned inputs

  aljoscha

  committed
  c3472b9

• [FLINK-7728] [DataStream] Make StatusWatermarkValve unit tests more fine-grained

  Show description for ea86a53
  

  tzulitai

  authored and

  aljoscha

  committed
  ea86a53

• [FLINK-7728] [DataStream] Flush max watermark across all inputs once all become idle

  Show description for f9b7966
  

  tzulitai

  authored and

  aljoscha

  committed
  f9b7966

• [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest

  Show description for 6481564
  

  tzulitai

  authored and

  aljoscha

  committed
  6481564

• [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs

  Show description for c81a7e5
  

  tzulitai

  authored and

  aljoscha

  committed
  c81a7e5

• [FLINK-7662] [build] Remove now obsolete packaged licenses for previously shaded ASM

  StephanEwen

  committed
  f4cb162

Commits on Sep 29, 2017

• [hotfix] [REST] Extend empty request/parameters support

  Show description for 174ea06
  

  zentol

  authored and

  tillrohrmann

  committed
  174ea06

Commits on Sep 28, 2017

• [FLINK-7667] [flip6] Use ArchivedExecutionGraph as serializable AccessExecutionGraph

  Show description for 2dd557f
  tillrohrmann

  committed
  2dd557f

• [FLINK-7734] [tests] Harden ResourceManagerTest#testHeartbeatTimeoutWithTaskExecutor

  Show description for 4902cdc
  tillrohrmann

  committed
  4902cdc

• [FLINK-7547] Make AsyncFunction.scala extends Function

  Show description for 09df80f
  

  yew1eb

  authored and

  aljoscha

  committed
  09df80f

• [FLINK-5619] Consolidate AggregatingState Tests in StateBackendTestBase

  aljoscha

  committed
  9d7bc7b

• [FLINK-7700] Fix RocksDB ReducingState merging

  Show description for ce0f83e
  aljoscha

  committed
  ce0f83e

• [FLINK-5619] Consolidate ReducingState Tests in StateBackendTestBase

  aljoscha

  committed
  560e5f3

• [FLINK-7700] Fix RocksDB ReducingState merging

  Show description for c691856
  aljoscha

  committed
  c691856

• [FLINK-5619] Consolidate ListState Tests in StateBackendTestBase

  aljoscha

  committed
  f03f832

• [FLINK-7700] Fix RocksDB ListState merging

  Show description for 93456ff
  aljoscha

  committed
  93456ff

• [FLINK-5619] Add numStateEntries() method for all keyed backends

  Show description for fc9bc2f
  aljoscha

  committed
  fc9bc2f

• [hotfix] Add checkstyle suppressions for StateBackendTestBase

  Show description for 2b66186
  aljoscha

  committed
  2b66186

Pagination

PreviousNext