From e1f289babd67830bd5c3ecaf3b6788e14d4a4817 Mon Sep 17 00:00:00 2001
From: stas-panasiuk <112094458+stas-panasiuk@users.noreply.github.com>
Date: Tue, 31 Dec 2024 10:17:06 -0500
Subject: [PATCH] ocsf schema read fix (#92)

---
 .../parserchains/queryservice/service/OcsfService.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java b/flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java
index 1cf1cd0f..aa2c1020 100644
--- a/flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java
+++ b/flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java
@@ -39,7 +39,11 @@ private byte[] readLocalFilePath(String fileName) {
                 String[] parts = uri.toString().split("!");
                 URI jarUri = URI.create(parts[0]);
                 try (FileSystem fs = FileSystems.newFileSystem(jarUri, Collections.emptyMap())) {
-                    return Files.readAllBytes(fs.getPath(parts[1]));
+                    StringBuilder filePathInsideJarBuilder = new StringBuilder();
+                    for (int i = 1; i < parts.length; i++) {
+                        filePathInsideJarBuilder.append(parts[i]);
+                    }
+                    return Files.readAllBytes(fs.getPath(filePathInsideJarBuilder.toString()));
                 } catch (IOException e) {
                     throw new RuntimeException(e);
                 }