Commits

Branch selector

 master

User selector

curcur

Datepicker

All time

Commit History

Commits on Oct 25, 2021

• [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints (apache#16606)

  Show description for 446bc70
  curcur

  authored
  446bc70

Commits on Sep 9, 2021

• [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (apache#17173)

  curcur

  authored
  a1a645a

Commits on Aug 13, 2021

• [FLINK-23473][runtime] Do not create transaction in TwoPhaseCommitSinkFunction after finish (apache#16768)

  curcur

  authored
  b00d158

Commits on Jul 22, 2021

• [FLINK-23204] Provide StateBackends access to MailboxExecutor (apache#16531)

  Show description for 6709573
  curcur

  authored
  6709573

Commits on Jul 6, 2021

• [FLINK-21448] Randomize ITTests

  

  curcur

  authored and

  rkhachatryan

  committed
  55dfea9

Commits on May 12, 2021

• [FLINK-21469][runtime] Implement advanceToEndOfEventTime for MultipleInputStreamTask

  Show description for 62f91de
  

  curcur

  authored and

  dawidwys

  committed
  62f91de

Commits on Apr 27, 2021

• [FLINK-22289] Update JDBC XA sink docs

  

  curcur

  authored and

  rkhachatryan

  committed
  334dae6

Commits on Apr 14, 2021

• [FLINK-21839][docs] Document stop-with-savepoint behavior more explicitly

  Show description for 81118c0
  

  curcur

  authored and

  dawidwys

  committed
  81118c0

• [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

  

  curcur

  authored and

  rkhachatryan

  committed
  5ac1073

Commits on Apr 9, 2021

• [hotfix] Remove unnessary rollbackPreparedFromCheckpoint from JdbcXaSinkFunction.snapshot

  

  curcur

  authored and

  rkhachatryan

  committed
  7e9de61

• [hotfix] Fix the release version for JdbcXaSinkFunction

  

  curcur

  authored and

  rkhachatryan

  committed
  7eedc54

Commits on Mar 21, 2021

• [hotfix][state backend] Put the delegating log to ChangelogStateBackend constructor

  

  curcur

  authored and

  rkhachatryan

  committed
  de9cf86

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 Jan 25, 2021

• [FLINK-21018] Update checkpoint related documentation for UI

  

  curcur

  authored and

  pnowojski

  committed
  fdba6ea

Commits on Jan 12, 2021

• [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an appropriate package

  

  curcur

  authored and

  pnowojski

  committed
  92b2196

Commits on Jan 8, 2021

• [FLINK-20488][runtime][checkpoint] Show checkpoint type in the Web-UI (AC/UC) for each subtask

  

  curcur

  authored and

  pnowojski

  committed
  0abbee9

Commits on Jan 4, 2021

• [docs/javadoc][hotfix] Explicitly Document task cancellation timeout does not apply to task failure

  

  curcur

  authored and

  pnowojski

  committed
  201803c

Commits on Nov 8, 2020

• [FLINK-19693] ITCases for Approximate Local Recovery

  

  curcur

  authored and

  tillrohrmann

  committed
  0b3f15e

• [FLINK-19693] Introduce a flag to enable approximate failover

  

  curcur

  authored and

  tillrohrmann

  committed
  72f8505

• [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery

  Show description for 0ea6d3b
  

  curcur

  authored and

  tillrohrmann

  committed
  0ea6d3b

Commits on Nov 5, 2020

• [hotfix] Do not emit EndOfChannelRecoveryEvent for Approximate Local Recovery

  

  curcur

  authored and

  AHeise

  committed
  f3964a9

Commits on Nov 2, 2020

• [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

  

  curcur

  authored and

  AHeise

  committed
  1e4b380

Commits on Oct 27, 2020

• [hotfix][runtime] Rename XXXSubPartitionBufferBuilderXXX to XXXUnicastBufferBuilderXXX

  

  curcur

  authored and

  pnowojski

  committed
  698f962

• [FLINK-19547][Runtime] Update BufferConsumer with BufferConsumerWithPartialRecordLength in PipelinedSubpartition.java

  Show description for 28d2766
  

  curcur

  authored and

  pnowojski

  committed
  28d2766

• [FLINK-19547][Runtime] Add the partialRecordLength when creating a BufferConsumer

  Show description for 11f9837
  

  curcur

  authored and

  pnowojski

  committed
  11f9837

Commits on Aug 24, 2020

• [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

  

  curcur

  authored and

  pnowojski

  committed
  3b1b77e

Commits on Jul 8, 2020

• [FLINK-15414] catch the right KafkaException for binding errors

  Show description for c237870
  

  curcur

  authored and

  dawidwys

  committed
  c237870

Commits on Jun 22, 2020

• [FLINK-17769] Wrong order of log events on a task failure

  Show description for ec4d155
  

  curcur

  authored and

  pnowojski

  committed
  ec4d155

Commits on May 27, 2020

• [FLINK-17351] Increase continuousFailureCounter in CheckpointFailureManager for CHECKPOINT_EXPIRED

  Show description for 3ec768a
  

  curcur

  authored and

  pnowojski

  committed
  3ec768a

Commits on May 18, 2020

• [FLINK-15670] Kafka Shuffle Test Case + add log4j2 file

  Show description for 1cd696d
  

  curcur

  authored and

  pnowojski

  committed
  1cd696d

• [FLINK-15670][connector] Kafka Shuffle API Part

  Show description for 83a8d57
  

  curcur

  authored and

  pnowojski

  committed
  83a8d57

• [FLINK-15670][connector] Adds the consumer for KafkaShuffle.

  Show description for 4b866fb
  

  curcur

  authored and

  pnowojski

  committed
  4b866fb

• [FLINK-15670][connector] Adds the producer for KafkaShuffle.

  Show description for 50a3b0f
  

  curcur

  authored and

  pnowojski

  committed
  50a3b0f

• [FLINK-15670][core] Provide a utility function to flatten a recursive Properties to a first level property HashTable

  Show description for e72e270
  

  curcur

  authored and

  pnowojski

  committed
  e72e270

• [FLINK-15670] Kafka Shuffle Test Case + add log4j2 file

  Show description for 78b7c71
  

  curcur

  authored and

  pnowojski

  committed
  78b7c71

Pagination

PreviousNext