Commits

Branch selector

 master

User selector

curcur

Datepicker

All time

Commit History

Commits on May 12, 2021

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

  

  curcur

  authored and

  dawidwys

  committedMay 12, 2021
  62f91de

Commits on Apr 27, 2021

• [FLINK-22289] Update JDBC XA sink docs

  

  curcur

  authored and

  rkhachatryan

  committedApr 27, 2021
  334dae6

Commits on Apr 14, 2021

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

  

  curcur

  authored and

  dawidwys

  committedApr 14, 2021
  81118c0

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

  

  curcur

  authored and

  rkhachatryan

  committedApr 14, 2021
  5ac1073

Commits on Apr 9, 2021

• [hotfix] Remove unnessary rollbackPreparedFromCheckpoint from JdbcXaSinkFunction.snapshot

  

  curcur

  authored and

  rkhachatryan

  committedApr 9, 2021
  7e9de61

• [hotfix] Fix the release version for JdbcXaSinkFunction

  

  curcur

  authored and

  rkhachatryan

  committedApr 9, 2021
  7eedc54

Commits on Mar 21, 2021

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

  

  curcur

  authored and

  rkhachatryan

  committedMar 21, 2021
  de9cf86

Commits on Mar 15, 2021

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

  

  curcur

  authored and

  rkhachatryan

  committedMar 15, 2021
  d72fa2e

Commits on Jan 25, 2021

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

  

  curcur

  authored and

  pnowojski

  committedJan 25, 2021
  fdba6ea

Commits on Jan 12, 2021

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

  

  curcur

  authored and

  pnowojski

  committedJan 12, 2021
  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

  committedJan 8, 2021
  0abbee9

Commits on Jan 4, 2021

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

  

  curcur

  authored and

  pnowojski

  committedJan 4, 2021
  201803c

Commits on Nov 8, 2020

• [FLINK-19693] ITCases for Approximate Local Recovery

  

  curcur

  authored and

  tillrohrmann

  committedNov 8, 2020
  0b3f15e

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

  

  curcur

  authored and

  tillrohrmann

  committedNov 8, 2020
  72f8505

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

  

  curcur

  authored and

  tillrohrmann

  committedNov 8, 2020
  0ea6d3b

Commits on Nov 5, 2020

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

  

  curcur

  authored and

  AHeise

  committedNov 5, 2020
  f3964a9

Commits on Nov 2, 2020

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

  

  curcur

  authored and

  AHeise

  committedNov 2, 2020
  1e4b380

Commits on Oct 27, 2020

• [hotfix][runtime] Rename XXXSubPartitionBufferBuilderXXX to XXXUnicastBufferBuilderXXX

  

  curcur

  authored and

  pnowojski

  committedOct 27, 2020
  698f962

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

  

  curcur

  authored and

  pnowojski

  committedOct 27, 2020
  28d2766

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

  

  curcur

  authored and

  pnowojski

  committedOct 27, 2020
  11f9837

Commits on Aug 24, 2020

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

  

  curcur

  authored and

  pnowojski

  committedAug 24, 2020
  3b1b77e

Commits on Jul 8, 2020

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

  

  curcur

  authored and

  dawidwys

  committedJul 8, 2020
  c237870

Commits on Jun 22, 2020

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

  

  curcur

  authored and

  pnowojski

  committedJun 22, 2020
  ec4d155

Commits on May 27, 2020

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

  

  curcur

  authored and

  pnowojski

  committedMay 27, 2020
  3ec768a

Commits on May 18, 2020

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  1cd696d

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  83a8d57

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  4b866fb

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  50a3b0f

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  e72e270

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  78b7c71

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  ff1695d

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  9fd02fe

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  e929c3c

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

  

  curcur

  authored and

  pnowojski

  committedMay 18, 2020
  03f5d54

Commits on Feb 10, 2020

• [hotfix][docs] Fix Readme Description for the State Machine Example (apache#11046)

  curcur

  committedFeb 10, 2020
  c8bdb67

Pagination

PreviousNext