Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/149#discussion_r136105878
--- Diff:
mapreduce/src/main/java/org/apache/rya/accumulo/mr/RyaOutputFormat.java ---
@@ -216,12 +215,22 @@ private static FreeTextIndexer
getFreeTextIndexer(Configuration conf) {
return freeText;
}
- private static TemporalIndexer getTemporalIndexer(Configuration conf) {
+ private static TemporalIndexer getTemporalIndexer(Configuration conf)
throws IOException {
if (!conf.getBoolean(ENABLE_TEMPORAL, true)) {
return null;
}
AccumuloTemporalIndexer temporal = new AccumuloTemporalIndexer();
temporal.setConf(conf);
+ Connector connector;
+ try {
+ connector = ConfigUtils.getConnector(conf);
+ } catch (AccumuloException | AccumuloSecurityException e) {
+ throw new IOException("Error when attempting to create a
connection for writing the temporal index.", e);
+ }
+ MultiTableBatchWriter mtbw =
connector.createMultiTableBatchWriter(new BatchWriterConfig());
--- End diff --
Why are you creating the multitable batch writer here? Can't you use the
same batchwriter that the other indexes are using? Have your
getTemporalIndexer(...) method take in a MultiTableBatchWriter as well.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
