File tree Expand file tree Collapse file tree
ingestion/src/main/java/feast/ingestion/transform/metrics Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2525import feast .proto .types .ValueProto .Value ;
2626import feast .proto .types .ValueProto .Value .ValCase ;
2727import java .time .Clock ;
28+ import java .util .Arrays ;
2829import java .util .HashMap ;
2930import java .util .Map ;
3031import java .util .Map .Entry ;
32+ import java .util .stream .Collectors ;
3133import javax .annotation .Nullable ;
3234import org .apache .beam .sdk .transforms .DoFn ;
3335import org .apache .beam .sdk .values .KV ;
@@ -192,11 +194,15 @@ public void processElement(
192194 }
193195 }
194196
197+ String [] split = c .getPipelineOptions ().getJobName ().split ("-" );
198+ String jobNameWithoutTimestamp =
199+ Arrays .stream (split ).limit (split .length - 1 ).collect (Collectors .joining ("-" ));
200+
195201 String [] tags = {
196202 STORE_TAG_KEY + ":" + getStoreName (),
197203 FEATURE_SET_PROJECT_TAG_KEY + ":" + featureSetProject ,
198204 FEATURE_SET_NAME_TAG_KEY + ":" + featureSetName ,
199- INGESTION_JOB_NAME_KEY + ":" + c . getPipelineOptions (). getJobName () ,
205+ INGESTION_JOB_NAME_KEY + ":" + jobNameWithoutTimestamp ,
200206 METRICS_NAMESPACE_KEY + ":" + getMetricsNamespace (),
201207 };
202208
You can’t perform that action at this time.
0 commit comments