Commit 1361d0cb by Shwetha GS

loading properties from conf directory in deployment

parent 0cdacb1d
...@@ -208,7 +208,7 @@ ...@@ -208,7 +208,7 @@
<value>${project.build.directory}/logs</value> <value>${project.build.directory}/logs</value>
</systemProperty> </systemProperty>
<systemProperty> <systemProperty>
<name>metadata.properties.location</name> <name>metadata.conf</name>
<value>addons/hive-bridge/src/test/resources</value> <value>addons/hive-bridge/src/test/resources</value>
</systemProperty> </systemProperty>
</systemProperties> </systemProperties>
......
...@@ -20,18 +20,31 @@ package org.apache.hadoop.metadata; ...@@ -20,18 +20,31 @@ package org.apache.hadoop.metadata;
import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.commons.configuration.PropertiesConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File; import java.io.File;
import java.net.MalformedURLException;
import java.net.URL;
public class PropertiesUtil { public class PropertiesUtil {
private static final Logger LOG = LoggerFactory.getLogger(PropertiesUtil.class);
private static final String APPLICATION_PROPERTIES = "application.properties"; private static final String APPLICATION_PROPERTIES = "application.properties";
public static final PropertiesConfiguration getApplicationProperties() throws ConfigurationException { public static final PropertiesConfiguration getApplicationProperties() throws MetadataException {
String proprtiesLocation = System.getProperty("metadata.properties.location"); String confLocation = System.getProperty("metadata.conf");
if (proprtiesLocation == null) { URL url;
return new PropertiesConfiguration(PropertiesUtil.class.getResource("/" + APPLICATION_PROPERTIES)); try {
} else { if (confLocation == null) {
return new PropertiesConfiguration(new File(proprtiesLocation, APPLICATION_PROPERTIES)); url = PropertiesUtil.class.getResource("/" + APPLICATION_PROPERTIES);
} else {
url = new File(confLocation, APPLICATION_PROPERTIES).toURI().toURL();
}
LOG.info("Loading {} from {}", APPLICATION_PROPERTIES, url);
return new PropertiesConfiguration(url);
} catch (Exception e) {
throw new MetadataException("Failed to load application properties", e);
} }
} }
} }
...@@ -21,6 +21,7 @@ package org.apache.hadoop.metadata.discovery; ...@@ -21,6 +21,7 @@ package org.apache.hadoop.metadata.discovery;
import com.thinkaurelius.titan.core.TitanGraph; import com.thinkaurelius.titan.core.TitanGraph;
import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.commons.configuration.PropertiesConfiguration;
import org.apache.hadoop.metadata.MetadataException;
import org.apache.hadoop.metadata.PropertiesUtil; import org.apache.hadoop.metadata.PropertiesUtil;
import org.apache.hadoop.metadata.discovery.graph.DefaultGraphPersistenceStrategy; import org.apache.hadoop.metadata.discovery.graph.DefaultGraphPersistenceStrategy;
import org.apache.hadoop.metadata.discovery.graph.GraphBackedDiscoveryService; import org.apache.hadoop.metadata.discovery.graph.GraphBackedDiscoveryService;
...@@ -70,7 +71,7 @@ public class HiveLineageService implements LineageService { ...@@ -70,7 +71,7 @@ public class HiveLineageService implements LineageService {
conf.getString("metadata.lineage.hive.process.inputs.name", "inputTables"); conf.getString("metadata.lineage.hive.process.inputs.name", "inputTables");
HIVE_PROCESS_OUTPUT_ATTRIBUTE_NAME = HIVE_PROCESS_OUTPUT_ATTRIBUTE_NAME =
conf.getString("metadata.lineage.hive.process.outputs.name", "outputTables"); conf.getString("metadata.lineage.hive.process.outputs.name", "outputTables");
} catch (ConfigurationException e) { } catch (MetadataException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
......
...@@ -23,6 +23,7 @@ import com.thinkaurelius.titan.core.TitanGraph; ...@@ -23,6 +23,7 @@ import com.thinkaurelius.titan.core.TitanGraph;
import org.apache.commons.configuration.Configuration; import org.apache.commons.configuration.Configuration;
import org.apache.commons.configuration.ConfigurationException; import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.commons.configuration.PropertiesConfiguration;
import org.apache.hadoop.metadata.MetadataException;
import org.apache.hadoop.metadata.PropertiesUtil; import org.apache.hadoop.metadata.PropertiesUtil;
import javax.inject.Singleton; import javax.inject.Singleton;
...@@ -38,7 +39,7 @@ public class TitanGraphProvider implements GraphProvider<TitanGraph> { ...@@ -38,7 +39,7 @@ public class TitanGraphProvider implements GraphProvider<TitanGraph> {
*/ */
private static final String METADATA_PREFIX = "metadata.graph."; private static final String METADATA_PREFIX = "metadata.graph.";
private static Configuration getConfiguration() throws ConfigurationException { private static Configuration getConfiguration() throws MetadataException {
PropertiesConfiguration configProperties = PropertiesUtil.getApplicationProperties(); PropertiesConfiguration configProperties = PropertiesUtil.getApplicationProperties();
Configuration graphConfig = new PropertiesConfiguration(); Configuration graphConfig = new PropertiesConfiguration();
...@@ -62,7 +63,7 @@ public class TitanGraphProvider implements GraphProvider<TitanGraph> { ...@@ -62,7 +63,7 @@ public class TitanGraphProvider implements GraphProvider<TitanGraph> {
Configuration config; Configuration config;
try { try {
config = getConfiguration(); config = getConfiguration();
} catch (ConfigurationException e) { } catch (MetadataException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
......
...@@ -99,7 +99,7 @@ mkdir -p $METADATA_LOG_DIR ...@@ -99,7 +99,7 @@ mkdir -p $METADATA_LOG_DIR
pushd ${BASEDIR} > /dev/null pushd ${BASEDIR} > /dev/null
JAVA_PROPERTIES="$METADATA_OPTS $METADATA_PROPERTIES -Dmetadata.log.dir=$METADATA_LOG_DIR -Dmetadata.home=${METADATA_HOME_DIR}" JAVA_PROPERTIES="$METADATA_OPTS $METADATA_PROPERTIES -Dmetadata.log.dir=$METADATA_LOG_DIR -Dmetadata.home=${METADATA_HOME_DIR} -Dmetadata.conf=${METADATA_CONF}"
shift shift
while [[ ${1} =~ ^\-D ]]; do while [[ ${1} =~ ^\-D ]]; do
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment