feast-dev
diff --git a/‎core/src/main/java/feast/core/storage/BigQueryStorageManager.java‎
Lines changed: 5 additions & 1 deletion b/‎core/src/main/java/feast/core/storage/BigQueryStorageManager.java‎
Lines changed: 5 additions & 1 deletion
diff --git a/‎core/src/test/java/feast/core/storage/BigQueryStorageManagerTest.java‎
Lines changed: 4 additions & 2 deletions b/‎core/src/test/java/feast/core/storage/BigQueryStorageManagerTest.java‎
Lines changed: 4 additions & 2 deletions
@@ -44,6 +44,7 @@ public class BigQueryStorageManager implements StorageManager {
   private static final String FIELD_ID = "id";
   private static final String FIELD_EVENT_TIMESTAMP = "event_timestamp";
   private static final String FIELD_CREATED_TIMESTAMP = "created_timestamp";
+  private static final String FIELD_JOB_ID = "job_id";
 
   private String id;
   private final BigQuery bigQuery;
@@ -103,6 +104,7 @@ public void registerNewFeature(FeatureSpec featureSpec) {
               createField(FIELD_ID, Enum.STRING, ""),
               createField(FIELD_EVENT_TIMESTAMP, Enum.TIMESTAMP, FIELD_EVENT_TIMESTAMP),
               createField(FIELD_CREATED_TIMESTAMP, Enum.TIMESTAMP, FIELD_CREATED_TIMESTAMP),
+              createField(FIELD_JOB_ID, Enum.STRING, FIELD_JOB_ID),
               createFeatureField(featureSpec));
       TableDefinition tableDefinition =
           StandardTableDefinition.newBuilder()
@@ -137,7 +139,9 @@ public void registerNewFeature(FeatureSpec featureSpec) {
                 f ->
                     !f.equals(FIELD_ID)
                         && !f.equals(FIELD_CREATED_TIMESTAMP)
-                        && !f.equals(FIELD_EVENT_TIMESTAMP))
+                        && !f.equals(FIELD_EVENT_TIMESTAMP)
+                        && !f.equals(FIELD_JOB_ID))
+
             .collect(Collectors.toList()));
     AuditLogger.log(
         Resource.STORAGE,
 
@@ -115,15 +115,17 @@ public void shouldCreateNewDatasetAndTableAndViewIfNotExist() throws Interrupted
         actualTable.getTableId().getTable(),
         equalTo(String.format("%s_%s", entityName, granularity.toString().toLowerCase())));
     List<Field> fields = actualTable.getDefinition().getSchema().getFields();
-    assertThat(fields.size(), equalTo(4));
+    assertThat(fields.size(), equalTo(5));
     Field idField = fields.get(0);
     assertThat(idField.getName(), equalTo("id"));
     Field etsField = fields.get(1);
     assertThat(etsField.getName(), equalTo("event_timestamp"));
     Field ctsField = fields.get(2);
     assertThat(ctsField.getName(), equalTo("created_timestamp"));
-    Field field = fields.get(3);
+    Field field = fields.get(4);
     assertThat(field.getDescription(), equalTo(description));
+    Field jobIdField = fields.get(3);
+    assertThat(jobIdField.getName(), equalTo("job_id"));
     assertThat(field.getType(), equalTo(LegacySQLTypeName.INTEGER));
     assertThat(field.getName(), equalTo(featureName));