Fix bug in emitting metrics for only system directives

data-integrations · Apr 26, 2023 · a59a739 · a59a739
1 parent 372eed2
commit a59a739
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java b/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java
@@ -600,8 +600,8 @@ private Optional<ExpressionFactory<String>> getExpressionFactory(RelationalTranf
    */
   private void emitDirectiveMetrics(List<Directive> directives, Metrics metrics) throws DirectiveLoadException {
     for (Directive directive : directives) {
-      // skip emitting metrics if the directive is not system metric
-      if (registry.get(Contexts.SYSTEM, directive.define().getDirectiveName()) != null) {
+      // skip emitting metrics if the directive is not system directive
+      if (registry.get(Contexts.SYSTEM, directive.define().getDirectiveName()) == null) {
         continue;
       }
       List<EntityCountMetric> countMetrics = new ArrayList<>();