Spawn Trigger Jobs With Owner Reference (#204)

Co-authored-by: Shrinand Thakkar <sthakkar@linkedin.com>

Author: srnand

deploy/samples/retl-job-template.yaml

@@ -17,7 +17,7 @@ spec:
             image: alpine/k8s:1.33.0
             env:
               - name: TABLE_TRIGGER_NAME
-                value: "{{name}}-trigger"
+                value: "{{trigger}}"
               - name: SOURCE_TABLE_NAME
                 value: "{{offline.table.name}}"
               - name: ONLINE_TABLE_NAME

hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/trigger/TableTriggerReconciler.java

@@ -4,13 +4,15 @@
 import java.time.Duration;
 import java.time.OffsetDateTime;
 import java.time.ZonedDateTime;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.Properties;
 
+import io.kubernetes.client.openapi.models.V1OwnerReference;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -221,7 +223,17 @@ private void createJob(String yaml, V1alpha1TableTrigger trigger) throws SQLExce
     annotations.put(TRIGGER_TIMESTAMP_KEY, trigger.getStatus().getTimestamp().toString());
     Map<String, String> labels = new HashMap<>();
     labels.put(TRIGGER_KEY, trigger.getMetadata().getName());
-    yamlApi.createWithMetadata(yaml, annotations, labels, trigger.getMetadata().getOwnerReferences());
+    List<V1OwnerReference> ownerReference;
+    if (trigger.getMetadata().getOwnerReferences() != null && !trigger.getMetadata().getOwnerReferences().isEmpty()) {
+      ownerReference = trigger.getMetadata().getOwnerReferences();
+    } else {
+      ownerReference = Collections.singletonList(new V1OwnerReference()
+          .apiVersion(trigger.getApiVersion())
+          .kind(trigger.getKind())
+          .name(trigger.getMetadata().getName())
+          .uid(trigger.getMetadata().getUid()));
+    }
+    yamlApi.createWithMetadata(yaml, annotations, labels, ownerReference);
   }
 
   private ExecutionTime scheduledExecution(V1alpha1TableTrigger object) {