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;