Commits

Commits on Apr 18, 2021

Update version to 1.14-SNAPSHOT
guoweiM
committedApr 18, 2021

Commits on Nov 30, 2020

[FLINK-20337] Let StatefulSinkWriterOperator load StreamingFileSink's state

guoweiM
authored and
aljoscha
committedNov 30, 2020

Commits on Nov 8, 2020

[FLINK-20031] Keep the UID of SinkWriter same as the SinkTransformation

guoweiM
authored and
aljoscha
committedNov 8, 2020

Commits on Nov 7, 2020

[FLINK-19963] Allow SinkWriter use processing timer service.

guoweiM
authored and
kl0u
committedNov 7, 2020

Commits on Nov 5, 2020

[FLINK-20007] SinkTransformationTranslator connect SinkWriter to correct upstream node

guoweiM
authored and
kl0u
committedNov 5, 2020
[FLINK-19958] Add IOException to all I/O related Sink API signatures

guoweiM
authored and
aljoscha
committedNov 5, 2020

Commits on Nov 4, 2020

[FLINK-19936] Stabilize the SinkITCase

guoweiM
authored and
kl0u
committedNov 4, 2020

Commits on Nov 3, 2020

[FLINK-19841] Sink API: Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

guoweiM
authored and
kl0u
committedNov 3, 2020
[FLINK-19760] Sink API: Make the GlobalCommitter not extend the Committer

guoweiM
authored and
kl0u
committedNov 3, 2020
[FLINK-19833] Rename Sink API Writer interface to SinkWriter

guoweiM
authored and
kl0u
committedNov 3, 2020

Commits on Nov 2, 2020

[FLINK-19736] Add SinkTransformation along with Translator

guoweiM
authored and
aljoscha
committedNov 2, 2020

Commits on Oct 28, 2020

[FLINK-19834] Make the TestSink reusable in all sink related tests

guoweiM
authored and
aljoscha
committedOct 28, 2020

Commits on Oct 24, 2020

[FLINK-19696] Add committer operator for BATCH mode for the new sink API

guoweiM
authored and
kl0u
committedOct 24, 2020
[FLINK-19586] Add global committer operator for STREAMING mode for new Sink API

guoweiM
authored and
kl0u
committedOct 24, 2020
[FLINK-19586] Add committer operators for STREAMING mode for new Sink API

guoweiM
authored and
kl0u
committedOct 24, 2020
[FLINK-19586] Extract 'TestSink' from 'WriterOperatorTestBase'

guoweiM
authored and
kl0u
committedOct 24, 2020

Commits on Oct 15, 2020

[FLINK-19531] Add runtime writer operators for new Sink API

guoweiM
authored and
aljoscha
committedOct 15, 2020

Commits on Oct 13, 2020

[FLINK-19512] Introduce the new sink API

guoweiM
authored and
kl0u
committedOct 13, 2020
[FLINK-19511] Rename the 'SinkTransformation' to 'LegacySinkTransformation'

guoweiM
authored and
kl0u
committedOct 13, 2020

Commits on Sep 23, 2020

[FLINK-11779] Update documentation based on bin/flink output

guoweiM
authored and
aljoscha
committedSep 23, 2020
[FLINK-11779] Update documentation about ‘RestOptions’

guoweiM
authored and
aljoscha
committedSep 23, 2020
[FLINK-11779] Update the description of the CLI -m parameter

guoweiM
authored and
aljoscha
committedSep 23, 2020

Commits on Sep 8, 2020

[FLINK-17637][connector] fix the unstable HadoopS3RecoverableWriterITCase#testCleanupRecoverableState

guoweiM
authored and
aljoscha
committedSep 8, 2020

Commits on Jun 24, 2020

[FLINK-17639] Document which FileSystems are supported by the StreamingFileSink

guoweiM
authored and
kl0u
committedJun 24, 2020

Commits on May 18, 2020

[FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

guoweiM
authored and
aljoscha
committedMay 18, 2020
[FLINK-17593][Connectors/FileSystem] Turn BucketStateSerializerTest into an upgrade test

guoweiM
authored and
aljoscha
committedMay 18, 2020

Commits on May 17, 2020

[FLINK-17593][fs-connector] Support arbitrary recovery mechanism for PartFileWriter

guoweiM
authored and
JingsongLi
committedMay 17, 2020

Commits on Mar 28, 2020

[FLINK-16262][connectors/kafka] Set the context classloader for parallel stream in FlinkKafkaProducer
guoweiM
committedMar 28, 2020

Commits on Mar 2, 2020

[FLINK-2336][DataStream API] Fix ArrayIndexOufOBoundsException in TypeExtractor for type erased lambdas

guoweiM
authored and
StephanEwen
committedMar 2, 2020

Commits on Jan 25, 2020

[FLINK-10819] Replace with the Flink's Deadline implementation

guoweiM
authored and
tillrohrmann
committedJan 25, 2020

Commits on Dec 2, 2019

[hotfix][docs] Fix an error in mesos.zh.md

guoweiM
authored and
GJL
committedDec 2, 2019
[FLINK-14467][mesos] Implement user code classloading in per-job cluster

guoweiM
authored and
GJL
committedDec 2, 2019

Commits on Nov 19, 2019

[FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

guoweiM
authored and
GJL
committedNov 19, 2019

Commits on Nov 9, 2019

[FLINK-14465] Let StandaloneJobClusterEntryPoint use the user code class loader

guoweiM
authored and
tillrohrmann
committedNov 9, 2019

Commits on Nov 1, 2019

[FLINK-14464] Introduce the AbstractUserClassPathJobGraphRetriever

guoweiM
authored and
tillrohrmann
committedNov 1, 2019