Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on May 25, 2022

• [FLINK-27251][checkpoint] Refactor the close() and cancel() of SubtaskCheckpointCoordinator

  

  1996fanrui

  authored and

  pnowojski

  committed
  e68d679

  Copy full SHA for e68d679

• [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

  

  1996fanrui

  authored and

  pnowojski

  committed
  dd8f4e2

  Copy full SHA for dd8f4e2

• [FLINK-27251][checkpoint] Refactor the barrier alignment timer and default priority sequence number

  

  1996fanrui

  authored and

  pnowojski

  committed
  10b7afa

  Copy full SHA for 10b7afa

Commits on May 20, 2022

• [FLINK-17295][runtime] Refine tests to ensure the consistency of jobVertexId, subtaskIndex, attemptNumber and executionAttemptId

  zhuzhurk

  committed
  014e8e0

  Copy full SHA for 014e8e0

• [FLINK-17295][runtime] Remove unnecessary fields from TaskDeploymentDescriptor

  zhuzhurk

  committed
  bccecc2

  Copy full SHA for bccecc2

• [FLINK-17295][runtime] Rework MetricGroup methods to ensure param consistency

  zhuzhurk

  committed
  13cb93b

  Copy full SHA for 13cb93b

Commits on May 19, 2022

• [FLINK-27682][tests] Migrate ComparatorTestBase to JUnit5

  

  snuyanzin

  authored and

  zentol

  committed
  df30751

  Copy full SHA for df30751

Commits on May 17, 2022

• [FLINK-27662][tests] Migrate TypeInformationTestBase to JUnit5

  

  snuyanzin

  authored and

  zentol

  committed
  62d64eb

  Copy full SHA for 62d64eb

• [FLINK-27501][tests] Migrate SerializerTestBase to JUnit5

  zentol

  authored
  bf38c12

  Copy full SHA for bf38c12

Commits on May 12, 2022

• [FLINK-25470][changelog] Expose more metrics of ChangelogStateBackend and materialization

  

  masteryhx

  authored and

  rkhachatryan

  committed
  7d2ca7b

  Copy full SHA for 7d2ca7b

Commits on May 8, 2022

• [release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create snapshots

  gaoyunhaii

  committed
  7d5a813

  Copy full SHA for 7d5a813

• [release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots

  gaoyunhaii

  committed
  da9e6be

  Copy full SHA for da9e6be

Commits on May 2, 2022

• [FLINK-27460][runtime] Remove unused notifyPartitionDataAvailable process

  

  zhuzhurk

  authored and

  zentol

  committed
  05676c4

  Copy full SHA for 05676c4

Commits on Apr 28, 2022

• [FLINK-25511][state] Introduce StreamStateHandle ID

  Show description for 5b58ef6
  rkhachatryan

  committed
  5b58ef6

  Copy full SHA for 5b58ef6

Commits on Apr 26, 2022

• [FLINK-24721][build] Remove unnecessary relativePath to parent

  zentol

  committed
  fcab8a8

  Copy full SHA for fcab8a8

Commits on Apr 25, 2022

• [FLINK-23252][changelog] Support recovery from checkpoint after disabling changelog backend

  

  masteryhx

  authored and

  Myasuka

  committed
  7b48eae

  Copy full SHA for 7b48eae

Commits on Apr 11, 2022

• [FLINK-26864] Fix performance regression from mailbox latency measurement

  

  Sebastian Mattheis

  authored and

  pnowojski

  committed
  fecd0fb

  Copy full SHA for fecd0fb

Commits on Apr 8, 2022

• [FLINK-26995][tests] Mark several tests as unit tests

  zentol

  committed
  b1a1874

  Copy full SHA for b1a1874

• [FLINK-26995][build] Enable fork-reuse for all unit tests

  zentol

  committed
  fee8217

  Copy full SHA for fee8217

• [FLINK-26995][tests] Migrate tests to ITCases

  Show description for d7812b4
  zentol

  committed
  d7812b4

  Copy full SHA for d7812b4

• [FLINK-26995][tests] Fix tests failing with fork-reuse enabled

  Show description for ebed442
  zentol

  committed
  ebed442

  Copy full SHA for ebed442

• [FLINK-27045][tests] Remove shared executor

  zentol

  committed
  f1867d3

  Copy full SHA for f1867d3

Commits on Apr 5, 2022

• [FLINK-27042][metrics] Fix instability of StreamTaskTest#testMailboxMetricsScheduling

  Show description for 450a142
  

  Sebastian Mattheis

  authored
  450a142

  Copy full SHA for 450a142

Commits on Apr 1, 2022

• [FLINK-23399][state] Add a benchmark for rescaling

  

  fredia

  authored and

  Myasuka

  committed
  562b182

  Copy full SHA for 562b182

Commits on Mar 29, 2022

• [FLINK-25256][streaming] Clarify the contract of ExternallyInducedSource(Reader).

  

  Arvid Heise

  authored and

  AHeise

  committed
  a4d194e

  Copy full SHA for a4d194e

• [FLINK-25256][streaming] Externally induced sources replay barriers received over RPC instead of inventing them out of thin air.

  Show description for 8a73e94
  

  Arvid Heise

  authored and

  AHeise

  committed
  8a73e94

  Copy full SHA for 8a73e94

• [refactor][streaming] Migrate Source(Operator)StreamTaskTest to JUnit5 and assertj

  

  Arvid Heise

  authored and

  AHeise

  committed
  7aefdf2

  Copy full SHA for 7aefdf2

• [FLINK-26616][tests] Remove deadlines from CommonTestUtils

  zentol

  authored
  7d85b27

  Copy full SHA for 7d85b27

Commits on Mar 28, 2022

• [FLINK-26708] TimestampsAndWatermarksOperator should not propagate WatermarkStatus

  dawidwys

  committed
  d87808f

  Copy full SHA for d87808f

Commits on Mar 22, 2022

• [hotfix][doc] fix typo in java doc.

  

  JingGe

  authored and

  pnowojski

  committed
  7acfa5e

  Copy full SHA for 7acfa5e

• [hotfix][Streaming] fix wrong local variable name in MailboxProcessor and fix typo in java doc.

  

  JingGe

  authored and

  pnowojski

  committed
  d9fab76

  Copy full SHA for d9fab76

Commits on Mar 21, 2022

• [FLINK-26279] Add mailbox metrics

  Show description for 32c2ca7
  

  Sebastian Mattheis

  authored and

  pnowojski

  committed
  32c2ca7

  Copy full SHA for 32c2ca7

• [FLINK-26334][datastream] Modified getWindowStartWithOffset method in org.apache.flink.table.runtime.operators.window.TimeWindow and org.apache.flink.streaming.api.windowing.windows.TimeWindow . Ad…

  Show description for c1bbbe6
  

  3 peopleauthored and

  fapaul

  committed
  c1bbbe6

  Copy full SHA for c1bbbe6

• [FLINK-26151]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

  Show description for 1fa91ba
  

  lovewin99

  authored and

  gaoyunhaii

  committed
  1fa91ba

  Copy full SHA for 1fa91ba

Commits on Mar 18, 2022

• [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

  pnowojski

  committed
  e9028ca

  Copy full SHA for e9028ca

Pagination

Previous

Next