如何从配置单元更新dynamodb表

c6ubokkw  于 2021-06-27  发布在  Hive
关注(0)|答案(1)|浏览(324)

我已经创建了一个连接到dynamodb的外部配置单元表,因此可以从配置单元将数据插入dynamodb表。但是现在,我希望能够更新表。我尝试在配置单元表上启用事务,以便可以在配置单元表上使用update命令。但我得到了一个错误:

FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. MetaException(message:The table must be bucketed and stored using an ACID compliant format (such as ORC))

所以,我的问题是如何从配置单元更新dynamodb表?

c9qzyr3d

c9qzyr3d1#

我认为您需要在您的配置单元脚本的顶部添加以下内容:

SET hive.txn.manager = org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
SET hive.enforce.bucketing = true;

可能还有并发性:

SET hive.support.concurrency = true;

文档似乎表明更新的dynamodb非常简单:
https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/emrfordynamodb.tutorial.copydatatoddb.html

相关问题