Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on May 18, 2021

• [FLINK-22067][tests] Wait for vertices to using API

  rkhachatryan

  committed
  0528f84

Commits on May 10, 2021

• [hotfix] Disable broken savepoint tests tracked in FLINK-22067

  rmetzger

  committed
  464e0d0

Commits on May 7, 2021

• [FLINK-22560][build] Filter maven metadata directory

  zentol

  committed
  06b3e26

Commits on May 5, 2021

• [FLINK-22442][CEP] Using scala api to change the TimeCharacteristic of the PatternStream is invalid

  Show description for cb0d8eb
  

  chennuo

  authored and

  dawidwys

  committed
  cb0d8eb

• [FLINK-22379][runtime] CheckpointCoordinator checks the state of all subtasks before triggering the checkpoint

  

  akalash

  authored and

  rkhachatryan

  committed
  ae402bc

Commits on Apr 18, 2021

• Update version to 1.14-SNAPSHOT

  guoweiM

  committed
  bb17562

Commits on Mar 30, 2021

• [FLINK-21945][streaming] Force aligned barriers on pointwise connections.

  Show description for 41936fe
  

  Arvid Heise

  authored and

  AHeise

  committed
  41936fe

Commits on Mar 28, 2021

• [FLINK-21626][core] Make RuntimeContext.jobID non-optional

  rkhachatryan

  committed
  42c6414

Commits on Mar 15, 2021

• [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

  Show description for d72fa2e
  

  curcur

  authored and

  rkhachatryan

  committed
  d72fa2e

Commits on Mar 11, 2021

• [FLINK-19801][checkpoint] Expose rescale descriptors in TaskStateManager and add ambiguity of subtasks + max parallelism.

  Show description for 5456814
  

  Arvid Heise

  authored and

  AHeise

  committed
  5456814

Commits on Mar 2, 2021

• [hotfix][runtime] Add job ID to RuntimeContext

  rkhachatryan

  committed
  cb8a8c6

Commits on Feb 27, 2021

• [hotfix][tests] Disable incremental checkpoints in CEPOperatorTest

  Show description for 546be79
  rkhachatryan

  committed
  546be79

Commits on Feb 24, 2021

• [FLINK-19970] State leak in CEP Operators

  Show description for 5a22de9
  dawidwys

  committed
  5a22de9

• [hotfix] Drop compatibility with Flink <= 1.5

  Show description for 4f6a94f
  dawidwys

  committed
  4f6a94f

Commits on Feb 22, 2021

• [FLINK-20536][tests] Update migration tests of CEPMigrationTest to cover migration from 1.12

  dianfu

  committed
  0259591

Commits on Feb 18, 2021

• [FLINK-20534] Add Flink 1.12 snapshots for TypeSerializer upgrade tests

  Show description for 6875421
  dianfu

  committed
  6875421

Commits on Feb 11, 2021

• [FLINK-21315][state-processor-api]set an operator name when collecting existing operator states.

  Show description for ae5bea3
  

  qinjunjerry

  authored and

  sjwiesman

  committed
  ae5bea3

• [FLINK-21315][state-processor-api]return DataSource<T> such that users can set operator names

  

  qinjunjerry

  authored and

  sjwiesman

  committed
  d8d446a

Commits on Jan 28, 2021

• [FLINK-20675][checkpointing] Refactor interfaces to decline checkpoint with CheckpointException

  Myasuka

  committed
  f421c6f

Commits on Jan 25, 2021

• [FLINK-19462][checkpointing] Report aborted checkpoint stats

  Show description for 621ea85
  

  rkhachatryan

  authored and

  pnowojski

  committed
  621ea85

• [FLINK-19465][runtime / statebackends] Remove checkpoint storage methods from StateBackend interface

  Show description for 2426d84
  sjwiesman

  committed
  2426d84

Commits on Dec 28, 2020

• [FLINK-20651] Format code with Spotless/google-java-format

  

  Rufus Refactor

  authored and

  zentol

  committed
  c6997c9

• [FLINK-20651] Fix formatting that doesn't work with google-java-format/checkstyle

  

  aljoscha

  authored and

  zentol

  committed
  ce427e7

Commits on Nov 26, 2020

• Update version to 1.13-SNAPSHOT

  dianfu

  committed
  b2231ee

Commits on Nov 7, 2020

• [FLINK-19741] Let timer service skip reading raw keyed state if it isn't the writer

  Show description for c151abc
  tzulitai

  committed
  c151abc

Commits on Nov 6, 2020

• [FLINK-19533][checkpoint] Add TaskStateAssignment to capture all intermediate state of StateAssignmentOperation.

  Show description for d6b8534
  

  Arvid Heise

  authored and

  AHeise

  committed
  d6b8534

• [FLINK-19533][checkpoint] Introduce builder for OperatorSubtaskState.

  Show description for 32a2ded
  

  Arvid Heise

  authored and

  AHeise

  committed
  32a2ded

• [hotfix][tests] Chain unexpected exception to assertion error.

  

  Arvid Heise

  authored and

  AHeise

  committed
  24c6eab

Commits on Nov 5, 2020

• [FLINK-17295] Make ExecutionAttemptID random again (apache#13929)

  rmetzger

  authored
  513c806

Commits on Nov 2, 2020

• [FLINK-19915][cep] fix comments bug of cep test.

  

  liuyongvs

  authored and

  dawidwys

  committed
  f84acf6

Commits on Oct 29, 2020

• [FLINK-19680][checkpointing] Provide alignment timeout checkpoint option

  pnowojski

  committed
  fda1679

Commits on Oct 27, 2020

• [FLINK-13095][state-processor-api] Introduce window bootstrap writer for writing window operator state

  Show description for eeb0ec5
  sjwiesman

  committed
  eeb0ec5

• [FLINK-13095][state-processor-api] Expose trigger state in window reader

  sjwiesman

  committed
  3a08d33

• [hotfix][testing] Add common test utility for collecting all elements from a stream

  sjwiesman

  committed
  19884a8

• [FLINK-19464][runtime] Rename CheckpointStorage interface to CheckpointStorageAccess

  Show description for d2b86a1
  sjwiesman

  committed
  d2b86a1

Pagination

PreviousNext