Hello,
when trying to import a graph using flat files, I get the following error message. Vertex file has been loaded perfectly, while the edge file causes the error.
Snippet of the edge file:
1327118,113821,112274,PartOf,validTo,5,,,9999-12-31T00:00:00.000+01:00
1327120,114495,112276,PartOf,validFrom,5,,,2018-01-01T00:00:00.000+01:00
1327120,114495,112276,PartOf,validTo,5,,,9999-12-31T00:00:00.000+01:00
1327121,116006,112276,PartOf,validFrom,5,,,2018-01-01T00:00:00.000+01:00
Vertex file:
121122,materialNumber,1,7373188,,,Material
121122,sparePart,6,Y,,,Material
121122,wearPart,6,N,,,Material
121123,materialNumber,1,7829936,,,Material
121123,sparePart,6,Y,,,Material
121123,wearPart,6,N,,,Material
Stacktrace:
12:50:37,726 ERROR SimpleLog - call(EdgeFileSplitter): exception found. Exception is
java.io.IOException: Pipe closed
at java.io.PipedInputStream.checkStateForReceive(PipedInputStream.java:260) ~[?:?]
at java.io.PipedInputStream.receive(PipedInputStream.java:226) ~[?:?]
at java.io.PipedOutputStream.write(PipedOutputStream.java:149) ~[?:?]
at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:233) ~[?:?]
at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:303) ~[?:?]
at sun.nio.cs.StreamEncoder.implWrite(StreamEncoder.java:281) ~[?:?]
at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:125) ~[?:?]
at sun.nio.cs.StreamEncoder.write(StreamEncoder.java:135) ~[?:?]
at java.io.OutputStreamWriter.write(OutputStreamWriter.java:229) ~[?:?]
at java.io.Writer.write(Writer.java:249) ~[?:?]
at oracle.pg.common.loader.OracleFlatFileSplitter.processFile(OracleFlatFileSplitter.java:397) ~[opg-dal_common-20.1.0.jar:?]
at oracle.pg.common.loader.OracleFlatFileSplitter.call(OracleFlatFileSplitter.java:188) [opg-dal_common-20.1.0.jar:?]
at oracle.pg.common.loader.OracleFlatFileSplitter.call(OracleFlatFileSplitter.java:32) [opg-dal_common-20.1.0.jar:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
12:50:37,726 DEBUG SimpleLog - (EdgeFileSplitter) closeResources: close buffered reader
12:50:37,727 DEBUG SimpleLog - (EdgeFileSplitter) closeResources: close output stream writer (pipe) 0
12:50:37,727 DEBUG SimpleLog - (EdgeFileSplitter) closeResources: close output stream 1
| Exception java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.io.IOException: Pipe closed
| at FutureTask.report (FutureTask.java:122)
| at FutureTask.get (FutureTask.java:191)
| at OracleFlatFileGraphLoader.executeFileSplitAndGraphLoadingTasks (OracleFlatFileGraphLoader.java:93)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:904)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:833)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:522)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:752)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:658)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:626)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:590)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:563)
| at OraclePropertyGraphDataLoader.loadData (OraclePropertyGraphDataLoader.java:117)
| at (#15:1)
| Caused by: java.lang.RuntimeException: java.io.IOException: Pipe closed
| at OracleFlatFileSplitter.call (OracleFlatFileSplitter.java:215)
| at OracleFlatFileSplitter.call (OracleFlatFileSplitter.java:32)
| at FutureTask.run (FutureTask.java:264)
| at Executors$RunnableAdapter.call (Executors.java:515)
| at FutureTask.run (FutureTask.java:264)
| at ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1128)
| at ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:628)
| at Thread.run (Thread.java:834)
| Caused by: java.io.IOException: Pipe closed
| at PipedInputStream.checkStateForReceive (PipedInputStream.java:260)
| at PipedInputStream.receive (PipedInputStream.java:226)
| at PipedOutputStream.write (PipedOutputStream.java:149)
| at StreamEncoder.writeBytes (StreamEncoder.java:233)
| at StreamEncoder.implWrite (StreamEncoder.java:303)
| at StreamEncoder.implWrite (StreamEncoder.java:281)
| at StreamEncoder.write (StreamEncoder.java:125)
| at StreamEncoder.write (StreamEncoder.java:135)
| at OutputStreamWriter.write (OutputStreamWriter.java:229)
| at Writer.write (Writer.java:249)
| at OracleFlatFileSplitter.processFile (OracleFlatFileSplitter.java:397)
| at OracleFlatFileSplitter.call (OracleFlatFileSplitter.java:188)
| ...
opg-jshell-rdbms> opgdl.loadData(opg, vfile, efile, 1, 1000, true, "PDDL=T,PDML=T,KEEP_WORK_TABS=T,KEEP_TMP_FILES=T,NO_DUP=T")
With the following call: opgdl.loadData(opg, vfile, efile, 1, 1000, true, "PDDL=T,PDML=T,KEEP_WORK_TABS=T,KEEP_TMP_FILES=T,NO_DUP=T")