File tree Expand file tree Collapse file tree 2 files changed +21
-13
lines changed
ansible/roles/controller/tasks
common/scala/src/main/scala/org/apache/openwhisk/connector/kafka Expand file tree Collapse file tree 2 files changed +21
-13
lines changed Original file line number Diff line number Diff line change 443443 >> /logs/{{ controller_name }}_logs.log 2>&1"
444444
445445- name : wait until the Controller in this host is up and running
446- uri :
447- url :
448- " {{controller.protocol}}://{{ansible_host}}:{{controller_port}}/ping"
449- validate_certs : " no"
450- client_key :
451- " {{ controller.confdir }}/{{ controller_name }}/{{ controller.ssl.key }}"
452- client_cert :
453- " {{ controller.confdir }}/{{ controller_name }}/{{ controller.ssl.cert }}"
454- register : result
455- until : result.status == 200
456- retries : 12
457- delay : 10
446+ block :
447+ - uri :
448+ url : " {{ controller.protocol }}://{{ ansible_host }}:{{ controller_port }}/ping"
449+ validate_certs : no
450+ client_key : " {{ controller.confdir }}/{{ controller_name }}/{{ controller.ssl.key }}"
451+ client_cert : " {{ controller.confdir }}/{{ controller_name }}/{{ controller.ssl.cert }}"
452+ register : result
453+ until : result.status == 200
454+ retries : 12
455+ delay : 10
456+ failed_when : result.status is defined and result.status not in [200]
457+ rescue :
458+ - name : dump controller docker logs
459+ shell : " docker logs {{ controller_name }}"
460+ register : controller_logs
461+ failed_when : false
462+ - name : output controller logs for debugging
463+ debug :
464+ var : controller_logs.stdout_lines
465+ - fail :
466+ msg : " Controller failed to start; logs emitted above"
458467
459468- name : warm up activation path
460469 uri :
Original file line number Diff line number Diff line change @@ -122,7 +122,6 @@ object KamonMetricsReporter {
122122 }
123123
124124 def isCounterMetric (metric : KafkaMetric ): Boolean = Try (metric.measurable()) match {
125- case Success (_ : CumulativeSum ) => true
126125 case Success (_ : CumulativeCount ) => true
127126 case Success (m) if m.getClass.getSimpleName == " Total" => true
128127 case Success (m) if m.getClass.getSimpleName == " WindowedSum" && metric.metricName().name().endsWith(" -total" ) =>
You can’t perform that action at this time.
0 commit comments