Commits

History for

Commits on Oct 27, 2020

Commits on Oct 26, 2020

Commits on Oct 5, 2020

[FLINK-19123] Make MiniClusterJobClient shutdown behaviour configurable
aljoscha
committedOct 5, 2020
[FLINK-19123] Move PerJobMiniClusterJobClient to runtime.minicluster package
aljoscha
committedOct 5, 2020
[FLINK-19123] Move PerJobMiniClusterJobClient to top level
aljoscha
committedOct 5, 2020

Commits on Sep 30, 2020

[FLINK-17480][kubernetes][python] Support running PyFlink on Kubernetes

shuiqiangchen
authored and
dianfu
committedSep 30, 2020

Commits on Sep 25, 2020

[FLINK-19124][datastream] Remove ClassLoader parameter from JobClient methods

SteNicholas
authored and
aljoscha
committedSep 25, 2020

Commits on Sep 23, 2020

[FLINK-11779] Update the description of the CLI -m parameter

guoweiM
authored and
aljoscha
committedSep 23, 2020

Commits on Sep 16, 2020

[hotfix] Consider INITIALIZING JobState also as scheduled in CliFrontend
rmetzger
committedSep 16, 2020

Commits on Sep 8, 2020

[FLINK-19131][python] Add support of Python 3.8 in PyFlink

sunjincheng121
authored and
dianfu
committedSep 8, 2020

Commits on Sep 6, 2020

[FLINK-16866] Make jobsubmission non-blocking
rmetzger
committedSep 6, 2020

Commits on Sep 3, 2020

[FLINK-19084] Remove deprecated methods from ExecutionConfig
dawidwys
committedSep 3, 2020

Commits on Aug 24, 2020

[FLINK-18742][cli] Respect all config args when creating packaged program at client

wangzzu
authored and
kl0u
committedAug 24, 2020

Commits on Aug 19, 2020

[FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope
tisonkun
committedAug 19, 2020

Commits on Aug 18, 2020

[FLINK-18219][runtime] Removed TestRestServerEndpoint from flink-client module. Instead, use newly added test utility class in flink-runtime.

XComp
authored and
tillrohrmann
committedAug 18, 2020

Commits on Aug 16, 2020

[FLINK-16917][runtime] Added option to disable safety net user classloader.

Arvid Heise
authored and
zentol
committedAug 16, 2020
[FLINK-16245][table] Close user classloader

Arvid Heise
authored and
zentol
committedAug 16, 2020

Commits on Jul 22, 2020

[FLINK-18607][build] Give the maven module a human readable name
nielsbasjes
committedJul 22, 2020

Commits on Jun 22, 2020

[hotfix] Annotate the DefaultClusterClientServiceLoader as internal
kl0u
committedJun 22, 2020
[FLINK-18352] Make DefaultClusterClientServiceLoader/DefaultExecutorServiceLoader thread-safe
kl0u
committedJun 22, 2020
[FLINK-18377] Rename "Flink Master" back to JobManager in documentation
aljoscha
committedJun 22, 2020

Commits on Jun 12, 2020

[FLINK-18241] Use correct user class loader in OptimizerPlanEnvironment & StreamPlanEnvironment
dawidwys
committedJun 12, 2020

Commits on Jun 10, 2020

[FLINK-18084] Rename the ExecutorCLI to GenericCLI according to docs
kl0u
committedJun 10, 2020
[hotfix][cli] Update the help message of the Generic CLI
kl0u
committedJun 10, 2020

Commits on Jun 9, 2020

[FLINK-16225] Implement user class loading exception handler
azagrebin
committedJun 9, 2020

Commits on Jun 4, 2020

Commits on May 29, 2020

[FLINK-16144] get client.timeout for the client, with a fallback to the akka.client.timeout.

wtog
authored and
kl0u
committedMay 29, 2020