Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 5, 2020

• [FLINK-19958] Add IOException to all I/O related Sink API signatures

  

  guoweiM

  authored and

  aljoscha

  committed
  79b1632

  Copy full SHA for 79b1632

Commits on Nov 4, 2020

• [FLINK-19662][runtime][core] Moved assembleDynamicConfigsStr into ConfigurationUtils to be used by both TaskExecutorProcessUtils and JobManagerProcessUtils.

  Show description for 5abd3bf
  

  XComp

  authored and

  tillrohrmann

  committed
  5abd3bf

  Copy full SHA for 5abd3bf

• [FLINK-19952][core] Replace deprecated ConfigOption builder in SecurityOptions.

  Show description for 7f5dd53
  

  liuyongvs

  authored and

  dawidwys

  committed
  7f5dd53

  Copy full SHA for 7f5dd53

Commits on Nov 3, 2020

• [FLINK-19602][network] Introduce new config options to enable sort-merge based blocking shuffle

  Show description for 11ba5b3
  

  kevin.cyj

  authored and

  StephanEwen

  committed
  11ba5b3

  Copy full SHA for 11ba5b3

• [FLINK-19600][network] Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle

  Show description for 1076da9
  

  kevin.cyj

  authored and

  StephanEwen

  committed
  1076da9

  Copy full SHA for 1076da9

• [FLINK-19760] Sink API: Make the GlobalCommitter not extend the Committer

  Show description for 926e1bc
  

  guoweiM

  authored and

  kl0u

  committed
  926e1bc

  Copy full SHA for 926e1bc

• [FLINK-19833] Rename Sink API Writer interface to SinkWriter

  Show description for 34d0a9c
  

  guoweiM

  authored and

  kl0u

  committed
  34d0a9c

  Copy full SHA for 34d0a9c

• [hotfix][core] Add Configuration.fromMap

  

  twalthr

  authored and

  wuchong

  committed
  4fa58f3

  Copy full SHA for 4fa58f3

Commits on Nov 2, 2020

• [FLINK-19736] Add SinkTransformation along with Translator

  Show description for 34d143f
  

  guoweiM

  authored and

  aljoscha

  committed
  34d143f

  Copy full SHA for 34d143f

Commits on Oct 30, 2020

• [FLINK-18363] Add user classloader to context in DeSerializationSchema

  Show description for da67eeb
  dawidwys

  committed
  da67eeb

  Copy full SHA for da67eeb

Commits on Oct 29, 2020

• [FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy

  Show description for 60b6401
  aljoscha

  committed
  60b6401

  Copy full SHA for 60b6401

• [FLINK-19836] Add SerializableSupplier in flink-core

  Show description for 91583c7
  aljoscha

  committed
  91583c7

  Copy full SHA for 91583c7

• [hotfix][doc] Correct FSDataInputStream in FileSystem document

  Show description for 234b814
  zhuxiaoshang

  authored
  234b814

  Copy full SHA for 234b814

Commits on Oct 28, 2020

• [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext. (apache#12647)

  pyscala

  authored
  fc41f03

  Copy full SHA for fc41f03

Commits on Oct 27, 2020

• [FLINK-19793][connector-kafka] Harden KafkaTableITCase.testKafkaSourceSinkWithMetadata

  Show description for b60c1f9
  twalthr

  committed
  b60c1f9

  Copy full SHA for b60c1f9

Commits on Oct 24, 2020

• [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution entirely

  Show description for 8fd36be
  

  kylemeow

  authored and

  tillrohrmann

  committed
  8fd36be

  Copy full SHA for 8fd36be

Commits on Oct 23, 2020

• [hotfix][table-common] Add a new Row.deepEquals for all conversion classes

  twalthr

  committed
  a59fa70

  Copy full SHA for a59fa70

Commits on Oct 22, 2020

• [FLINK-18971][security] Introduce security.kerberos.krb5-conf.path option

  

  KarmaGYZ

  authored and

  xintongsong

  committed
  cbd1fa0

  Copy full SHA for cbd1fa0

Commits on Oct 16, 2020

• [FLINK-19583] Expose the execution.runtime-mode to users

  Show description for b3fd487
  kl0u

  committed
  b3fd487

  Copy full SHA for b3fd487

• [FLINK-19640] Enable sorting inputs for batch

  Show description for 2ff3b77
  dawidwys

  committed
  2ff3b77

  Copy full SHA for 2ff3b77

Commits on Oct 15, 2020

• [hotfix] Disable KryoSerializerConcurrencyCheckInactiveITCase if logging level is DEBUG

  rmetzger

  committed
  c6bf700

  Copy full SHA for c6bf700

Commits on Oct 14, 2020

• [FLINK-16620] - Add attempt information in TaskInfo

  

  Jiayi-Liao

  authored and

  pnowojski

  committed
  eb1297b

  Copy full SHA for eb1297b

Commits on Oct 13, 2020

• [FLINK-18662][task] Calculate alignmentDurationNanos for unaligned checkpoints and CheckpointBarrierTracker

  Show description for fc5f49e
  pnowojski

  committed
  fc5f49e

  Copy full SHA for fc5f49e

• [FLINK-19512] Introduce the new sink API

  Show description for 28c1646
  

  guoweiM

  authored and

  kl0u

  committed
  28c1646

  Copy full SHA for 28c1646

• [FLINK-19180][runtime] Decalare managed memory use cases for transformations with state backends.

  xintongsong

  committed
  074fb61

  Copy full SHA for 074fb61

• [FLINK-19180][core] Rename ManagedMemoryUseCase.ROCKSDB to STATE_BACKEND

  Show description for 9897a83
  xintongsong

  committed
  9897a83

  Copy full SHA for 9897a83

• [hotfix][core] Annotate ManagedMemoryUseCase as Internal.

  xintongsong

  committed
  7ad3993

  Copy full SHA for 7ad3993

Commits on Oct 12, 2020

• [hotfix] Make Transformation.getTransitivePredecessors() return a list

  kl0u

  committed
  c3fedf3

  Copy full SHA for c3fedf3

• [FLINK-19485] Add the Transformation.getInputs() method

  Show description for bed3352
  kl0u

  committed
  bed3352

  Copy full SHA for bed3352

• [FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API

  Show description for 162c072
  StephanEwen

  committed
  162c072

  Copy full SHA for 162c072

Commits on Oct 6, 2020

• [FLINK-19472] Add an option to enable sorted inputs for operators

  Show description for cf40acd
  dawidwys

  committed
  cf40acd

  Copy full SHA for cf40acd

• [FLINK-19472] Implement a one input sorting DataInput

  Show description for 63bdbc9
  dawidwys

  committed
  63bdbc9

  Copy full SHA for 63bdbc9

• [hotfix] Alllow declaring which ordering direction should be tested

  Show description for b8e8cd9
  dawidwys

  committed
  b8e8cd9

  Copy full SHA for b8e8cd9

Commits on Oct 2, 2020

• [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

  Show description for 7a50e3e
  

  kezhuw

  authored and

  tillrohrmann

  committed
  7a50e3e

  Copy full SHA for 7a50e3e

• [FLINK-19457][core] Add a number sequence generating source for the FLIP-27 source API.

  Show description for bd5d461
  StephanEwen

  committed
  bd5d461

  Copy full SHA for bd5d461

Pagination

Previous

Next