Commits

History for

Commits on Dec 3, 2020

[FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas
authored and
dianfu
committedDec 3, 2020

Commits on Dec 2, 2020

[FLINK-20055][configuration] Add Datadog 'apikey' to list of sensitive options
florianakos
committedDec 2, 2020
[FLINK-20221] DelimitedInputFormat does not restore compressed splits
Gyula Fora
committedDec 2, 2020
[hotfix] Correct the description of security.kerberos.krb5-conf.path

KarmaGYZ
authored and
xintongsong
committedDec 2, 2020

Commits on Dec 1, 2020

[FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

Arvid Heise
authored and
AHeise
committedDec 1, 2020

Commits on Nov 27, 2020

[FLINK-18545][configuration] Introduce pipeline.name to allow users to specify job name by configuration
godfreyhe
committedNov 27, 2020

Commits on Nov 26, 2020

[hotfix][connectors] Fixed typo in Source.java docs

iraleigh
authored and
azagrebin
committedNov 26, 2020
Update version to 1.13-SNAPSHOT
dianfu
committedNov 26, 2020

Commits on Nov 25, 2020

[hotfix][javadocs] Fix typo in RichFunction
dongxuwang
committedNov 25, 2020

Commits on Nov 24, 2020

[FLINK-20282][runtime] Add logs for managed memory use cases whose consumer weights are 0 or missing.
xintongsong
committedNov 24, 2020
[hotfix][core] Extend JavaDocs for ExternallyInducedSourceReader.
StephanEwen
committedNov 24, 2020
[FLINK-20270][runtime] Add support for ExternallyInducedSource based on FLIP-27 to SourceOperatorStreamTask.

becketqin
authored and
StephanEwen
committedNov 24, 2020

Commits on Nov 23, 2020

[hotfix][core] Fix JavaDocs for TemporaryClassLoaderContext
StephanEwen
committedNov 23, 2020

Commits on Nov 22, 2020

Commits on Nov 20, 2020

[FLINK-20240] Add execution.runtime-mode setter in StreamExecutionEnvironment
kl0u
committedNov 20, 2020

Commits on Nov 17, 2020

[hotfix][doc] Include config option TaskManagerOptions#MANAGED_MEMORY_CONSUMER_WEIGHTS into docs.
xintongsong
committedNov 17, 2020
[FLINK-19300] Fix input stream read to prevent heap based timer loss

Acesine
authored and
tzulitai
committedNov 17, 2020

Commits on Nov 16, 2020

[FLINK-20152] Document supported execution.target values
kl0u
committedNov 16, 2020
[FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner
tillrohrmann
committedNov 16, 2020

Commits on Nov 11, 2020

[FLINK-20018] Allow escaping in 'pipeline.cached-files' and 'pipeline.default-kryo-serializers'
dawidwys
committedNov 11, 2020

Commits on Nov 10, 2020

[refactor] Move Source Reader Test Utils classes from 'flink-core' test jar to 'flink-connector-test-utils'
StephanEwen
committedNov 10, 2020

Commits on Nov 9, 2020

Commits on Nov 8, 2020

Commits on Nov 7, 2020

[minor] Rework Javadoc in Sink interface
aljoscha
committedNov 7, 2020
[FLINK-20019][core] Support all conversion classes in Row.equals/hashCode
twalthr
committedNov 7, 2020
[FLINK-19963] Allow SinkWriter use processing timer service.

guoweiM
authored and
kl0u
committedNov 7, 2020

Commits on Nov 6, 2020

[hotfix] Improve JavaDocs of SourceReader.
StephanEwen
committedNov 6, 2020
[FLINK-19384][core] Add common permissive exception signatures to all methods of Source.
StephanEwen
committedNov 6, 2020
[hotfix][core] InstantiationUtil#serializeObject creates ObjectOutputStream only when necessary.

Arvid Heise
authored and
AHeise
committedNov 6, 2020
[hotfix][util] Fix Precondition#checkNotNull annotations.

Arvid Heise
authored and
AHeise
committedNov 6, 2020