Commits

Branch selector

 master

User selector

Sxnan

Datepicker

All time

Commit History

Commits on Aug 9, 2022

• [FLINK-28857][docs] Add Document for DataStream Cache API

  Show description for 21712c9
  

  Sxnan

  authored and

  gaoyunhaii

  committed
  21712c9

  Copy full SHA for 21712c9

• [FLINK-28860][tests] Disable CacheITCase temporarily

  Show description for 208f08b
  

  Sxnan

  authored and

  gaoyunhaii

  committed
  208f08b

  Copy full SHA for 208f08b

Commits on Aug 6, 2022

• [FLINK-27524][datastream] Introduce cache API to DataStream

  Show description for cf1a29d
  

  Sxnan

  authored and

  gaoyunhaii

  committed
  cf1a29d

  Copy full SHA for cf1a29d

Commits on Jun 20, 2022

• [FLINK-27523][runtime] Runtime supports producing and consuming cached intermediate results

  Show description for a9f2e20
  

  Sxnan

  authored and

  gaoyunhaii

  committed
  a9f2e20

  Copy full SHA for a9f2e20

Commits on Feb 3, 2022

• [FLINK-25685][rest] RestClusterClient supports uploading local file path with scheme

  Sxnan

  authored
  46bb038

  Copy full SHA for 46bb038

Commits on Nov 12, 2020

• [FLINK-19253][connector/common][test] Add test case to test when all split fetchers are closed with leftover element in queue

  

  Sxnan

  authored and

  becketqin

  committed
  8d7e9e6

  Copy full SHA for 8d7e9e6

• [FLINK-19253][connector/common] Synchronize setting the isIdle flag in SourceReaderBase.

  

  Sxnan

  authored and

  becketqin

  committed
  e131a47

  Copy full SHA for e131a47

Commits on Nov 4, 2020

• [hotfix][build] Replace hard-coded project version

  Sxnan

  authored
  c4a74be

  Copy full SHA for c4a74be

Commits on Oct 29, 2020

• [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator

  Show description for fada6fb
  

  Sxnan

  authored and

  dawidwys

  committed
  fada6fb

  Copy full SHA for fada6fb

Commits on Oct 18, 2020

• [FLINK-19669][coordination] PipelinedRegionSchedulingStrategy#init ResultPartitionType blocking check use isBlocking method

  

  Sxnan

  authored and

  zhuzhurk

  committed
  8133c06

  Copy full SHA for 8133c06

Commits on Mar 27, 2020

• [FLINK-16128][docs-zh] Translate "Google Cloud PubSub" page into Chinese

  Show description for 66c2913
  Sxnan

  authored
  66c2913

  Copy full SHA for 66c2913

• [FLINK-16127][docs-zh] Translate "Fault Tolerance Guarantees" page of connectors into Chinese

  Show description for 7feba94
  Sxnan

  authored
  7feba94

  Copy full SHA for 7feba94