Commits

Branch selector

 d34f8cc

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 13, 2018

• [FLINK-9810][rest] Close jar file in JarListHandler

  Show description for d34f8cc
  zentol

  committed
  d34f8cc

• [FLINK-9801][build] Add missing example dependencies to flink-dist

  Show description for 63f353f
  zentol

  committed
  63f353f

• [FLINK-9563][cep][tests] Migrate CEPITCase to collect()

  Show description for 40f9131
  

  deepaks4077

  authored and

  zentol

  committed
  40f9131

Commits on Jul 12, 2018

• [hotfix] Fixed import order in RocksDBKeyedStateBackend.

  kl0u

  committed
  ca0fa96

• [FLINK-8480][DataStream] Add APIs for Interval Joins.

  Show description for 42ada8a
  

  florianschmidt1994

  authored and

  kl0u

  committed
  42ada8a

• [FLINK-9701] Introduce TTL configuration in state descriptors

  Show description for f45b7f7
  

  azagrebin

  authored and

  StefanRRichter

  committed
  f45b7f7

• [hotfix] Correct checkstyle violations in RestartStrategies

  tillrohrmann

  committed
  b407ba7

• [FLINK-9804][state] Fix KeyedStateBackend.getKeys() for RocksDBMapState.

  Show description for def2aed
  sihuazhou

  committed
  def2aed

• [FLINK-9799][state] Generalize and unify state meta infos

  Show description for f1ac0f2
  StefanRRichter

  committed
  f1ac0f2

• [FLINK-9784] Fix inconsistent use of 'static' in AsyncIOExample.java

  Show description for 5363595
  

  nekrassov

  authored and

  tillrohrmann

  committed
  5363595

• [FLINK-9766][network][tests] fix cleanup in RemoteInputChannelTest

  Show description for 598e460
  

  Nico Kruber

  committed
  598e460

• [hotfix][checkstyle] fix checkstyle in PartitionRequestClientFactory

  

  Nico Kruber

  committed
  a154dd5

• [FLINK-9785][network] add remote address information to LocalTransportException instances

  Show description for 9e87e20
  

  Nico Kruber

  committed
  9e87e20

• [FLINK-9809] [DataSteam API] Allow setting co-location constraints on StreamTransformations.

  Show description for 3f0b9fe
  StephanEwen

  committed
  3f0b9fe

Commits on Jul 11, 2018

• [FLINK-9706] Properly wait for termination of JobManagerRunner before restarting jobs

  Show description for 3c4e59a
  tillrohrmann

  committed
  3c4e59a

• [FLINK-9511] Implement state TTL configuration

  Show description for dc7d81c
  

  yanghua

  authored and

  StefanRRichter

  committed
  dc7d81c

• [FLINK-5363] Clarify Trigger behaviour for empty windows

  aljoscha

  committed
  5c43d2b

• [FLINK-5363] Fire timers when window state is currently empty

  Show description for fdce4b2
  

  minwenjun

  authored and

  aljoscha

  committed
  fdce4b2

• [FLINK-9754][release] Remove references to scala profiles

  Show description for c3b013b
  zentol

  committed
  c3b013b

• [FLINK-9768][release] Speed up binary release

  Show description for 04d0009
  zentol

  committed
  04d0009

• [hotfix][rat] Add *.snapshot files to RAT exclusion list

  Show description for 0cb1fe2
  

  nekrassov

  authored and

  zentol

  committed
  0cb1fe2

• [FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink

  Show description for 04a7cd4
  

  sihuazhou

  authored and

  zentol

  committed
  04a7cd4

• [FLINK-9666][refactor] Use short-circuit logic in boolean contexts

  Show description for 5dbb6dd
  

  lamber-ken

  authored and

  zentol

  committed
  5dbb6dd

• [FLINK-9730][refactor] Fix static accesses via instance reference

  Show description for cad6e4d
  

  lamber-ken

  authored and

  zentol

  committed
  cad6e4d

• [FLINK-9187][metrics] Add Prometheus PushGateway reporter

  Show description for 5ee5dbf
  

  lamber-ken

  authored and

  zentol

  committed
  5ee5dbf

• [FLINK-9789][metrics] Ensure uniqueness of watermark metrics

  Show description for 60df251
  zentol

  committed
  60df251

• [FLINK-9743][client] Use correct zip path separator for nested jars

  Show description for 2fbe562
  

  snuyanzin

  authored and

  zentol

  committed
  2fbe562

• [FLINK-9470] Allow querying the key in KeyedProcessFunction

  aljoscha

  committed
  cde504e

Commits on Jul 10, 2018

• [FLINK-9776] [runtime] Stop sending periodic interrupts once executing thread leaves user function / operator code.

  Show description for 53e6657
  StephanEwen

  committed
  53e6657

• [FLINK-9691] [kinesis] Modify runloop to try to track a particular getRecords() frequency.

  Show description for 7953a2e
  

  Jamie Grier

  authored and

  StephanEwen

  committed
  7953a2e

• [FLINK-8863] [sql-client] Make user-defined functions more robust

  Show description for abfdc1a
  twalthr

  committed
  abfdc1a

• [FLINK-8863] [sql-client] Add user-defined function support in SQL Client

  Show description for 8014dad
  

  xccui

  authored and

  twalthr

  committed
  8014dad

Commits on Jul 9, 2018

• [FLINK-9486][state] Introduce InternalPriorityQueue as state in keyed state backends

  Show description for 79b38f8
  StefanRRichter

  committed
  79b38f8

• [FLINK-9603] Fix part counter loop in BucketingSink to account for part suffix.

  Show description for b12acea
  

  testrinatsharipov

  authored and

  kl0u

  committed
  b12acea

• [FLINK-9772][docs] Update Hadoop compatibility docs regarding HadoopInputs

  Show description for b5b4fb9
  

  yanghua

  authored and

  zentol

  committed
  b5b4fb9

Pagination

PreviousNext