Commits

History for

Commits on Nov 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-19662][runtime][core] Moved assembleDynamicConfigsStr into ConfigurationUtils to be used by both TaskExecutorProcessUtils and JobManagerProcessUtils.

XComp
authored and
tillrohrmann
committedNov 4, 2020
[FLINK-19952][core] Replace deprecated ConfigOption builder in SecurityOptions.

liuyongvs
authored and
dawidwys
committedNov 4, 2020

Commits on Nov 3, 2020

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

wsry
authored and
StephanEwen
committedNov 3, 2020
[FLINK-19600][network] Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle

wsry
authored and
StephanEwen
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
[hotfix][core] Add Configuration.fromMap

twalthr
authored and
wuchong
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 30, 2020

[FLINK-18363] Add user classloader to context in DeSerializationSchema
dawidwys
committedOct 30, 2020

Commits on Oct 29, 2020

[FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy
aljoscha
committedOct 29, 2020
[FLINK-19836] Add SerializableSupplier in flink-core
aljoscha
committedOct 29, 2020
[hotfix][doc] Correct FSDataInputStream in FileSystem document
zhuxiaoshang
committedOct 29, 2020

Commits on Oct 28, 2020

[FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext. (apache#12647 )
pyscala
committedOct 28, 2020

Commits on Oct 27, 2020

[FLINK-19793][connector-kafka] Harden KafkaTableITCase.testKafkaSourceSinkWithMetadata
twalthr
committedOct 27, 2020

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

kylemeow
authored and
tillrohrmann
committedOct 24, 2020

Commits on Oct 23, 2020

[hotfix][table-common] Add a new Row.deepEquals for all conversion classes
twalthr
committedOct 23, 2020

Commits on Oct 22, 2020

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

KarmaGYZ
authored and
xintongsong
committedOct 22, 2020

Commits on Oct 16, 2020

[FLINK-19583] Expose the execution.runtime-mode to users
kl0u
committedOct 16, 2020
[FLINK-19640] Enable sorting inputs for batch
dawidwys
committedOct 16, 2020

Commits on Oct 15, 2020

[hotfix] Disable KryoSerializerConcurrencyCheckInactiveITCase if logging level is DEBUG
rmetzger
committedOct 15, 2020

Commits on Oct 14, 2020

[FLINK-16620] - Add attempt information in TaskInfo

Jiayi-Liao
authored and
pnowojski
committedOct 14, 2020

Commits on Oct 13, 2020

Commits on Oct 12, 2020

[hotfix] Make Transformation.getTransitivePredecessors() return a list
kl0u
committedOct 12, 2020
[FLINK-19485] Add the Transformation.getInputs() method
kl0u
committedOct 12, 2020
[FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API
StephanEwen
committedOct 12, 2020

Commits on Oct 6, 2020

[FLINK-19472] Add an option to enable sorted inputs for operators
dawidwys
committedOct 6, 2020
[FLINK-19472] Implement a one input sorting DataInput
dawidwys
committedOct 6, 2020
[hotfix] Alllow declaring which ordering direction should be tested
dawidwys
committedOct 6, 2020

Commits on Oct 2, 2020

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

kezhuw
authored and
tillrohrmann
committedOct 2, 2020
[FLINK-19457][core] Add a number sequence generating source for the FLIP-27 source API.
StephanEwen
committedOct 2, 2020