Skip to content

Commit a545e0f

Browse files
committed
Set job name to avoid Dataflow JDBC mode error
1 parent bd43397 commit a545e0f

File tree

1 file changed

+6
-7
lines changed
  • pipelines/batch/src/main/java/com/google/fhir/analytics

1 file changed

+6
-7
lines changed

Diff for: pipelines/batch/src/main/java/com/google/fhir/analytics/FhirEtl.java

+6-7
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,9 @@
2828
import com.google.fhir.analytics.view.ViewDefinitionException;
2929
import java.io.IOException;
3030
import java.sql.SQLException;
31-
import java.util.ArrayList;
32-
import java.util.Arrays;
33-
import java.util.Collections;
34-
import java.util.HashSet;
35-
import java.util.List;
36-
import java.util.Map;
37-
import java.util.Set;
31+
import java.time.LocalDateTime;
32+
import java.time.format.DateTimeFormatter;
33+
import java.util.*;
3834
import java.util.stream.Collectors;
3935
import javax.sql.DataSource;
4036
import org.apache.avro.generic.GenericRecord;
@@ -330,6 +326,9 @@ private static List<Pipeline> buildHapiJdbcPipeline(FhirEtlOptions options)
330326

331327
totalNumOfResources += numResources;
332328
foundResource = true;
329+
330+
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS");
331+
options.setJobName(resourceType + System.currentTimeMillis());
333332
Pipeline pipeline = Pipeline.create(options);
334333
PCollection<QueryParameterDescriptor> queryParameters =
335334
pipeline.apply(

0 commit comments

Comments
 (0)