Merge pull request #64 from cdapio/feature/CDAP-17721-k8s-kerberos

(CDAP-17721) Added support for extra Hadoop configuration

Author: chtyim

controllers/cdapmaster_controller.go

@@ -16,14 +16,15 @@ limitations under the License.
 package controllers
 
 import (
-	"cdap.io/cdap-operator/controllers/cdapmaster"
 	"fmt"
-	batchv1 "k8s.io/api/batch/v1"
-	"sigs.k8s.io/controller-reconciler/pkg/finalizer"
 	"strconv"
 	"strings"
 	"text/template"
 
+	"cdap.io/cdap-operator/controllers/cdapmaster"
+	batchv1 "k8s.io/api/batch/v1"
+	"sigs.k8s.io/controller-reconciler/pkg/finalizer"
+
 	"github.com/go-logr/logr"
 	"k8s.io/apimachinery/pkg/runtime"
 	gr "sigs.k8s.io/controller-reconciler/pkg/genericreconciler"
@@ -165,12 +166,19 @@ func (h *ConfigMapHandler) Objects(rsrc interface{}, rsrclabels map[string]strin
 	}
 
 	fillTemplate := func(templateFile string) (string, error) {
-		template, err := template.New(templateFile).ParseFiles(templateDir + templateFile)
+		tmpl, err := template.New(templateFile).Funcs(template.FuncMap{
+			"hasPrefix": func(str, prefix string) bool {
+				return strings.HasPrefix(str, prefix)
+			},
+			"trimPrefix": func(str, prefix string) string {
+				return strings.TrimPrefix(str, prefix)
+			},
+		}).ParseFiles(templateDir + templateFile)
 		if err != nil {
 			return "", err
 		}
 		var output strings.Builder
-		if err := template.Execute(&output, templateData); err != nil {
+		if err := tmpl.Execute(&output, templateData); err != nil {
 			return "", err
 		}
 		return output.String(), nil

templates/cdap-site.xml

@@ -15,10 +15,12 @@
   the License.
   -->
 <configuration>
-{{range $k,$v := .Master.Spec.Config}}
+{{range $k,$v := .Master.Spec.Config -}}
+  {{if not (hasPrefix $k "hadoop:")}}
   <property>
     <name>{{html $k}}</name>
     <value>{{html $v}}</value>
   </property>
-{{end}}
+  {{end}}
+{{- end}}
 </configuration>

templates/core-site.xml

@@ -19,4 +19,12 @@
     <name>fs.defaultFS</name>
     <value>{{html .Master.Spec.LocationURI}}</value>
   </property>
+{{range $k,$v := .Master.Spec.Config -}}
+  {{if hasPrefix $k "hadoop:"}}
+  <property>
+    <name>{{html (trimPrefix $k "hadoop:")}}</name>
+    <value>{{html $v}}</value>
+  </property>
+  {{end}}
+{{- end}}
 </configuration>