Primary key not passed to connector node

[wenym1]

Describe the bug

I was trying to create an upsert iceberg sink from an upstream table created with schema

CREATE TABLE s1 (
    seq_id bigint, 
    user_id bigint,
    user_name varchar)                      
WITH (             
    connector = 'datagen',
    ...
);

CREATE TABLE s1 (seq_id bigint, user_id bigint,
  usercreate sink s1_sink from s1
with (              
    connector = 'iceberg',
    type='upsert',
    primary_key = 'seq_id',
    warehouse.path = 's3a://yiming-test1/iceberg',
    s3.endpoint = 'https://s3.ap-southeast-1.amazonaws.com',
    s3.access.key = '...',
    s3.secret.key = '...',
    database.name='dev', = 'random',
    table.name='table'
);

but it fails with an error try to insert a duplicated primary key in the connector node log.

I added some other log, and figure out that the TableSchema class has an empty primaryKeys.

table schema: TableSchema{columnNames=[seq_id, user_id, user_name], columns={user_id=INT64, user_name=VARCHAR, seq_id=INT64}, columnIndices={user_id=1, user_name=2, seq_id=0}, primaryKeys=[]}

To Reproduce

No response

Expected behavior

No response

Additional context

No response