From 17f250a9137546ccda001413575aa8f2fb6a7d85 Mon Sep 17 00:00:00 2001 From: Kai Date: Thu, 27 Aug 2020 15:54:11 +0800 Subject: Add des module in datalake-handler Issue-ID: DCAEGEN2-2230 Signed-off-by: Kai Lu Change-Id: I13a4907462edc68ec26523bf856083b21b32dee7 --- components/datalake-handler/des/pom.xml | 5 +++-- .../org/onap/datalake/des/controller/DataExposureController.java | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) (limited to 'components/datalake-handler/des') diff --git a/components/datalake-handler/des/pom.xml b/components/datalake-handler/des/pom.xml index c0346ce9..9554052f 100644 --- a/components/datalake-handler/des/pom.xml +++ b/components/datalake-handler/des/pom.xml @@ -27,13 +27,13 @@ org.onap.dcaegen2.services.components datalake-handler - 1.2.0-SNAPSHOT + 1.1.0-SNAPSHOT org.onap.dcaegen2.services.components.datalake-handler des jar - DataLake Exposure Service + DataLake Extraction Service 2.9.2 @@ -228,6 +228,7 @@ org.onap.dcaegen2.services.components.datalake-handler feeder + ${project.version} diff --git a/components/datalake-handler/des/src/main/java/org/onap/datalake/des/controller/DataExposureController.java b/components/datalake-handler/des/src/main/java/org/onap/datalake/des/controller/DataExposureController.java index e71ba6b0..925afb89 100644 --- a/components/datalake-handler/des/src/main/java/org/onap/datalake/des/controller/DataExposureController.java +++ b/components/datalake-handler/des/src/main/java/org/onap/datalake/des/controller/DataExposureController.java @@ -102,7 +102,7 @@ public class DataExposureController { String query = sub.replace(sqlTemplate); log.info("Going to start Datalake Data Exposure Service ... query=" + query); // https://prestodb.io/docs/current/installation/jdbc.html - String url = String.format("jdbc:presto://dl-presto:8080/%s/%s", dataExposure.getDb().getPrestoCatalog(), + String url = String.format("jdbc:presto://dl-presto:8080/%s/%s", dataExposure.getDb().getHost(), dataExposure.getDb().getDatabase()); Properties properties = new Properties(); properties.setProperty("user", "test"); -- cgit