Commits

Commits on Jul 31, 2021

[FLINK-22802][k8s] Remove the unnecessary temporary fix for fabric8 Kubernetes client max concurrent requests
wangyang0918
committedJul 31, 2021
[FLINK-22802][k8s] Bump fabric8 Kubernetes client version to 5.5.0
wangyang0918
committedJul 31, 2021
[hotfix] Replace deprecated Assert.assertThat
wangyang0918
committedJul 31, 2021

Commits on Jul 28, 2021

[FLINK-23418][e2e] Increase the timeout to make kubernetes application ha test more stable
wangyang0918
committedJul 28, 2021

Commits on Jun 7, 2021

[FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

wangyang0918
authored and
xintongsong
committedJun 7, 2021

Commits on May 18, 2021

[FLINK-19545][e2e] Add e2e test for native Kubernetes HA

wangyang0918
authored and
tillrohrmann
committedMay 18, 2021

Commits on May 11, 2021

[FLINK-17857][test] Make K8s e2e tests could run on Mac

wangyang0918
authored and
tillrohrmann
committedMay 11, 2021
[hotfix][e2e] Output and collect the logs for Kubernetes IT cases

wangyang0918
authored and
tillrohrmann
committedMay 11, 2021

Commits on Apr 9, 2021

[FLINK-21008][coordination] Register ClusterEntrypoint#closeAsync as shutdown hook for the cleanup

wangyang0918
authored and
tillrohrmann
committedApr 9, 2021
[hotfix][yarn-tests] Check the applicationId in verifyStringsInNamedLogFiles

wangyang0918
authored and
tillrohrmann
committedApr 9, 2021

Commits on Apr 7, 2021

[FLINK-22006][doc] Add documentation about how to configure Fabric8 Kubernetes client

wangyang0918
authored and
tillrohrmann
committedApr 7, 2021
[FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

wangyang0918
authored and
tillrohrmann
committedApr 7, 2021

Commits on Apr 1, 2021

[FLINK-21942][coordination] Remove job from JobLeaderIdService when disconnecting JobManager with globally terminal state

wangyang0918
authored and
tillrohrmann
committedApr 1, 2021
[FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

wangyang0918
authored and
tillrohrmann
committedApr 1, 2021

Commits on Mar 23, 2021

[FLINK-21382][docs] Update documentation for standalone Flink on Kubernetes with standby JobManagers

wangyang0918
authored and
tillrohrmann
committedMar 23, 2021
[hotfix][doc] Fix the less-than and greater-than sign in Kubernetes documentation

wangyang0918
authored and
tillrohrmann
committedMar 23, 2021

Commits on Mar 4, 2021

[FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

wangyang0918
authored and
zentol
committedMar 4, 2021
[hotfix][dist] Extract parseTmArgsAndExportLogs to config.sh so that it could be reused

wangyang0918
authored and
zentol
committedMar 4, 2021

Commits on Mar 2, 2021

[FLINK-21521][k8s] Pretty print K8s specifications in logs

wangyang0918
authored and
tillrohrmann
committedMar 2, 2021

Commits on Mar 1, 2021

[FLINK-15656][k8s][doc] Add documentation for pod template

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021
[FLINK-15656][k8s] Support to overwrite and merge some K8s fields from pod template and config options

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021
[FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021
[FLINK-15656][k8s] Unify the main container name of jobmanager and taskmanager pod

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021
[hotfix][k8s] Rename the implicit variable pod to podWithoutMainContainer

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021
[hotfix][k8s] Remove the unused variable in KubernetesResourceManagerDriver

wangyang0918
authored and
tillrohrmann
committedMar 1, 2021

Commits on Feb 8, 2021

[FLINK-20417][k8s] Create a new watcher when the old one is closed with HTTP_GONE

wangyang0918
authored and
tillrohrmann
committedFeb 8, 2021

Commits on Jan 21, 2021

[FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

wangyang0918
authored and
tillrohrmann
committedJan 21, 2021

Commits on Jan 12, 2021

[FLINK-20770][k8s] Correct the description of kubernetes config option 'kubernetes.rest-service.exposed.type'

wangyang0918
authored and
tillrohrmann
committedJan 12, 2021

Commits on Jan 11, 2021

[FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

wangyang0918
authored and
tillrohrmann
committedJan 11, 2021

Commits on Dec 25, 2020

[FLINK-20664][k8s][doc] Update RBAC section in native kubernetes document

wangyang0918
authored and
xintongsong
committedDec 25, 2020
[FLINK-20648][k8s] Add itcase for recovering from savepoint with Kubernetes HA enabled

wangyang0918
authored and
xintongsong
committedDec 25, 2020

Commits on Dec 23, 2020

[FLINK-20650][k8s] Remove "native-k8s" command and add bash wrapper for JobManager and TaskManager container args

wangyang0918
authored and
xintongsong
committedDec 23, 2020

Commits on Dec 2, 2020

[FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDuringInitialization

wangyang0918
authored and
tillrohrmann
committedDec 2, 2020

Commits on Nov 24, 2020

[FLINK-20214][k8s] Fix the unnecessary warning logs when Hadoop environment is not set

wangyang0918
authored and
xintongsong
committedNov 24, 2020

Commits on Nov 23, 2020

[FLINK-20211][doc] Use <ClusterId>-rest to get the external ip address

wangyang0918
authored and
xintongsong
committedNov 23, 2020