Apache Beam TextIO wildcard on local files -
i can't use wildcard character "*" textio , local files underlying library doesn't seem support according exception below. code works fine wildcards if use google cloud storage path. need escape wildcards in way?
java.lang.reflect.invocationtargetexception @ sun.reflect.nativemethodaccessorimpl.invoke0(native method) @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:62) @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43) @ java.lang.reflect.method.invoke(method.java:498) @ org.codehaus.mojo.exec.execjavamojo$1.run(execjavamojo.java:293) @ java.lang.thread.run(thread.java:745) caused by: java.nio.file.invalidpathexception: illegal char <*> @ index 36: c:\input\* @ sun.nio.fs.windowspathparser.normalize(windowspathparser.java:182) @ sun.nio.fs.windowspathparser.parse(windowspathparser.java:153) @ sun.nio.fs.windowspathparser.parse(windowspathparser.java:77) @ sun.nio.fs.windowspath.parse(windowspath.java:94) @ sun.nio.fs.windowsfilesystem.getpath(windowsfilesystem.java:255) @ java.nio.file.paths.get(paths.java:84) @ org.apache.beam.sdk.util.fileiochannelfactory.spectofile(fileiochannelfactory.java:81) @ org.apache.beam.sdk.util.fileiochannelfactory.match(fileiochannelfactory.java:92) @ my.package.xmlrawio$read$bound.expand(xmlrawio.java:235) @ my.package.xmlrawio$read$bound.expand(xmlrawio.java:151) @ org.apache.beam.sdk.pipeline.applyinternal(pipeline.java:475) @ org.apache.beam.sdk.pipeline.applytransform(pipeline.java:389) @ org.apache.beam.sdk.values.pbegin.apply(pbegin.java:47) @ org.apache.beam.sdk.pipeline.apply(pipeline.java:160) @ my.package.pushenactortransactions.main(pushtransactions.java:70) ... 6 more
historically, there issue support local file system in apache beam didn't support pattern matching on windows os. didn't apply in other case -- local file system on other operating systems, google cloud storage on operating system, etc. worked expected.
there plenty of improvements in area recently, , there more in progress. believe specific exception fixed, i'd encourage try again newer version.
Comments
Post a Comment