Commits

Branch selector

 master

User selector

wangyang0918

Datepicker

All time

Commit History

Commits on May 18, 2021

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

  Show description for f15d277
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  f15d277

  Copy full SHA for f15d277

Commits on May 11, 2021

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

  Show description for 35ca4cf
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  35ca4cf

  Copy full SHA for 35ca4cf

• [hotfix][e2e] Output and collect the logs for Kubernetes IT cases

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  12010db

  Copy full SHA for 12010db

Commits on Apr 9, 2021

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

  Show description for e294300
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  e294300

  Copy full SHA for e294300

• [hotfix][yarn-tests] Check the applicationId in verifyStringsInNamedLogFiles

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  3b6af3d

  Copy full SHA for 3b6af3d

Commits on Apr 7, 2021

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

  Show description for 0eed15d
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  0eed15d

  Copy full SHA for 0eed15d

• [FLINK-22006][k8s] Support to configure max concurrent requests for fabric8 Kubernetes client via JAVA opts or envs

  Show description for ec677a1
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  ec677a1

  Copy full SHA for ec677a1

Commits on Apr 1, 2021

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

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  8aa510b

  Copy full SHA for 8aa510b

• [FLINK-21685][k8s] Use dedicated thread pool for Kubernetes client IO operations

  Show description for ade268e
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  ade268e

  Copy full SHA for ade268e

Commits on Mar 23, 2021

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

  Show description for d67c4d9
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  d67c4d9

  Copy full SHA for d67c4d9

• [hotfix][doc] Fix the less-than and greater-than sign in Kubernetes documentation

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  71ea41d

  Copy full SHA for 71ea41d

Commits on Mar 4, 2021

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

  

  wangyang0918

  authored and

  zentol

  committed
  a26388c

  Copy full SHA for a26388c

• [hotfix][dist] Extract parseTmArgsAndExportLogs to config.sh so that it could be reused

  

  wangyang0918

  authored and

  zentol

  committed
  f73b7e7

  Copy full SHA for f73b7e7

Commits on Mar 2, 2021

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

  Show description for 9874f01
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  9874f01

  Copy full SHA for 9874f01

Commits on Mar 1, 2021

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

  Show description for 24fe5ab
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  24fe5ab

  Copy full SHA for 24fe5ab

• [FLINK-15656][k8s] Support to overwrite and merge some K8s fields from pod template and config options

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  1552131

  Copy full SHA for 1552131

• [FLINK-15656][k8s] Support pod template for native kubernetes integration

  Show description for 4957736
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  4957736

  Copy full SHA for 4957736

• [FLINK-15656][k8s] Unify the main container name of jobmanager and taskmanager pod

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  a9003dd

  Copy full SHA for a9003dd

• [hotfix][k8s] Rename the implicit variable pod to podWithoutMainContainer

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  4fcc408

  Copy full SHA for 4fcc408

• [hotfix][k8s] Remove the unused variable in KubernetesResourceManagerDriver

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  b4bf3e3

  Copy full SHA for b4bf3e3

Commits on Feb 8, 2021

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

  Show description for eccbfe6
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  eccbfe6

  Copy full SHA for eccbfe6

Commits on Jan 21, 2021

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

  Show description for 65da60b
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  65da60b

  Copy full SHA for 65da60b

Commits on Jan 12, 2021

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

  Show description for d412c5d
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  d412c5d

  Copy full SHA for d412c5d

Commits on Jan 11, 2021

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

  Show description for 460e179
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  460e179

  Copy full SHA for 460e179

Commits on Dec 25, 2020

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

  Show description for 4e5448c
  

  wangyang0918

  authored and

  xintongsong

  committed
  4e5448c

  Copy full SHA for 4e5448c

• [FLINK-20648][k8s] Add itcase for recovering from savepoint with Kubernetes HA enabled

  Show description for 2c92ea9
  

  wangyang0918

  authored and

  xintongsong

  committed
  2c92ea9

  Copy full SHA for 2c92ea9

Commits on Dec 23, 2020

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

  Show description for 59a212f
  

  wangyang0918

  authored and

  xintongsong

  committed
  59a212f

  Copy full SHA for 59a212f

Commits on Dec 2, 2020

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

  Show description for 674d610
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  674d610

  Copy full SHA for 674d610

Commits on Nov 24, 2020

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

  Show description for 00ee23b
  

  wangyang0918

  authored and

  xintongsong

  committed
  00ee23b

  Copy full SHA for 00ee23b

Commits on Nov 23, 2020

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

  Show description for 3b0ad56
  

  wangyang0918

  authored and

  xintongsong

  committed
  3b0ad56

  Copy full SHA for 3b0ad56

Commits on Nov 18, 2020

• [FLINK-20143][yarn] Support non-qualified path for Yarn shared lib

  Show description for 424d41d
  

  wangyang0918

  authored and

  kl0u

  committed
  424d41d

  Copy full SHA for 424d41d

Commits on Nov 16, 2020

• [FLINK-19546][doc] Add documentation for native Kubernetes HA

  Show description for 4a6ce27
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  4a6ce27

  Copy full SHA for 4a6ce27

Commits on Nov 9, 2020

• [FLINK-20047][coordination] DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed

  Show description for 8bc6a7b
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  8bc6a7b

  Copy full SHA for 8bc6a7b

Commits on Nov 7, 2020

• [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

  Show description for dc56273
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  dc56273

  Copy full SHA for dc56273

• [hotfix][coordination] Introduce CompletedCheckpointStore composition mechanism and migrate ZooKeeperCompletedCheckpointStore

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  2e08e2e

  Copy full SHA for 2e08e2e

Pagination

Previous

Next