configmap.yaml 1.3 KB

12345678910111213141516171819202122232425262728293031323334
  1. apiVersion: v1
  2. kind: ConfigMap
  3. metadata:
  4. name: {{ include "flink.fullname" . }}-config
  5. labels:
  6. {{ include "flink.labels" . | indent 4 }}
  7. data:
  8. flink-conf.yaml: |+
  9. {{- if .Values.jobmanager.highAvailability.enabled }}
  10. jobmanager.rpc.address: REPLACE_HOSTNAME
  11. {{- end }}
  12. {{ include "flink.configuration" . | indent 4 }}
  13. flink-conf-taskmanager.yaml: |+
  14. {{ include "flink.configuration" . | indent 4 }}
  15. log4j.properties: |+
  16. log4j.rootLogger=INFO, file
  17. log4j.logger.akka=WARN
  18. log4j.logger.org.apache.kafka=WARN
  19. log4j.logger.org.apache.kafka.clients.producer.ProducerConfig=WARN
  20. log4j.logger.org.apache.kafka.clients.consumer.ConsumerConfig=WARN
  21. log4j.logger.org.apache.hadoop=INFO
  22. log4j.logger.org.apache.zookeeper=INFO
  23. log4j.appender.file=org.apache.log4j.FileAppender
  24. log4j.appender.file.file=${log.file}
  25. log4j.appender.file.layout=org.apache.log4j.PatternLayout
  26. log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n
  27. log4j.logger.org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline=ERROR, file
  28. security.properties:
  29. # The java-level namelookup cache policy for successful lookups
  30. networkaddress.cache.ttl=30
  31. {{- if .Values.jobmanager.highAvailability.enabled }}
  32. masters: |
  33. {{ include "flink.fullname" . }}-jobmanager
  34. {{- end }}