Merge pull request #659 from wu8685/master

show exception message when failing to acquire or renew election lock

Author: k8s-ci-robot

examples/src/main/java/io/kubernetes/client/examples/LeaderElectionExample.java

@@ -24,7 +24,7 @@ public static void main(String[] args) throws Exception {
     EndpointsLock lock = new EndpointsLock("kube-system", "leader-election", "foo");
 
     LeaderElectionConfig leaderElectionConfig =
-        new LeaderElectionConfig(lock, Duration.ofMillis(10000), null, Duration.ofMillis(5000));
+        new LeaderElectionConfig(lock, Duration.ofMillis(10000), null, Duration.ofMillis(2000));
     LeaderElector leaderElector = new LeaderElector(leaderElectionConfig);
 
     leaderElector.run(

extended/src/main/java/io/kubernetes/client/extended/leaderelection/LeaderElector.java

@@ -69,6 +69,7 @@ private boolean acquire() {
               } catch (CancellationException e) {
                 log.info("Processing tryAcquireOrRenew successfully canceled");
               } catch (Throwable t) {
+                log.error("Error processing tryAcquireOrRenew as {}", t.getMessage());
                 future.cancel(true);
               }
             },

extended/src/main/java/io/kubernetes/client/extended/leaderelection/resourcelock/ConfigMapLock.java

@@ -96,6 +96,7 @@ public boolean update(LeaderElectionRecord record) {
           .putAnnotationsItem(
               LeaderElectionRecordAnnotationKey,
               coreV1Client.getApiClient().getJSON().serialize(record));
+      // TODO consider to retry if receiving a 409 code
       V1ConfigMap replacedConfigMap =
           coreV1Client.replaceNamespacedConfigMap(name, namespace, configMap, null, null, null);
       configMapRefer.set(replacedConfigMap);

extended/src/main/java/io/kubernetes/client/extended/leaderelection/resourcelock/EndpointsLock.java

@@ -96,6 +96,7 @@ public boolean update(LeaderElectionRecord record) {
           .putAnnotationsItem(
               LeaderElectionRecordAnnotationKey,
               coreV1Client.getApiClient().getJSON().serialize(record));
+      // TODO consider to retry if receiving a 409 code
       V1Endpoints replacedEndpoints =
           coreV1Client.replaceNamespacedEndpoints(name, namespace, endpoints, null, null, null);
       endpointsRefer.set(replacedEndpoints);