Commits

Branch selector

 master

User selector

wangyang0918

Datepicker

All time

Commit History

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

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

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

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

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

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

  Show description for 2c92ea9
  

  wangyang0918

  authored and

  xintongsong

  committed
  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

Commits on Dec 2, 2020

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

  Show description for 674d610
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  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

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

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

Commits on Nov 16, 2020

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

  Show description for 4a6ce27
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  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

Commits on Nov 7, 2020

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

  Show description for dc56273
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  dc56273

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

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  2e08e2e

• [hotfix][test] Add TestingRetrievableStateStorageHelper which is settable with exception

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  653bc10

• [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API

  Show description for 5f7e0dc
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  5f7e0dc

• [FLINK-19543][k8s] Introduce composition implementations to support JobGraphStore on Kubernetes

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  847f3bb

• [FLINK-19543][k8s] Implement KubernetesStateHandleStore based on Kubernetes API

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  8b4f28b

• [hotfix][coordination] Wire ZooKeeperJobGraphStore to the new interface

  Show description for c3a6b51
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  c3a6b51

• [hotfix][coordination] Introduce new interfaces and data structure for JobGraphStore composition mechanism

  Show description for 90df930
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  90df930

• [hotfix][coordination] Introduce the interface StateHandleStore and make ZooKeeperStateHandleStore as an implementation

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  3dda515

• [hotfix][test] Abstract TestingLongStateHandleHelper from ZooKeeperStateHandleStoreTest so that it could be reused

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  86d2019

• [hotfix] Move RetrievableStateStorageHelper and implementation out of zookeeper package so that it could be reused by Kubernetes high-availability

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  d1f1865

Commits on Nov 5, 2020

• [FLINK-19542][k8s] Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

  Show description for 0198805
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  0198805

• [FLINK-19542][k8s] Introduce data structures and interface for KubernetesLeaderElector

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  a73acc0

• [FLINK-19542][k8s] Introduce data structures and common operations for KubernetesConfigMap

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  fd6ef3e

• [hotfix][coordination] Introduce AbstractHaServices for common logics and wire ZookeeperHaServices to new interface

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  e6dd788

• [hotfix][coordination] Wire ZooKeeper leader election/retrieval services to new interface

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  04b9383

• [hotfix][coordination] Introduce new interfaces and data structure for LeaderElection and LeaderRetrieval composition mechanism

  Show description for 9cfda8d
  

  wangyang0918

  authored and

  tillrohrmann

  committed
  9cfda8d

• [hotfix][test] Refactor TestingContender and TestingListener to abstract some common methods

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  66adfe3

• [hotfix][util] Make FutureUtils#retry could stop at non-retryable exception

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  4d0fdd3

• [hotfix][k8s] Add interface FlinkKubeClient#close with no exception

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  0d4583a

• [hotfix][k8s] Abstract get common labels to KubernetesUtils#getCommonLabels

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  f2c90a1

• [hotfix][k8s] Introduce AbstractKubernetesWatcher with common logics

  

  wangyang0918

  authored and

  tillrohrmann

  committed
  e2bb32c

Pagination

PreviousNext