[Feature] Transaction isolation that supports the Serializable isolation level

[Zouxxyy]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Currently, the transaction isolation level of paimon is snapshot level. For the following concurrent modification scenarios, incorrect data may occur

sql("create table t1 (id int, c1 string, c2 string) using paimon tblproperties('primary-key'='id')")

sql("insert into t1 values (1, 'a', 'a')")

val update1 = Future {
  sql("update t1 set c1 = 'b' where id = 1")
}

val update2 = Future {
  sql("update t1 set c2 = 'c' where id = 1")
}
Await.result(update1, 1000.seconds)
Await.result(update2, 1000.seconds)

sql("select * from t1").show()

The output result may be any of 1, 'b', 'a' 1, 'a', 'c' or 1, 'b', 'c'

Solution

No response

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!