Fixed build failures

Signed-off-by: Kondaka <krishkdk@amazon.com>

Author: kkondaka

data-prepper-pipeline-parser/src/main/java/org/opensearch/dataprepper/pipeline/parser/model/PipelineConfiguration.java

@@ -137,7 +137,7 @@ private static SinkContextPluginSetting getSinkContextPluginSettingFromSinkModel
         final Map<String, Object> settingsMap = Optional
                 .ofNullable(sinkModel.getPluginSettings())
                 .orElseGet(HashMap::new);
-        return new SinkContextPluginSetting(sinkModel.getPluginName(), settingsMap, new SinkContext(sinkModel.getTagsTargetKey(), sinkModel.getRoutes(), sinkModel.getIncludeKeys(), sinkModel.getExcludeKeys(), sinkModel.getForwardPipelineNames()));
+        return new SinkContextPluginSetting(sinkModel.getPluginName(), settingsMap, new SinkContext(sinkModel.getTagsTargetKey(), sinkModel.getRoutes(), sinkModel.getIncludeKeys(), sinkModel.getExcludeKeys(), sinkModel.getForwardConfig().getPipelineNames()));
     }
 
     private Integer getWorkersFromPipelineModel(final PipelineModel pipelineModel) {

data-prepper-plugins/common/src/main/java/org/opensearch/dataprepper/plugins/sink/FileSink.java

@@ -88,7 +88,7 @@ public void output(final Collection<Record<Object>> records) {
             }
 
             if (doForward) {
-                sinkContext.forwardRecords(events);
+                sinkContext.forwardRecords(events, null, null);
             }
             try {
                 writer.flush();