Merge remote-tracking branch 'origin/state_store_temporal' into state_store_temporal

Author: pratapaditya04

gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/org.apache.gobblin.service.flowconfigsV2.restspec.json

@@ -35,7 +35,7 @@
     } ],
     "finders" : [ {
       "name" : "filterFlows",
-      "doc" : "Get all {@link FlowConfig}s that matches the provided parameters. All the parameters are optional.\n If a parameter is null, it is ignored. {@see FlowConfigV2Resource#getFilteredFlows}",
+      "doc" : "Get all {@link FlowConfig}s that matches the provided parameters. All the parameters are optional.\n If a parameter is null, it is ignored.",
       "parameters" : [ {
         "name" : "flowGroup",
         "type" : "string",

gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/org.apache.gobblin.service.flowstatuses.restspec.json

@@ -6,7 +6,7 @@
   "namespace" : "org.apache.gobblin.service",
   "path" : "/flowstatuses",
   "schema" : "org.apache.gobblin.service.FlowStatus",
-  "doc" : "Deprecated, use {@link FlowExecutionResource}\n\nResource for handling flow status requests. generated from: org.apache.gobblin.service.FlowStatusResource",
+  "doc" : "Resource for handling flow status requests. Deprecated, use {@link FlowExecutionResource}\n\ngenerated from: org.apache.gobblin.service.FlowStatusResource",
   "collection" : {
     "identifier" : {
       "name" : "id",

gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/org.apache.gobblin.service.flowconfigsV2.snapshot.json

@@ -136,7 +136,7 @@
       } ],
       "finders" : [ {
         "name" : "filterFlows",
-        "doc" : "Get all {@link FlowConfig}s that matches the provided parameters. All the parameters are optional.\n If a parameter is null, it is ignored. {@see FlowConfigV2Resource#getFilteredFlows}",
+        "doc" : "Get all {@link FlowConfig}s that matches the provided parameters. All the parameters are optional.\n If a parameter is null, it is ignored.",
         "parameters" : [ {
           "name" : "flowGroup",
           "type" : "string",

gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/org.apache.gobblin.service.flowstatuses.snapshot.json

@@ -271,7 +271,7 @@
     "namespace" : "org.apache.gobblin.service",
     "path" : "/flowstatuses",
     "schema" : "org.apache.gobblin.service.FlowStatus",
-    "doc" : "Deprecated, use {@link FlowExecutionResource}\n\nResource for handling flow status requests. generated from: org.apache.gobblin.service.FlowStatusResource",
+    "doc" : "Resource for handling flow status requests. Deprecated, use {@link FlowExecutionResource}\n\ngenerated from: org.apache.gobblin.service.FlowStatusResource",
     "collection" : {
       "identifier" : {
         "name" : "id",

gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobContext.java

@@ -43,7 +43,6 @@
 import com.google.common.eventbus.Subscribe;
 import com.google.inject.Guice;
 import com.google.inject.Injector;
-import com.typesafe.config.Config;
 
 import javax.annotation.Nullable;
 import lombok.AccessLevel;
@@ -69,7 +68,6 @@
 import org.apache.gobblin.runtime.util.JobMetrics;
 import org.apache.gobblin.source.Source;
 import org.apache.gobblin.source.extractor.JobCommitPolicy;
-import org.apache.gobblin.util.ClassAliasResolver;
 import org.apache.gobblin.util.ConfigUtils;
 import org.apache.gobblin.util.Either;
 import org.apache.gobblin.util.ExecutorsUtils;

gobblin-runtime/src/test/java/org/apache/gobblin/runtime/DummyJobContext.java

@@ -51,12 +51,6 @@ public DummyJobContext(Properties jobProps, Logger logger, Map<String, JobState.
     this.datasetStateMap = datasetStateMap;
   }
 
-  @Override
-  protected FsDatasetStateStore createStateStore(Config config)
-      throws IOException {
-    return new NoopDatasetStateStore(FileSystem.getLocal(new Configuration()), "");
-  }
-
   @Override
   protected Optional<JobHistoryStore> createJobHistoryStore(Properties jobProps) {
     return Optional.absent();