Github user pvillard31 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2663#discussion_r184788317
--- Diff:
nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/SiteToSiteBulletinReportingTask.java
---
@@ -76,10 +81,16 @@
private volatile long lastSentBulletinId = -1L;
+ public SiteToSiteBulletinReportingTask() throws IOException {
+ final InputStream schema =
getClass().getClassLoader().getResourceAsStream("schema-bulletins.avsc");
+ recordSchema = AvroTypeUtil.createSchema(new
Schema.Parser().parse(schema));
+ }
+
@Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
final List<PropertyDescriptor> properties = new
ArrayList<>(super.getSupportedPropertyDescriptors());
properties.add(PLATFORM);
+ properties.add(RECORD_WRITER);
--- End diff --
Yeah I asked myself this question... I was not sure if it'd make sense to
move it to the abstract base class in case some users implemented custom
impl... but that wouldn't break anything (just the addition of an unused
property) so it's probably cleaner to have it in the abstract class. What's
your feeling?
---
