Skip to content

Commit

Permalink
PR feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
jwomeara committed Apr 29, 2024
1 parent 949a15d commit 42fbb1c
Showing 1 changed file with 1 addition and 48 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -193,9 +193,6 @@ public void _initializeConfiguration(QueryLogicFactory queryLogicFactory, Accumu

AccumuloOutputFormat.configure().clientProperties(clientProps).createTables(true).defaultTable(tableName).store(job);
// formatter:on

// TODO: this is not supported on the new output format -- just use normal logging configuration
// AccumuloOutputFormat.loglevel
}
} catch (WebApplicationException wex) {
throw wex;
Expand Down Expand Up @@ -352,51 +349,7 @@ protected void exportSystemProperties(String id, Job job, FileSystem fs, Path cl

// Note: The logic used to submit a mapreduce query is not needed when running in the mapper
systemProperties.put(MapReduceQueryProperties.PREFIX + ".enabled", "false");

// TODO: JWO: Set properties for the data and edge dictionaries if necessary

// TODO: JWO: Set properties for the user's JWT

// TODO: JWO: What is the substitute for this?
// if (this.jsseSecurityDomain != null) {
// String useJobCacheString = systemProperties.getProperty("dw.mapreduce.securitydomain.useJobCache");
// boolean useJobCache = Boolean.parseBoolean(useJobCacheString);
// if (useJobCache) {
// try {
// String keyStoreURL = systemProperties.getProperty("dw.mapreduce.securitydomain.keyStoreURL");
// File keyStore = new File(keyStoreURL);
// Path keyStorePath = new Path(classpath, keyStore.getName());
// addSingleFile(keyStoreURL, keyStorePath, id, job, fs);
// systemProperties.setProperty("dw.mapreduce.securitydomain.keyStoreURL", keyStore.getName());
// } catch (IOException e) {
// log.error(e.getMessage(), e);
// }
// try {
// String trustStoreURL = systemProperties.getProperty("dw.mapreduce.securitydomain.trustStoreURL");
// File trustStore = new File(trustStoreURL);
// Path trustStorePath = new Path(classpath, trustStore.getName());
// addSingleFile(trustStoreURL, trustStorePath, id, job, fs);
// systemProperties.setProperty("dw.mapreduce.securitydomain.trustStoreURL", trustStore.getName());
// } catch (IOException e) {
// log.error(e.getMessage(), e);
// }
// }
//
// if (jsseSecurityDomain.getClientAlias() != null) {
// systemProperties.setProperty("dw.mapreduce.securitydomain.clientAlias", jsseSecurityDomain.getClientAlias());
// }
// if (jsseSecurityDomain.getServerAlias() != null) {
// systemProperties.setProperty("dw.mapreduce.securitydomain.serverAlias", jsseSecurityDomain.getServerAlias());
// }
// if (jsseSecurityDomain.getCipherSuites() != null) {
// systemProperties.setProperty("dw.mapreduce.securitydomain.cipherSuites", StringUtils.join(jsseSecurityDomain.getCipherSuites(), ','));
// }
// if (jsseSecurityDomain.getProtocols() != null) {
// systemProperties.setProperty("dw.mapreduce.securitydomain.protocols", StringUtils.join(jsseSecurityDomain.getProtocols(), ','));
// }
// systemProperties.setProperty("dw.mapreduce.securitydomain.clientAuth", Boolean.toString(jsseSecurityDomain.isClientAuth()));
// }


writeProperties(id, job, fs, classpath, systemProperties);
}

Expand Down

0 comments on commit 42fbb1c

Please sign in to comment.