operator flink-kubernetes-operator (1.6.0)

operators/flink-kubernetes-operator/1.6.0/bundle.Dockerfile

@@ -0,0 +1,37 @@
+################################################################################
+#  Licensed to the Apache Software Foundation (ASF) under one
+#  or more contributor license agreements.  See the NOTICE file
+#  distributed with this work for additional information
+#  regarding copyright ownership.  The ASF licenses this file
+#  to you under the Apache License, Version 2.0 (the
+#  "License"); you may not use this file except in compliance
+#  with the License.  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+# limitations under the License.
+################################################################################
+FROM scratch
+
+ARG ARCH=multiarch
+ARG USER=1001
+
+# Core bundle labels.
+LABEL operators.operatorframework.io.bundle.mediatype.v1=registry+v1
+LABEL operators.operatorframework.io.bundle.manifests.v1=manifests/
+LABEL operators.operatorframework.io.bundle.metadata.v1=metadata/
+LABEL operators.operatorframework.io.bundle.package.v1=flink-kubernetes-operator
+LABEL operators.operatorframework.io.bundle.channels.v1=latest
+LABEL operators.operatorframework.io.metrics.builder=operator-sdk-v1.23.0
+LABEL operators.operatorframework.io.metrics.mediatype.v1=metrics+v1
+LABEL operators.operatorframework.io.metrics.project_layout=unknown
+
+USER ${USER}
+
+# Copy files to locations specified by labels.
+COPY ./manifests /manifests/
+COPY ./metadata /metadata/

operators/flink-kubernetes-operator/1.6.0/manifests/flink-operator-config_v1_configmap.yaml

@@ -0,0 +1,175 @@
+apiVersion: v1
+data:
+  flink-conf.yaml: |
+    ################################################################################
+    #  Licensed to the Apache Software Foundation (ASF) under one
+    #  or more contributor license agreements.  See the NOTICE file
+    #  distributed with this work for additional information
+    #  regarding copyright ownership.  The ASF licenses this file
+    #  to you under the Apache License, Version 2.0 (the
+    #  "License"); you may not use this file except in compliance
+    #  with the License.  You may obtain a copy of the License at
+    #
+    #      http://www.apache.org/licenses/LICENSE-2.0
+    #
+    #  Unless required by applicable law or agreed to in writing, software
+    #  distributed under the License is distributed on an "AS IS" BASIS,
+    #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    #  See the License for the specific language governing permissions and
+    # limitations under the License.
+    ################################################################################
+
+    # Flink job/cluster related configs
+    taskmanager.numberOfTaskSlots: 1
+    parallelism.default: 1
+
+    # Flink operator related configs
+    # kubernetes.operator.reconcile.interval: 60 s
+    # kubernetes.operator.reconcile.parallelism: 5
+    # kubernetes.operator.flink.client.cancel.timeout: 1 min
+    # kubernetes.operator.resource.cleanup.timeout: 60 s
+    # kubernetes.operator.observer.rest-ready.delay: 10 s
+    # kubernetes.operator.observer.progress-check.interval: 10 s
+    # kubernetes.operator.observer.savepoint.trigger.grace-period: 10 s
+    # kubernetes.operator.flink.client.timeout: 10 s
+    # kubernetes.operator.deployment.rollback.enabled: false
+    # kubernetes.operator.deployment.readiness.timeout: 5min
+    # kubernetes.operator.user.artifacts.base.dir: /opt/flink/artifacts
+    # kubernetes.operator.job.upgrade.ignore-pending-savepoint: false
+    # kubernetes.operator.watched.namespaces: ns1,ns2
+    # kubernetes.operator.label.selector: flink=enabled
+    # kubernetes.operator.dynamic.namespaces.enabled: false
+    # kubernetes.operator.retry.initial.interval: 5 s
+    # kubernetes.operator.retry.interval.multiplier: 2
+    # kubernetes.operator.retry.max.attempts: 10
+    # kubernetes.operator.exception.stacktrace.enabled: false
+    # kubernetes.operator.exception.stacktrace.max.length: 2048
+    # kubernetes.operator.exception.field.max.length: 2048
+    # kubernetes.operator.exception.throwable.list.max.count: 2
+    # kubernetes.operator.exception.label.mapper: Job has already been submitted:duplicatedJobFound,Server returned HTTP response code:httpResponseCodeFound
+    # kubernetes.operator.leader-election.enabled: false
+    # kubernetes.operator.leader-election.lease-name: flink-operator-lease
+
+    # kubernetes.operator.metrics.reporter.slf4j.factory.class: org.apache.flink.metrics.slf4j.Slf4jReporterFactory
+    # kubernetes.operator.metrics.reporter.slf4j.interval: 5 MINUTE
+
+    # Flink Config Overrides
+    kubernetes.operator.metrics.reporter.slf4j.factory.class: org.apache.flink.metrics.slf4j.Slf4jReporterFactory
+    kubernetes.operator.metrics.reporter.slf4j.interval: 5 MINUTE
+
+    kubernetes.operator.reconcile.interval: 15 s
+    kubernetes.operator.observer.progress-check.interval: 5 s
+
+    kubernetes.operator.health.probe.enabled: true
+    kubernetes.operator.health.probe.port: 8085
+  log4j-console.properties: |
+    ################################################################################
+    #  Licensed to the Apache Software Foundation (ASF) under one
+    #  or more contributor license agreements.  See the NOTICE file
+    #  distributed with this work for additional information
+    #  regarding copyright ownership.  The ASF licenses this file
+    #  to you under the Apache License, Version 2.0 (the
+    #  "License"); you may not use this file except in compliance
+    #  with the License.  You may obtain a copy of the License at
+    #
+    #      http://www.apache.org/licenses/LICENSE-2.0
+    #
+    #  Unless required by applicable law or agreed to in writing, software
+    #  distributed under the License is distributed on an "AS IS" BASIS,
+    #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    #  See the License for the specific language governing permissions and
+    # limitations under the License.
+    ################################################################################
+
+    # This affects logging for both user code and Flink
+    rootLogger.level = INFO
+    rootLogger.appenderRef.console.ref = ConsoleAppender
+    rootLogger.appenderRef.rolling.ref = RollingFileAppender
+
+    # Uncomment this if you want to _only_ change Flink's logging
+    #logger.flink.name = org.apache.flink
+    #logger.flink.level = INFO
+
+    # The following lines keep the log level of common libraries/connectors on
+    # log level INFO. The root logger does not override this. You have to manually
+    # change the log levels here.
+    logger.akka.name = akka
+    logger.akka.level = INFO
+    logger.kafka.name= org.apache.kafka
+    logger.kafka.level = INFO
+    logger.hadoop.name = org.apache.hadoop
+    logger.hadoop.level = INFO
+    logger.zookeeper.name = org.apache.zookeeper
+    logger.zookeeper.level = INFO
+
+    # Log all infos to the console
+    appender.console.name = ConsoleAppender
+    appender.console.type = CONSOLE
+    appender.console.layout.type = PatternLayout
+    appender.console.layout.pattern = %d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n
+
+    # Log all infos in the given rolling file
+    appender.rolling.name = RollingFileAppender
+    appender.rolling.type = RollingFile
+    appender.rolling.append = false
+    appender.rolling.fileName = ${sys:log.file}
+    appender.rolling.filePattern = ${sys:log.file}.%i
+    appender.rolling.layout.type = PatternLayout
+    appender.rolling.layout.pattern = %d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n
+    appender.rolling.policies.type = Policies
+    appender.rolling.policies.size.type = SizeBasedTriggeringPolicy
+    appender.rolling.policies.size.size=100MB
+    appender.rolling.strategy.type = DefaultRolloverStrategy
+    appender.rolling.strategy.max = 10
+
+    # Suppress the irrelevant (wrong) warnings from the Netty channel handler
+    logger.netty.name = org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline
+    logger.netty.level = OFF
+
+    # Flink Deployment Logging Overrides
+    # rootLogger.level = DEBUG
+  log4j-operator.properties: |+
+    ################################################################################
+    #  Licensed to the Apache Software Foundation (ASF) under one
+    #  or more contributor license agreements.  See the NOTICE file
+    #  distributed with this work for additional information
+    #  regarding copyright ownership.  The ASF licenses this file
+    #  to you under the Apache License, Version 2.0 (the
+    #  "License"); you may not use this file except in compliance
+    #  with the License.  You may obtain a copy of the License at
+    #
+    #      http://www.apache.org/licenses/LICENSE-2.0
+    #
+    #  Unless required by applicable law or agreed to in writing, software
+    #  distributed under the License is distributed on an "AS IS" BASIS,
+    #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    #  See the License for the specific language governing permissions and
+    # limitations under the License.
+    ################################################################################
+
+    rootLogger.level = INFO
+    rootLogger.appenderRef.console.ref = ConsoleAppender
+
+    # Log all infos to the console
+    appender.console.name = ConsoleAppender
+    appender.console.type = CONSOLE
+    appender.console.layout.type = PatternLayout
+    appender.console.layout.pattern = %style{%d}{yellow} %style{%-30c{1.}}{cyan} %highlight{[%-5level]%notEmpty{[%X{resource.namespace}/}%notEmpty{%X{resource.name}]} %msg%n%throwable}
+
+    # Do not log config loading
+    logger.conf.name = org.apache.flink.configuration.GlobalConfiguration
+    logger.conf.level = WARN
+
+    # Flink Operator Logging Overrides
+    # rootLogger.level = DEBUG
+    # logger.operator.name= org.apache.flink.kubernetes.operator
+    # logger.operator.level = DEBUG
+
+kind: ConfigMap
+metadata:
+  labels:
+    app.kubernetes.io/managed-by: Helm
+    app.kubernetes.io/name: flink-kubernetes-operator
+    app.kubernetes.io/version: 1.6.0
+    helm.sh/chart: flink-kubernetes-operator-1.6.0
+  name: flink-operator-config

operators/flink-kubernetes-operator/1.6.0/manifests/flink-operator-webhook-secret_v1_secret.yaml

@@ -0,0 +1,7 @@
+apiVersion: v1
+data:
+  password: cGFzc3dvcmQxMjM0
+kind: Secret
+metadata:
+  name: flink-operator-webhook-secret
+type: Opaque

operators/flink-kubernetes-operator/1.6.0/manifests/flink-role-binding_rbac.authorization.k8s.io_v1_rolebinding.yaml

@@ -0,0 +1,19 @@
+apiVersion: rbac.authorization.k8s.io/v1
+kind: RoleBinding
+metadata:
+  annotations:
+    helm.sh/resource-policy: keep
+  creationTimestamp: null
+  labels:
+    app.kubernetes.io/managed-by: Helm
+    app.kubernetes.io/name: flink-kubernetes-operator
+    app.kubernetes.io/version: 1.6.0
+    helm.sh/chart: flink-kubernetes-operator-1.6.0
+  name: flink-role-binding
+roleRef:
+  apiGroup: rbac.authorization.k8s.io
+  kind: Role
+  name: flink
+subjects:
+  - kind: ServiceAccount
+    name: flink