Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 17, 2020

• [FLINK-16587][checkpointing] Introducing IndexedInputGate for abstracting single channel InputGates with a specific index.

  

  Arvid Heise

  authored and

  pnowojski

  committedApr 17, 2020
  1007232

Commits on Apr 10, 2020

• [FLINK-16744][task] Send channel state handles to JM

  

  rkhachatryan

  authored and

  pnowojski

  committedApr 10, 2020
  83c8d93

Commits on Apr 9, 2020

• [FLINK-16864][metrics] Add IdleTime metric for task

  

  wenlong.lwl

  authored and

  pnowojski

  committedApr 9, 2020
  b8f0bf4

Commits on Apr 8, 2020

• Revert "[FLINK-16864][metrics] Add IdleTime metric for task"

  pnowojski

  committedApr 8, 2020
  d69d3c0

• [FLINK-16513][checkpointing] add task channel state for unaligned checkpoints

  

  rkhachatryan

  authored and

  carp84

  committedApr 8, 2020
  d6982e6

• [FLINK-16513][checkpointing] pre-requisite refactorings to add channel state to snapshot metadata

  

  rkhachatryan

  authored and

  carp84

  committedApr 8, 2020
  5254920

• [FLINK-16864][metrics] Add IdleTime metric for task

  

  wenlong.lwl

  authored and

  pnowojski

  committedApr 8, 2020
  1878723

• [FLINK-17040][tests] Fix SavepointWriterITCase failure because of UnsupportedOperationException

  

  wsry

  authored and

  zhijiangW

  committedApr 8, 2020
  5303a21

Commits on Mar 25, 2020

• [FLINK-16316][operators] Pass StreamTaskStateInitializer to operators from outside

  pnowojski

  committedMar 25, 2020
  cb4c32f

• [FLINK-16316][operators] Remove chaining strategy methods from the StreamOperator interface

  pnowojski

  committedMar 25, 2020
  c5eb0e5

• [FLINK-16712][task] Refactor StreamTask to construct final fields

  zhijiangW

  committedMar 25, 2020
  bb4ec22

Commits on Mar 20, 2020

• [FLINK-16011] Distinguish between no time window and 0 length time windwo in NFACompiler

  tillrohrmann

  committedMar 20, 2020
  1be88b1

• [FLINK-16011] fix the bug that with will not effect if not in the end of pattern

  

  shuai-xu

  authored and

  tillrohrmann

  committedMar 20, 2020
  96dc51f

Commits on Mar 6, 2020

• [FLINK-16313][state-processor-api] Properly dispose of native resources when closing input split

  

  sjwiesman

  authored and

  tzulitai

  committedMar 6, 2020
  560e805

• [FLINK-16313] Ignore unstable rocksdb state processing api test

  rmetzger

  committedMar 6, 2020
  d1f1d40

Commits on Feb 25, 2020

• [FLINK-16259][checkpoints] Drop interface/impl separation for checkpoint Metadata and rename MetadataV2 to CheckpointMetadata

  StephanEwen

  committedFeb 25, 2020
  ff83629

• [FLINK-16247][checkpoints] Rename 'checkpoints.savepoint.' package and classes to 'checkpoint.metadata.'

  StephanEwen

  committedFeb 25, 2020
  5fa3edc

• [FLINK-16178][refactor] Make the versioned Checkpoint Metadata Serializers only responsible for deserialization.

  StephanEwen

  committedFeb 25, 2020
  f575a82

Commits on Feb 21, 2020

• [FLINK-15672][build][tests] Migrate test log4j configurations to log4j2

  zentol

  committedFeb 21, 2020
  ee7fb5e

• [FLINK-15672][build] Migrate production log4j configuration to log4j2

  zentol

  committedFeb 21, 2020
  e7db6b2

• [FLINK-15672][build] Migrate to log4j2

  zentol

  committedFeb 21, 2020
  e396e7c

• [FLINK-14231][task] Add StreamOperatorWrapper that handles the close, endInput and other related logic of an operator

  

  sunhaibotb

  authored and

  pnowojski

  committedFeb 21, 2020
  56ce696

• [FLINK-14231][task] Add the quiesce() method to ProcessingTimeService and remove TimerService::awaitPendingAfterQuiesce method

  

  sunhaibotb

  authored and

  pnowojski

  committedFeb 21, 2020
  fa22ed2

Commits on Feb 14, 2020

• [hotfix][build] Remove various unused test dependencies

  zentol

  committedFeb 14, 2020
  736ebc0

• [FLINK-15099][runtime] Add Operator Coordinators and Events

  StephanEwen

  committedFeb 14, 2020
  41b6bfa

Commits on Feb 2, 2020

• [FLINK-15627][cep] Correct the wrong naming of compareMaps in NFATestUtilities

  ayushtkn

  committedFeb 2, 2020
  d8164e1

Commits on Jan 15, 2020

• [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

  

  yanghua

  authored and

  aljoscha

  committedJan 15, 2020
  e17907a

• [FLINK-15431][CEP] Add numLateRecordsDropped metric in CepOperator

  

  libenchao

  authored and

  dawidwys

  committedJan 15, 2020
  8d8e708

Commits on Jan 7, 2020

• [FLINK-15406][state-processor-api] RocksDB savepoints with heap timers cannot be restored by non-process functions

  

  sjwiesman

  authored and

  aljoscha

  committedJan 7, 2020
  f21f1c7

Commits on Dec 9, 2019

• Update version to 1.11-SNAPSHOT

  GJL

  committedDec 9, 2019
  4ccac6b

Commits on Dec 6, 2019

• [FLINK-14484][state-backend] Some refactorings for the RocksDB memory controlling code

  StephanEwen

  committedDec 6, 2019
  06fb0ec

Commits on Dec 3, 2019

• [FLINK-15014][state-processor-api] Refactor KeyedStateInputFormat to support multiple types of user functions

  

  sjwiesman

  authored and

  StephanEwen

  committedDec 3, 2019
  faf394d

• [FLINK-14962] Fix various inefficient use of keySet iterator instead of entrySet iterator

  

  caidezhi

  authored and

  KurtYoung

  committedDec 3, 2019
  e2bc967

Commits on Nov 20, 2019

• [FLINK-14871][cep] Add space

  

  cyq89051127

  authored and

  zentol

  committedNov 20, 2019
  051ff03

Commits on Nov 11, 2019

• [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

  

  yanghua

  authored and

  aljoscha

  committedNov 11, 2019
  7a61c58

Pagination

PreviousNext