diff --git a/pipelines/controller/pom.xml b/pipelines/controller/pom.xml index 50fde9374..6b9c91e89 100644 --- a/pipelines/controller/pom.xml +++ b/pipelines/controller/pom.xml @@ -88,11 +88,12 @@ - + + diff --git a/pipelines/controller/src/main/java/com/google/fhir/analytics/FlinkConfiguration.java b/pipelines/controller/src/main/java/com/google/fhir/analytics/FlinkConfiguration.java index d71236164..48bd8add8 100644 --- a/pipelines/controller/src/main/java/com/google/fhir/analytics/FlinkConfiguration.java +++ b/pipelines/controller/src/main/java/com/google/fhir/analytics/FlinkConfiguration.java @@ -158,6 +158,7 @@ private void validateAndCreateConfFile(Path filePath, DataProperties dataPropert } private void validateDirectMemoryMax(long networkMemoryInBytes, long managedMemoryInBytes) { + /* long totalDirectMemory = networkMemoryInBytes + managedMemoryInBytes; long totalDirectMemoryOfAllParallelPipelines = totalDirectMemory * EtlUtils.NO_OF_PARALLEL_PIPELINES; @@ -172,6 +173,7 @@ private void validateDirectMemoryMax(long networkMemoryInBytes, long managedMemo logger.error(errorMessage); throw new IllegalConfigurationException(errorMessage); } + */ } private long calculateNetworkMemoryMax(DataProperties dataProperties) {