From 609c107b074281746c3d1a729d774c5301a65077 Mon Sep 17 00:00:00 2001 From: Bashir Sadjad Date: Wed, 21 Aug 2024 22:07:58 +0000 Subject: [PATCH] temporary commit to show how to use spring-boot:run --- pipelines/controller/pom.xml | 5 +++-- .../java/com/google/fhir/analytics/FlinkConfiguration.java | 2 ++ 2 files changed, 5 insertions(+), 2 deletions(-) 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) {