MirrerZu commented on issue #6831:
URL: https://github.com/apache/seatunnel/issues/6831#issuecomment-2114916685
same result as used JDBC source.
first, insert five records into an empty table:
``` hocon
env {
parallelism = 1
job.mode = "BATCH"
}
source {
FakeSource {
schema = {
fields {
pk_id = bigint
tchar = string
}
primaryKey {
name = "pk_id"
columnNames = [pk_id]
}
}
rows = [
{
kind = INSERT
fields = [1, "AAA"]
},
{
kind = INSERT
fields = [2, "BBB"]
},
{
kind = INSERT
fields = [3, "CCC"]
},
{
kind = INSERT
fields = [4, "DDD"]
},
{
kind = INSERT
fields = [5, "EEE"]
}
]
}
}
sink {
Paimon {
warehouse = "file:///tmp/paimon"
database = "seatunnel_test"
table = "test1"
}
}
```
next, change field `tchar` to 'ZZZ' and insert:
```hocon
env {
parallelism = 1
job.mode = "BATCH"
}
source {
FakeSource {
schema = {
fields {
pk_id = bigint
tchar = string
}
primaryKey {
name = "pk_id"
columnNames = [pk_id]
}
}
rows = [
{
kind = INSERT
fields = [1, "ZZZ"]
},
{
kind = INSERT
fields = [2, "ZZZ"]
},
{
kind = INSERT
fields = [3, "ZZZ"]
},
{
kind = INSERT
fields = [4, "ZZZ"]
},
{
kind = INSERT
fields = [5, "ZZZ"]
}
]
}
}
sink {
Paimon {
warehouse = "file:///tmp/paimon"
database = "seatunnel_test"
table = "test1"
paimon.table.primary-keys = "pk_id"
paimon.table.write-props = {
bucket = 1
}
}
}
```
query results for table `test1` (even though all values of the 'tchar'
should be 'ZZZ'):
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
