Commits

History for

Commits on Jun 27, 2019

[FLINK-11662] Disable task to fail on checkpoint errors

Myasuka
authored and
StefanRRichter
committedJun 27, 2019

Commits on Jun 26, 2019

[FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept
zentol
committedJun 26, 2019
[FLINK-12732] [state-processing-api] Add savepoint reader for consuming partitioned operator state

sjwiesman
authored and
tzulitai
committedJun 26, 2019
[hotfix] Refactor NeverCompleteFuture into a reusable utility

sjwiesman
authored and
tzulitai
committedJun 26, 2019
[FLINK-12729] [state-processing-api] Add state reader for consuming non-partitioned operator state

sjwiesman
authored and
tzulitai
committedJun 26, 2019

Commits on Jun 25, 2019

[hotfix][config][docs] Fiy typo for taskmanager.memory.preallocate

hehuiyuan
authored and
zentol
committedJun 25, 2019

Commits on Jun 21, 2019

[FLINK-12868][plugins] Log warnings if the plugins directory doesn't exist
pnowojski
committedJun 21, 2019

Commits on Jun 20, 2019

Commits on Jun 19, 2019

[FLINK-12143][runtime] Workaround for dynamic class loading in FS creation: set thread context class loader to plugin's class loader

1u0
authored and
pnowojski
committedJun 19, 2019

Commits on Jun 15, 2019

[FLINK-12446][docs] update openSSL option documentation
NicoK
committedJun 15, 2019
[hotfix][docs] correctly escape ampersands
NicoK
committedJun 15, 2019
[FLINK-9816][network] allow configuring the SSL engine provider
NicoK
committedJun 15, 2019
[hotfix][docs] make LineBreakElement also implement InlineElement
NicoK
committedJun 15, 2019
[FLINK-12297] Make Java ClosureCleaner recursive to handle nested functions

Aitozi
authored and
aljoscha
committedJun 15, 2019

Commits on Jun 14, 2019

[FLINK-12647][network] Make partition release on consumption optional
zentol
committedJun 14, 2019
[FLINK-12669][runtime] Implement FixedDelayRestartBackoffTimeStrategy

eaglewatcherwb
authored and
tillrohrmann
committedJun 14, 2019
[FLINK-12670][runtime] Implement FailureRateRestartBackoffTimeStrategy

eaglewatcherwb
authored and
tillrohrmann
committedJun 14, 2019

Commits on Jun 13, 2019

[FLINK-12822] Add explicit transformer from SerializableOptional to Optional

tisonkun
authored and
tillrohrmann
committedJun 13, 2019
[FLINK-12163] User correct ClassLoader for Hadoop Writable TypeInfo

arganzheng
authored and
aljoscha
committedJun 13, 2019
[FLINK-12143] PluginLoader: use system level always parents first patterns in class loading

1u0
authored and
pnowojski
committedJun 13, 2019
[FLINK-12143][dist] Ship plugins in the cluster the same way as lib jars
pnowojski
committedJun 13, 2019
[FLINK-12143] Distribute FLINK_PLUGINS_DIR the same way as FLINK_LIB_DIR is distributed
pnowojski
committedJun 13, 2019
[hotfix][core] Deduplicate code and unify method names in GlobalConfiguration
pnowojski
committedJun 13, 2019
[hotfix] Use proper template format substitute for Preconditions

1u0
authored and
zentol
committedJun 13, 2019

Commits on Jun 11, 2019

[FLINK-11392][network] Rename NetworkEnviroment to NettyShuffleEnviroment

azagrebin
authored and
tillrohrmann
committedJun 11, 2019

Commits on Jun 7, 2019

[hotfix][datastream, core] Move StreamTransformation to flink-core
dawidwys
committedJun 7, 2019

Commits on Jun 5, 2019

[FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

yanghua
authored and
GJL
committedJun 5, 2019
[hotfix][core] Add notice about TypeSerializerSnapshot serialization
twalthr
committedJun 5, 2019

Commits on Jun 3, 2019

[FLINK-12547][blob] Add connection and socket timeouts for the blob client

sunhaibotb
authored and
tillrohrmann
committedJun 3, 2019
[FLINK-12409][python] Adds from_elements in TableEnvironment

dianfu
authored and
sunjincheng121
committedJun 3, 2019