草庐IT

schema_uri

全部标签

java - 失败 : IllegalArgumentException java.net.URISyntaxException:绝对 URI 中的相对路径:

我的hive-site.xml配置是当我使用配置单元时:显示数据库;我遇到的异常是:FAILED:IllegalArgumentExceptionjava.net.URISyntaxException:RelativepathinabsoluteURI:file:./tmp/hive-root/root/74dc7e51-1d24-4397-9321-9b8c651ee212/hive_2016-12-04_22-55-36_784_2074916962149947374-1 最佳答案 使用以下属性更改hive-site.xmlhi

hadoop - pig 帮 : How can I add a fixed field that is not defined in the schema

如何添加架构中未定义的固定字段(例如日期或月份)?我运行了以下pig脚本以将固定日期添加到我的结果表中,并收到以下错误消息:Invalidfieldprojection。方案中不存在投影字段[日期]。joined_table=joinAby(key1),Bby(key1);result=foreachjoined_tablegenerate20140625asdate,A::value1asv1,B::value1asv2; 最佳答案 这是你可能想要的:result=FOREACHjoined_tableGENERATE'20140

hadoop - 线程 "main"java.io.IOException : Incomplete HDFS URI, 中的异常没有主机:hdfs Spark RDD

我正在尝试使用Spark将文本文件的内容保存在hdfs中:importorg.apache.spark.{SparkContext,SparkConf}objectFormatTlfHdfs{defmain(args:Array[String]){valconf=newSparkConf().setAppName("Cleandata").setMaster("local").setSparkHome("/usr/lib/spark")valsc=newSparkContext(conf)varvertices=sc.textFile("hdfs:///user/cloudera/ds

hadoop - 如何防止 `hadoop fs rmr <uri>` 创建 $folder$ 文件?

我们正在使用Amazon的ElasticMapReduce来执行一些大型文件处理作业。作为我们工作流程的一部分,我们偶尔需要从S3中删除可能已经存在的文件。我们使用hadoopfs接口(interface)这样做,如下所示:hadoopfs-rmrs3://mybucket/a/b/myfile.log这会适本地从S3中删除文件,但会在原处留下一个名为“s3://mybucket/a/b_$folder$”的空文件。如thisquestion中所述,Hadoop的Pig无法处理这些文件,因此工作流中的后续步骤可能会因该文件而阻塞。(请注意,我们使用-rmr还是-rm还是使用s3://似

java - Avro Schema Evolution With GenericData.Record - Mapreduce 过程

我有一个mapreduce程序,它从avro数据中读取数据,对其进行处理并输出avro数据。我有这个avro数据的模式,假设有4列。我使用GenericData.Record来写入avro数据。现在,我使用具有5列的模式在此数据之上创建一个pig关系。第5列是新的,具有avsc文件中定义的默认值。根据我的理解,我应该能够使用带有一列的新模式读取旧数据(由4列生成)。相反,我收到一条错误消息-Tryingtoaccessnon-existcolumn.我错过了什么?Mapreduce驱动程序代码Jobjob=Job.getInstance(getConf());job.setJarByC

java - 使用指向 HDFS 的 URI 创建文件实例

是否可以通过将我的HDFS的uri作为File类的构造函数来创建文件实例?例如:valconf=newConfiguration()conf.addResource(hdfsCoreSitePath)conf.addResource(hdfsHDFSSitePath)valuri=conf.get("fs.default.name")valfile=newFile(uri+pathtothefile)然后,对于文件实例,我希望使用File类提供的函数访问文件列表,例如file.list()以返回命名文件和目录的字符串数组此抽象路径名表示的目录。我尝试了代码,但它在file.list()

hadoop - 如何使用 Hive 显示 Information Schema?

有什么方法可以使用Hive实现information_schema吗?另外,在Hive中进行数据分析的过程是什么?在SQL中,我们使用Information_Schema的示例如下:SELECT*FROMINFORMATION_SCHEMA.TABLES; 最佳答案 information_schema没有在Hive中实现,有一个openJIRA对于相同的。默认情况下,Hive使用Derby作为Metastore来存储表元数据。通过连接到Derby,可以看到系统表。 关于hadoop-如

hadoop - 指向本地文件的 AvroStorage schema_uri 不起作用

我像这样使用AvroStorage:STOREaliasINTO'$OUTPUT'USINGorg.apache.pig.piggybank.storage.avro.AvroStorage('{"index":1,"schema_uri":"file://path/schema.avsc"}');因此,从本地文件系统而不是HDFS获取schema.avsc是明确的。它在伪分布式集群中工作,但在模式文件的java.io.FileNotFoundException的普通集群上失败看起来这是在后端发生的。我假设这是因为AvroStorage在一个节点上的后端调用,与我运行pig脚本的节点不

hadoop - 所需表缺失 : "DBS" in Catalog "" Schema ""

我正在尝试在我的Windows机器上运行Hive。但是,当我尝试从C:\hadoop-2.7.1\hive-2.1.0\bin>hive运行命令时,出现以下错误。Requiredtablemissing:"DBS"inCatalog""Schema"".DataNucleusrequiresthistabletoperformitspersistenceoperations.EitheryourMetaDataisincorrect,oryouneedtoenable"datanucleus.schema.autoCreateTables"org.datanucleus.store.r

hadoop - Pig Schema 错误意外字符 ':'

我正在尝试使用2B:chararray作为一列的名称来创建一个pig模式。它给我一个错误信息2B:chararrayUnexpectedcharacter':'如果删除了该架构,则会创建该架构。这里有什么问题?架构是load'Batting.csv'usingorg.apache.pig.piggybank.storage.CSVExcelStorage(',','YES_MULTILINE','NOCHANGE','SKIP_INPUT_HEADER')as(yearID:int,sting:chararray,teamID:chararray,lgID:chararray,G:ch