Hive can't update transactional table which created by trino

[boson234]

hi,
I create a trancational table with trino 410 ,and insert some rows, and I can update rows with trion success.
howerver, when I try to update data for this table with hive,it failed.
my hive version is 3.1.0
create table trino_11 with (transactional =true) as select * from (values(1),(2),(3)) as t1(a);

here is the error log on Mapreduce

[bitsondatadev]

Have you created an equivalent table in Hive and it was successful?

[boson234]

yes，all that in hive works.

…

---Original--- From: ***@***.***> Date: Fri, Mar 10, 2023 19:38 PM To: ***@***.***>; Cc: ***@***.******@***.***>; Subject: Re: [trinodb/trino] Hive can't update transactional table whichcreated by trino (Discussion #16488) Have you created an equivalent table in Hive and it was successful? — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***>

[bitsondatadev]

@djsstarburst or @findepi, any ideas as to what could be causing this? I believe this worked on a previous version of Hive.

[boson234]

bucket count!!! trino is 0 but hive is -1

I add codes to set NumBucket to -1
in ThriftMetastoreUtil.makeStorageDescriptor
and it works

[djsstarburst]

I was unable to reproduce the UPDATE failure. This test added to TestHiveTransactionalTable passes. I'm running Trino tip master and Hive version 3.1.2-20:

    @Test
    public void testIncorrectBucketCount()
    {
        String tableName = "trino_11_" + randomNameSuffix();
        onTrino().executeQuery("create table %s with (transactional = true) as select * from (values(1),(2),(3)) as t1(a)".formatted(tableName));
        onHive().executeQuery("UPDATE %s SET a = a + 4 WHERE a = 1".formatted(tableName));
        verifySelectForTrinoAndHive("SELECT * FROM " + tableName, row(5), row(2), row(3));
        onTrino().executeQuery("UPDATE %s SET a = a + 4 WHERE a = 5".formatted(tableName));
        verifySelectForTrinoAndHive("SELECT * FROM " + tableName, row(9), row(2), row(3));
        onTrino().executeQuery("DROP TABLE " + tableName);
    }

[boson234]

I was unable to reproduce the UPDATE failure. This test added to TestHiveTransactionalTable passes. I'm running Trino tip master and Hive version 3.1.2-20:

    @Test
    public void testIncorrectBucketCount()
    {
        String tableName = "trino_11_" + randomNameSuffix();
        onTrino().executeQuery("create table %s with (transactional = true) as select * from (values(1),(2),(3)) as t1(a)".formatted(tableName));
        onHive().executeQuery("UPDATE %s SET a = a + 4 WHERE a = 1".formatted(tableName));
        verifySelectForTrinoAndHive("SELECT * FROM " + tableName, row(5), row(2), row(3));
        onTrino().executeQuery("UPDATE %s SET a = a + 4 WHERE a = 5".formatted(tableName));
        verifySelectForTrinoAndHive("SELECT * FROM " + tableName, row(9), row(2), row(3));
        onTrino().executeQuery("DROP TABLE " + tableName);
    }

maybe the hive version I used has some difference from open source hive.