diff --git a/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionEnvironment.java b/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionEnvironment.java index f47aeaf..fae4f6c 100644 --- a/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionEnvironment.java +++ b/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionEnvironment.java @@ -37,7 +37,9 @@ public class SubscriptionEnvironment extends Resource.SimpleEnvironment { public SubscriptionEnvironment(String namespace, String name, Pipeline pipeline, Map hints) { - exportAll(hints); + if (hints != null) { + exportAll(hints); + } export("pipeline.namespace", namespace); export("pipeline.name", name); export("pipeline.avroSchema", AvroConverter.avro("com.linkedin.hoptimator", "OutputRecord",