关于创建/插入数据到配置单元的带扣表中的建议。
我读了些书(https://cwiki.apache.org/confluence/display/hive/languagemanual+ddl+bucketedtables)尝试了一些选择,但没有成功。
当前运行insert时出现以下错误: Error while processing statement: FAILED: Execution Error, return code 3 from org.apache.hadoop.hive.ql.exec.spark.SparkTask
创建代码: CREATE test_in ( id VARCHAR(250), field_1 VARCHAR(250), field_2 VARCHAR(250), field_3 VARCHAR(250), field_4 VARCHAR(250), field_5 VARCHAR(250) ) PARTITIONED BY(ds STRING) CLUSTERED BY(id) into 10 buckets STORED AS orc tblproperties("orc.compress"="NONE","transactional"="true");
插入代码: INSERT INTO TABLE test_in VALUES ( '9gD0xQxOYS', 'ZhQbTjUGLhz8KuQ', 'SmszyJHEqIVAeK8gAFVx', 'RvbRdU7ia1AMHhaXd9tOgLEzi', 'a010E000004uJt8QAE', 'yh6phK4ZG7W4JaOdoOhDJXNJgmcoZU' )
需要帮助为create/insert语句创建正确的语法,并对配置单元中的bucketing进行一些解释。
1条答案
按热度按时间55ooxyrt1#
创建语句-单词
table
不见了(可能是打字错误)insert语句-缺少分区详细信息。插入操作期间需要分区值,因为它是分区表。
正确和有效的查询如下:,
创建语句:
插入语句:
希望这有帮助!