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

Popular posts from this blog

Command prompt result in label. Python 2.7 -

javascript - How do I use URL parameters to change link href on page? -

amazon web services - AWS Route53 Trying To Get Site To Resolve To www -