This is an automated email from the ASF dual-hosted git repository.

wlo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 595446d36 [GOBBLIN-2031] Fix empty message in event submitter in 
Temporal (#3907)
595446d36 is described below

commit 595446d365f37aabc05e50c3db397c27d637891d
Author: Matthew Ho <[email protected]>
AuthorDate: Sun Mar 31 16:10:14 2024 -0700

    [GOBBLIN-2031] Fix empty message in event submitter in Temporal (#3907)
    
    [GOBBLIN-2031] Fix empty message in event submitter in Temporal
---
 .../gobblin/temporal/workflows/metrics/EventSubmitterContext.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java
 
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java
index a1f756971..6ef80f00d 100644
--- 
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java
+++ 
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java
@@ -21,14 +21,14 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Properties;
 
-import com.google.common.collect.ImmutableList;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
+import com.google.common.collect.ImmutableList;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-
 import lombok.NoArgsConstructor;
+
 import org.apache.gobblin.configuration.ConfigurationKeys;
 import org.apache.gobblin.configuration.State;
 import org.apache.gobblin.instrumented.Instrumented;
@@ -125,7 +125,6 @@ public class EventSubmitterContext {
           jobProps.getProperty(ConfigurationKeys.JOB_GROUP_KEY, "")));
       this.tags.add(new Tag<>(TimingEvent.FlowEventConstants.JOB_NAME_FIELD,
           jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY, "")));
-      this.tags.add(new Tag<>(TimingEvent.METADATA_MESSAGE, ""));
 
       this.tags.add(new Tag<>(Help.USER_TO_PROXY_KEY, 
jobProps.getProperty(Help.USER_TO_PROXY_KEY, "")));
       return this;

Reply via email to