Commits

Branch selector

 master

User selector

rkhachatryan

Datepicker

All time

Commit History

Commits on Jul 16, 2020

• [FLINK-18163][task] Add RecordWriter.volatileFlusherException

  

  rkhachatryan

  authored and

  pnowojski

  committed
  9fa0a99

Commits on Jul 3, 2020

• [FLINK-15416][network] Remove ignored PartitionRequestClientFactoryTest.testResourceReleaseAfterInterruptedConnect

  Show description for 9ddfb95
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  9ddfb95

Commits on Jul 2, 2020

• [FLINK-18336][checkpointing] Ignore failures of past checkpoints in CheckpointFailureManager

  Show description for 06af98a
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  06af98a

• [hotfix][checkpointing] Extract CheckpointFailureManager.handleCheckpointException method

  

  rkhachatryan

  authored and

  zhijiangW

  committed
  c0be7a4

Commits on Jun 17, 2020

• [FLINK-18290][checkpointing] Don't System.exit on CheckpointCoordinator failure if it is shut down

  

  rkhachatryan

  authored and

  pnowojski

  committed
  f85dfbb

Commits on Jun 16, 2020

• [FLINK-17824][tests] Fix resume_savepoint e2e test by slowing down the Source (apache#12671)

  Show description for a9d3074
  rkhachatryan

  authored
  a9d3074

Commits on Jun 10, 2020

• [FLINK-17869][task][checkpointing] Abort writing of channel state by RPC

  Show description for b2d1c2d
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  b2d1c2d

• [FLINK-17869][tests] Unignore UnalignedCheckpointITCase

  

  rkhachatryan

  authored and

  zhijiangW

  committed
  26762bd

• [FLINK-17869][task][checkpointing] Ignore out of order checkpoints in SubtaskCheckpointCoordinator

  Show description for 64ff676
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  64ff676

• [FLINK-17869][task][checkpointing] Increase ChannelStateWriterImpl.DEFAULT_MAX_CHECKPOINTS

  Show description for 2b51cda
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  2b51cda

• [FLINK-17869][task][checkpointing] Abort channel state write if checkpoint is subsumed

  Show description for 91df1a5
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  91df1a5

• [FLINK-17869][task][checkpointing] Revert "[FLINK-17218][checkpointing] Ensuring that ChannelStateWriter aborts previous checkpoints before a new checkpoint is started."

  Show description for 73afe2b
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  73afe2b

• [FLINK-17869][hotfix] Don't pass ChannelStateWrite Future to AsyncCheckpointRunnable

  Show description for 82a13db
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  82a13db

• [FLINK-17869][hotfix] Add taskName to ChannelStateWriter log messages

  

  rkhachatryan

  authored and

  zhijiangW

  committed
  1cb9d54

Commits on Jun 9, 2020

• [FLINK-18136][checkpointing] Don't start channel state writer for savepoint

  Show description for 6dc624d
  rkhachatryan

  authored
  6dc624d

Commits on Jun 8, 2020

• [FLINK-18050][task][checkpointing] Simplify ChannelStateCheckpointWriter interface

  

  rkhachatryan

  authored and

  zhijiangW

  committed
  f2dd4b8

• [FLINK-18050][task][checkpointing] Use CloseableIterator to write ResultSubpartition state

  Show description for ed7b0b1
  

  rkhachatryan

  authored and

  zhijiangW

  committed
  ed7b0b1

Commits on Jun 2, 2020

• [FLINK-16057][task] Optimize TaskMailbox state retrieval

  Show description for 31d661d
  

  rkhachatryan

  authored and

  pnowojski

  committed
  31d661d

• [FLINK-16057][task] Optimize ContinuousFileReaderOperator

  Show description for 1a69cb9
  

  rkhachatryan

  authored and

  pnowojski

  committed
  1a69cb9

• [FLINK-16057][hotfix][task] Remove MailboxProcessor.mainMailboxExecutor field

  Show description for 78b4e3d
  

  rkhachatryan

  authored and

  pnowojski

  committed
  78b4e3d

Commits on May 28, 2020

• [FLINK-17986] Fix check in FsCheckpointStateOutputStream.write

  

  rkhachatryan

  authored and

  pnowojski

  committed
  0179156

• [FLINK-17988][checkpointing] Discard only unique channel state delegates

  Show description for 435bf23
  

  rkhachatryan

  authored and

  pnowojski

  committed
  435bf23

• [FLINK-17928][checkpointing] Fix ChannelStateHandle size

  Show description for f89c606
  

  rkhachatryan

  authored and

  pnowojski

  committed
  f89c606

• [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

  Show description for 1b824d5
  

  rkhachatryan

  authored and

  pnowojski

  committed
  1b824d5

• [FLINK-17861][task][checkpointing] Merge channel state serializer and deserializer

  Show description for 8f0a41c
  

  rkhachatryan

  authored and

  pnowojski

  committed
  8f0a41c

• [FLINK-17861][tests][hotfix] Fix ChannelStateCheckpointWriterTest.testRecordingOffsets

  Show description for 54ea4d3
  

  rkhachatryan

  authored and

  pnowojski

  committed
  54ea4d3

Commits on May 27, 2020

• [FLINK-17820][checkpointing] Respect fileSizeThreshold in FsCheckpointStateOutputStream.flush()

  Show description for 8b4fe87
  rkhachatryan

  authored
  8b4fe87

Commits on May 25, 2020

• [FLINK-17905][docs] Fix JDBC docs to remove the duplicate licence and markup

  Show description for a91db83
  rkhachatryan

  authored
  a91db83

Commits on May 19, 2020

• [FLINK-17547][task] Implement getUnconsumedSegment for spilled buffers

  

  rkhachatryan

  authored and

  pnowojski

  committed
  2aacb62

• [FLINK-17547][task] Use RefCountedFile in SpanningWrapper (todo: merge

  Show description for 5415574
  

  rkhachatryan

  authored and

  pnowojski

  committed
  5415574

• [FLINK-17547][task][hotfix] Move RefCountedFile to flink-core

  Show description for 2fcc1fc
  

  rkhachatryan

  authored and

  pnowojski

  committed
  2fcc1fc

• [FLINK-17547][task][hotfix] Extract RefCountedFileWithStream from RefCountedFile

  Show description for 179de29
  

  rkhachatryan

  authored and

  pnowojski

  committed
  179de29

• [FLINK-17547][task] Use iterator for unconsumed buffers.

  Show description for 37f441a
  

  rkhachatryan

  authored and

  pnowojski

  committed
  37f441a

• [FLINK-17547][task][hotfix] Extract methods from RecordsDeserializer

  

  rkhachatryan

  authored and

  pnowojski

  committed
  824100e

• [FLINK-17547][task][hotfix] Fix compiler warnings in NonSpanningWrapper

  

  rkhachatryan

  authored and

  pnowojski

  committed
  67d3eae

Pagination

PreviousNext