Commits

Branch selector

 master

User selector

azagrebin

Datepicker

All time

Commit History

Commits on Jan 25, 2019

• [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

  Show description for bced96a
  

  azagrebin

  authored and

  tillrohrmann

  committed
  bced96a

Commits on Dec 20, 2018

• [FLINK-10461][runtime] Refactor direct executor service

  Show description for 1708260
  

  2 peopleauthored and

  zentol

  committed
  1708260

Commits on Dec 6, 2018

• [FLINK-10482] Fix double counting of checkpoint stat

  

  azagrebin

  authored and

  tillrohrmann

  committed
  114cb2c

• [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running (apache#7216)

  

  azagrebin

  authored and

  tillrohrmann

  committed
  64f6d0b

Commits on Nov 23, 2018

• [FLINK-10946] Silence checkpoint exception logging in task executor if job is not running

  

  azagrebin

  authored and

  StefanRRichter

  committed
  6e62ca2

• [FLINK-10842] [e2e] Fix broken waiting loops in common.sh

  Show description for 76afc31
  

  azagrebin

  authored and

  twalthr

  committed
  76afc31

Commits on Nov 16, 2018

• [FLINK-10736] [tests] Use staticly hosted test data for S3 wordcount tests

  Show description for aabbd65
  

  azagrebin

  authored and

  StephanEwen

  committed
  aabbd65

• [FLINK-10869] [tests] Fix test_streaming_file_sink to use proper and unique output directory

  

  azagrebin

  authored and

  StephanEwen

  committed
  6a97c11

Commits on Nov 15, 2018

• [FLINK-10628][E2E][SSL] Enable mutual REST SSL auth in e2e tests

  

  azagrebin

  authored and

  zentol

  committed
  6f9aa83

Commits on Nov 14, 2018

• [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination (apache#6989)

  Show description for 9f1f25d
  

  azagrebin

  authored and

  pnowojski

  committed
  9f1f25d

Commits on Nov 5, 2018

• [FLINK-10627][e2e] Test s3 output for streaming file sink.

  Show description for e9703e7
  

  azagrebin

  authored and

  kl0u

  committed
  e9703e7

Commits on Oct 15, 2018

• [FLINK-10075][rest] Addnull check before KeepAliveWrite.flush

  

  azagrebin

  authored and

  zentol

  committed
  be23889

Commits on Oct 10, 2018

• [FLINK-10075][rest] Redirect non-ssl requests to https url if ssl is enabled

  

  azagrebin

  authored and

  zentol

  committed
  b46e195

Commits on Oct 9, 2018

• [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

  

  azagrebin

  authored and

  zentol

  committed
  a887b7f

Commits on Oct 1, 2018

• [FLINK-10312][rest] Propagate exception from server to client in REST API

  

  azagrebin

  authored and

  zentol

  committed
  06c1b7e

Commits on Sep 26, 2018

• [FLINK-9891] Make shutdown of started cluster in attached mode optional, add cli option 'schutdownOnAttachedExist'

  Show description for a36d199
  

  azagrebin

  authored and

  GJL

  committed
  a36d199

Commits on Sep 21, 2018

• [FLINK-10157][State TTL] Allow null user values in map state with TTL

  Show description for f343204
  

  azagrebin

  authored and

  StefanRRichter

  committed
  f343204

Commits on Sep 20, 2018

• [FLINK-10260] Clean up log messages for TaskExecutor registrations

  Show description for 542e8cc
  

  azagrebin

  authored and

  tillrohrmann

  committed
  542e8cc

Commits on Sep 14, 2018

• [FLINK-10325] [State TTL] Refactor TtlListState to use only loops, no java stream API for performance

  Show description for 2e21582
  

  azagrebin

  authored and

  tillrohrmann

  committed
  2e21582

Commits on Aug 16, 2018

• [FLINK-10151][state] Fix false recursion call for state TTL in TransformingStateTableKeyGroupPartitioner.tryAddToSource

  Show description for c73747b
  

  azagrebin

  authored and

  StefanRRichter

  committed
  c73747b

Commits on Aug 9, 2018

• [FLINK-9637] [docs] Add public user documentation for state TTL feature

  Show description for 44eef6f
  

  azagrebin

  authored and

  twalthr

  committed
  44eef6f

Commits on Aug 7, 2018

• [FLINK-10095][state] Swap serialization order in TTL value: first timestamp then user value

  Show description for b535fab
  

  azagrebin

  authored and

  StefanRRichter

  committed
  b535fab

Commits on Aug 3, 2018

• [FLINK-9938][state] Clean up full snapshot from expired state with TTL

  Show description for ce96c40
  

  azagrebin

  authored and

  StefanRRichter

  committed
  ce96c40

Commits on Jul 27, 2018

• [FLINK-8439] Add Flink shading to AWS credential provider s3 hadoop config

  

  azagrebin

  authored and

  aljoscha

  committed
  7be0787

Commits on Jul 20, 2018

• [FLINK-9858][tests] State TTL End-to-End Test

  Show description for 01cf808
  

  azagrebin

  authored and

  StefanRRichter

  committed
  01cf808

Commits on Jul 13, 2018

• [FLINK-9701] [state] (follow up) Use StateTtlConfiguration.DISABLED instead of null, make it Serializable and add

  Show description for 1632681
  

  azagrebin

  authored and

  tillrohrmann

  committed
  1632681

Commits on Jul 12, 2018

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

  Show description for f45b7f7
  

  azagrebin

  authored and

  StefanRRichter

  committed
  f45b7f7

Commits on Jul 4, 2018

• [FLINK-9513][state] Implement TTL state wrappers factory and serializer for value with TTL

  Show description for afdbf54
  

  azagrebin

  authored and

  StefanRRichter

  committed
  afdbf54

Commits on Jul 3, 2018

• [FLINK-9301][tests] Enable high-parallellism-iterations test

  Show description for 885640f
  

  azagrebin

  authored and

  zentol

  committed
  885640f

Commits on Jun 29, 2018

• [FLINK-9514,FLINK-9515,FLINK-9516] Introduce wrapper to enhance state with ttl

  Show description for 2c13e00
  

  azagrebin

  authored and

  StefanRRichter

  committed
  2c13e00

Commits on Jun 22, 2018

• [FLINK-9493] Forward cause when releasing a TaskManager at the SlotPool

  Show description for 5372813
  

  azagrebin

  authored and

  tillrohrmann

  committed
  5372813

Commits on Jun 18, 2018

• [FLINK-9571] Repace StateBinder with internal backend-specific state factories

  Show description for 0bdde83
  

  azagrebin

  authored and

  StefanRRichter

  committed
  0bdde83

Commits on Jun 15, 2018

• [FLINK-8573] Extend ProgramInvocationException message with Job ID where applicable

  Show description for fc3ee68
  

  azagrebin

  authored and

  tillrohrmann

  committed
  fc3ee68

Commits on Jun 14, 2018

• [FLINK-9572] Extend InternalAppendingState with internal stored state access

  Show description for 09fbf23
  

  azagrebin

  authored and

  StefanRRichter

  committed
  09fbf23