You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by deanding <di...@gmail.com> on 2018/04/23 21:33:20 UTC
Re: [jira] [Created] (FLINK-9075) BucketingSink S3 does not work on
local cluster
Hi,
I have the similar issue when I was trying running on HDFS
java.io.IOException: Error opening the Input Split
hdfs://localhost:9000/user/yliu/test_big.csv [0,111513]: Provider for class
javax.xml.parsers.DocumentBuilderFactory cannot be created
at
org.apache.flink.api.common.io.FileInputFormat.open(FileInputFormat.java:705)
at
org.apache.flink.api.common.io.DelimitedInputFormat.open(DelimitedInputFormat.java:477)
at
org.apache.flink.api.common.io.GenericCsvInputFormat.open(GenericCsvInputFormat.java:301)
at org.apache.flink.api.java.io.CsvInputFormat.open(CsvInputFormat.java:53)
at org.apache.flink.api.java.io.CsvInputFormat.open(CsvInputFormat.java:36)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:145)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
at java.lang.Thread.run(Thread.java:745)
Caused by: javax.xml.parsers.FactoryConfigurationError: Provider for class
javax.xml.parsers.DocumentBuilderFactory cannot be created
at
javax.xml.parsers.FactoryFinder.findServiceProvider(FactoryFinder.java:311)
at javax.xml.parsers.FactoryFinder.find(FactoryFinder.java:267)
at
javax.xml.parsers.DocumentBuilderFactory.newInstance(DocumentBuilderFactory.java:120)
at
org.apache.hadoop.conf.Configuration.loadResource(Configuration.java:2516)
at
org.apache.hadoop.conf.Configuration.loadResources(Configuration.java:2492)
at org.apache.hadoop.conf.Configuration.getProps(Configuration.java:2405)
at org.apache.hadoop.conf.Configuration.get(Configuration.java:981)
at org.apache.hadoop.conf.Configuration.getTrimmed(Configuration.java:1031)
at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2189)
at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2654)
at
org.apache.flink.runtime.fs.hdfs.HadoopFsFactory.create(HadoopFsFactory.java:99)
at
org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:401)
at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:320)
at
org.apache.flink.api.common.io.FileInputFormat$InputSplitOpenThread.run(FileInputFormat.java:864)
Anyone help?
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/