Skip to content

Commit e1f289b

Browse files
ocsf schema read fix (#92)
1 parent b8be254 commit e1f289b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,11 @@ private byte[] readLocalFilePath(String fileName) {
3939
String[] parts = uri.toString().split("!");
4040
URI jarUri = URI.create(parts[0]);
4141
try (FileSystem fs = FileSystems.newFileSystem(jarUri, Collections.emptyMap())) {
42-
return Files.readAllBytes(fs.getPath(parts[1]));
42+
StringBuilder filePathInsideJarBuilder = new StringBuilder();
43+
for (int i = 1; i < parts.length; i++) {
44+
filePathInsideJarBuilder.append(parts[i]);
45+
}
46+
return Files.readAllBytes(fs.getPath(filePathInsideJarBuilder.toString()));
4347
} catch (IOException e) {
4448
throw new RuntimeException(e);
4549
}

0 commit comments

Comments
 (0)