feast-dev
diff --git a/‎core/src/main/java/feast/core/job/direct/DirectRunnerJobManager.java‎
Lines changed: 1 addition & 0 deletions b/‎core/src/main/java/feast/core/job/direct/DirectRunnerJobManager.java‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎ingestion/src/main/java/feast/ingestion/options/ImportOptions.java‎
Lines changed: 0 additions & 30 deletions b/‎ingestion/src/main/java/feast/ingestion/options/ImportOptions.java‎
Lines changed: 0 additions & 30 deletions
@@ -98,6 +98,7 @@ private ImportOptions getPipelineOptions(List<FeatureSetSpec> featureSetSpecs,
     pipelineOptions.setFeatureSetSpecJson(featureSetsJson);
     pipelineOptions.setStoreJson(Collections.singletonList(printer.print(sink)));
     pipelineOptions.setRunner(DirectRunner.class);
+    pipelineOptions.setProject(""); // set to default value to satisfy validation
     if (metrics.isEnabled()) {
       pipelineOptions.setMetricsExporterType(metrics.getType());
       if (metrics.getType().equals("prometheus")) {
 
@@ -84,34 +84,4 @@ public interface ImportOptions extends PipelineOptions, DataflowPipelineOptions,
 
   void setPrometheusExporterAddress(String prometheusExporterAddress);
 
-  @Description("Limit of rows to sample and output for debugging")
-  @Default.Integer(0)
-  int getSampleLimit();
-
-  void setSampleLimit(int value);
-
-  @Description(
-      "Enable coalesce rows, merges feature rows within a time window to output only the latest value")
-  @Default.Boolean(false)
-  boolean isCoalesceRowsEnabled();
-
-  void setCoalesceRowsEnabled(boolean value);
-
-  @Description("Delay in seconds to wait for newer values to coalesce on key before emitting")
-  @Default.Integer(10)
-  int getCoalesceRowsDelaySeconds();
-
-  void setCoalesceRowsDelaySeconds(int value);
-
-  @Description("Time in seconds to retain feature rows to merge with newer records")
-  @Default.Integer(30)
-  int getCoalesceRowsTimeoutSeconds();
-
-  void setCoalesceRowsTimeoutSeconds(int value);
-
-  @Description("If dry run is set, execute up to feature row validation")
-  @Default.Boolean(false)
-  Boolean isDryRun();
-
-  void setDryRun(Boolean value);
 }