Skip to content
Permalink
Browse files
Enabling quartz sync
  • Loading branch information
isururanawaka committed Sep 15, 2021
1 parent eb80b2b commit d5c535b0f0e217e851c2f520ce653336a5710dbe
Showing 2 changed files with 9 additions and 8 deletions.
@@ -32,6 +32,7 @@ datalake_repo: "https://github.com/apache/airavata-data-lake.git"
datalake_git_branch: master
kafka_listener_port: 9092
kafka_url: "{{ groups['data-lake'][0] }}:9092"
custos_kafka_url: 149.165.156.200:9092
zookeeper_client_port: 2181
zookeeper_connection_url: localhost:2181

@@ -90,7 +91,7 @@ datalake_drms_custos_host: custos.scigap.org
datalake_drms_custos_port: 31499
datalake_drms_http_port: 8900

datalake_synch_broker_url: "{{ kafka_url }}"
datalake_synch_broker_url: "{{ custos_kafka_url }}"
datalake_synch_broker_consumer_group: custosEventsGroup
datalake_synch_broker_topic: 10002640-561b67b4-fa7d-4368-8643-dcd9d0159c1d
datalake_synch_tenant_id: custos-ii8g0cfwsz6ruwezykn9-10002640
@@ -24,13 +24,13 @@ public class CustosDataFetchingJob implements Job {
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try {
LOGGER.debug("Executing CustosDataFetchingJob ....... ");
// JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
// String path = jobDataMap.getString("configurationPath");
// Configuration configuration = loadConfiguration(path);
// UserAndGroupHandler userAndGroupHandler = new UserAndGroupHandler();
// userAndGroupHandler.mergeUserAndGroups(configuration);
// SharingHandler sharingHandler = new SharingHandler();
// sharingHandler.mergeSharings(configuration);
JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
String path = jobDataMap.getString("configurationPath");
Configuration configuration = loadConfiguration(path);
UserAndGroupHandler userAndGroupHandler = new UserAndGroupHandler();
userAndGroupHandler.mergeUserAndGroups(configuration);
SharingHandler sharingHandler = new SharingHandler();
sharingHandler.mergeSharings(configuration);
} catch (Exception ex) {
String msg = "Error occurred while executing job" + ex.getMessage();
LOGGER.error(msg, ex);

0 comments on commit d5c535b

Please sign in to comment.